public class SSTableIdentityIterator extends java.lang.Object implements java.lang.Comparable<SSTableIdentityIterator>, OnDiskAtomIterator
| Modifier and Type | Field and Description |
|---|---|
long |
dataSize |
ColumnSerializer.Flag |
flag |
| Constructor and Description |
|---|
SSTableIdentityIterator(SSTableReader sstable,
RandomAccessReader file,
DecoratedKey key,
long dataSize)
Used to iterate through the columns of a row.
|
SSTableIdentityIterator(SSTableReader sstable,
RandomAccessReader file,
DecoratedKey key,
long dataSize,
boolean checkData)
Used to iterate through the columns of a row.
|
| Modifier and Type | Method and Description |
|---|---|
void |
close()
clean up any open resources
|
int |
compareTo(SSTableIdentityIterator o) |
static SSTableIdentityIterator |
createFragmentIterator(SSTableReader sstable,
RandomAccessReader file,
DecoratedKey key,
long dataSize,
boolean checkData)
Used only by scrubber to solve problems with data written after the END_OF_ROW marker.
|
ColumnFamily |
getColumnFamily() |
DecoratedKey |
getKey() |
java.lang.String |
getPath() |
boolean |
hasNext() |
OnDiskAtom |
next() |
void |
remove() |
public final long dataSize
public final ColumnSerializer.Flag flag
public SSTableIdentityIterator(SSTableReader sstable, RandomAccessReader file, DecoratedKey key, long dataSize)
sstable - SSTable we are reading ffrom.file - Reading using this file.key - Key of this row.dataSize - length of row datapublic SSTableIdentityIterator(SSTableReader sstable, RandomAccessReader file, DecoratedKey key, long dataSize, boolean checkData)
sstable - SSTable we are reading ffrom.file - Reading using this file.key - Key of this row.dataSize - length of row datacheckData - if true, do its best to deserialize and check the coherence of row datapublic static SSTableIdentityIterator createFragmentIterator(SSTableReader sstable, RandomAccessReader file, DecoratedKey key, long dataSize, boolean checkData)
public DecoratedKey getKey()
getKey in interface OnDiskAtomIteratorpublic ColumnFamily getColumnFamily()
getColumnFamily in interface OnDiskAtomIteratorpublic boolean hasNext()
hasNext in interface java.util.Iterator<OnDiskAtom>public OnDiskAtom next()
next in interface java.util.Iterator<OnDiskAtom>public void remove()
remove in interface java.util.Iterator<OnDiskAtom>public void close()
OnDiskAtomIteratorclose in interface java.io.Closeableclose in interface java.lang.AutoCloseableclose in interface OnDiskAtomIteratorpublic java.lang.String getPath()
public int compareTo(SSTableIdentityIterator o)
compareTo in interface java.lang.Comparable<SSTableIdentityIterator>Copyright © 2015 The Apache Software Foundation