Package org.apache.cassandra.db

Class UnfilteredDeserializer

java.lang.Object

org.apache.cassandra.db.UnfilteredDeserializer

public class UnfilteredDeserializer
extends Object

Helper class to deserialize Unfiltered object from disk efficiently. More precisely, this class is used by the low-level reader to ensure we don't do more work than necessary (i.e. we don't allocate/deserialize objects for things we don't care about).

Field Summary

Fields

Modifier and Type	Field	Description
protected final DeserializationHelper	helper
protected final DataInputPlus	in
protected final TableMetadata	metadata

Method Summary

Modifier and Type	Method	Description
void	clearState()	Clears any state in this deserializer.
int	compareNextTo(ClusteringBound<?> bound)	Compare the provided bound to the next atom to read on disk.
static UnfilteredDeserializer	create(TableMetadata metadata, DataInputPlus in, SerializationHeader header, DeserializationHelper helper)
boolean	hasNext()	Whether or not there is more atom to read.
boolean	nextIsRow()	Returns whether the next atom is a row or not.
Unfiltered	readNext()	Returns the next atom.
void	skipNext()	Skips the next atom.

Methods inherited from class java.lang.Object

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

Field Details

metadata

protected final TableMetadata metadata

in

protected final DataInputPlus in

helper

protected final DeserializationHelper helper

Method Details

create

public static UnfilteredDeserializer create(TableMetadata metadata,
 DataInputPlus in,
 SerializationHeader header,
 DeserializationHelper helper)

hasNext

public boolean hasNext()
                throws IOException

Whether or not there is more atom to read.

Throws:

IOException

compareNextTo

public int compareNextTo(ClusteringBound<?> bound)
                  throws IOException

Compare the provided bound to the next atom to read on disk. This will not read/deserialize the whole atom but only what is necessary for the comparison. Whenever we know what to do with this atom (read it or skip it), readNext or skipNext should be called.

Throws:

IOException

nextIsRow

public boolean nextIsRow()
                  throws IOException

Returns whether the next atom is a row or not.

Throws:

IOException

readNext

public Unfiltered readNext()
                    throws IOException

Returns the next atom.

Throws:

IOException

clearState

public void clearState()

Clears any state in this deserializer.

skipNext

public void skipNext()
              throws IOException

Skips the next atom.

Throws:

IOException