Package org.apache.cassandra.db.partitions

Class UnfilteredPartitionIterators.Serializer

java.lang.Object

org.apache.cassandra.db.partitions.UnfilteredPartitionIterators.Serializer

Enclosing class:

UnfilteredPartitionIterators

public static class UnfilteredPartitionIterators.Serializer
extends Object

Serialize each UnfilteredSerializer one after the other, with an initial byte that indicates whether we're done or not.

Constructor Summary

Constructors

Constructor	Description
Serializer()

Method Summary

Modifier and Type	Method	Description
UnfilteredPartitionIterator	deserialize(DataInputPlus in, int version, TableMetadata metadata, ColumnFilter selection, DeserializationHelper.Flag flag)
void	serialize(UnfilteredPartitionIterator iter, ColumnFilter selection, DataOutputPlus out, int version)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

Serializer

public Serializer()

Method Details

serialize

public void serialize(UnfilteredPartitionIterator iter,
 ColumnFilter selection,
 DataOutputPlus out,
 int version)
               throws IOException

Throws:

IOException

deserialize

public UnfilteredPartitionIterator deserialize(DataInputPlus in,
 int version,
 TableMetadata metadata,
 ColumnFilter selection,
 DeserializationHelper.Flag flag)
                                        throws IOException

Throws:

IOException