public abstract class UnfilteredDeserializer
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected SerializationHelper |
helper |
protected DataInputPlus |
in |
protected CFMetaData |
metadata |
Modifier | Constructor and Description |
---|---|
protected |
UnfilteredDeserializer(CFMetaData metadata,
DataInputPlus in,
SerializationHelper helper) |
Modifier and Type | Method and Description |
---|---|
abstract long |
bytesReadForUnconsumedData()
For the legacy layout deserializer, we have to deal with the fact that a row can span multiple index blocks and that
the call to hasNext() reads the next element upfront.
|
abstract void |
clearState()
Clears any state in this deserializer.
|
abstract int |
compareNextTo(ClusteringBound bound)
Compare the provided bound to the next atom to read on disk.
|
static UnfilteredDeserializer |
create(CFMetaData metadata,
DataInputPlus in,
SerializationHeader header,
SerializationHelper helper) |
abstract boolean |
hasNext()
Whether or not there is more atom to read.
|
abstract boolean |
nextIsRow()
Returns whether the next atom is a row or not.
|
abstract boolean |
nextIsStatic()
Returns whether the next atom is the static row or not.
|
abstract Unfiltered |
readNext()
Returns the next atom.
|
abstract void |
skipNext()
Skips the next atom.
|
protected final CFMetaData metadata
protected final DataInputPlus in
protected final SerializationHelper helper
protected UnfilteredDeserializer(CFMetaData metadata, DataInputPlus in, SerializationHelper helper)
public static UnfilteredDeserializer create(CFMetaData metadata, DataInputPlus in, SerializationHeader header, SerializationHelper helper)
public abstract boolean hasNext() throws java.io.IOException
java.io.IOException
public abstract int compareNextTo(ClusteringBound bound) throws java.io.IOException
java.io.IOException
public abstract boolean nextIsRow() throws java.io.IOException
java.io.IOException
public abstract boolean nextIsStatic() throws java.io.IOException
java.io.IOException
public abstract Unfiltered readNext() throws java.io.IOException
java.io.IOException
public abstract void clearState() throws java.io.IOException
java.io.IOException
public abstract void skipNext() throws java.io.IOException
java.io.IOException
public abstract long bytesReadForUnconsumedData()
Copyright © 2018 The Apache Software Foundation