Class AbstractSSTableIterator.Reader
- java.lang.Object
-
- org.apache.cassandra.db.columniterator.AbstractSSTableIterator.Reader
-
- All Implemented Interfaces:
java.util.Iterator<Unfiltered>
- Enclosing class:
- AbstractSSTableIterator
protected abstract class AbstractSSTableIterator.Reader extends java.lang.Object implements java.util.Iterator<Unfiltered>
-
-
Field Summary
Fields Modifier and Type Field Description protected UnfilteredDeserializer
deserializer
FileDataInput
file
protected DeletionTime
openMarker
-
Constructor Summary
Constructors Modifier Constructor Description protected
Reader(FileDataInput file, boolean shouldCloseFile)
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description void
close()
boolean
hasNext()
protected abstract boolean
hasNextInternal()
Unfiltered
next()
protected abstract Unfiltered
nextInternal()
protected void
seekToPosition(long position)
abstract void
setForSlice(Slice slice)
protected void
updateOpenMarker(RangeTombstoneMarker marker)
-
-
-
Field Detail
-
file
public FileDataInput file
-
deserializer
protected UnfilteredDeserializer deserializer
-
openMarker
protected DeletionTime openMarker
-
-
Constructor Detail
-
Reader
protected Reader(FileDataInput file, boolean shouldCloseFile)
-
-
Method Detail
-
seekToPosition
protected void seekToPosition(long position) throws java.io.IOException
- Throws:
java.io.IOException
-
updateOpenMarker
protected void updateOpenMarker(RangeTombstoneMarker marker)
-
hasNext
public boolean hasNext()
- Specified by:
hasNext
in interfacejava.util.Iterator<Unfiltered>
-
next
public Unfiltered next()
- Specified by:
next
in interfacejava.util.Iterator<Unfiltered>
-
setForSlice
public abstract void setForSlice(Slice slice) throws java.io.IOException
- Throws:
java.io.IOException
-
hasNextInternal
protected abstract boolean hasNextInternal() throws java.io.IOException
- Throws:
java.io.IOException
-
nextInternal
protected abstract Unfiltered nextInternal() throws java.io.IOException
- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException
- Throws:
java.io.IOException
-
-