Modifier and Type | Method and Description |
---|---|
java.util.Iterator<OnDiskAtom> |
CFMetaData.getOnDiskIterator(java.io.DataInput in,
ColumnSerializer.Flag flag,
int expireBefore,
Descriptor.Version version) |
java.util.Iterator<OnDiskAtom> |
CFMetaData.getOnDiskIterator(java.io.DataInput in,
Descriptor.Version version) |
Modifier and Type | Interface and Description |
---|---|
interface |
Cell
Cell is immutable, which prevents all kinds of confusion in a multithreaded environment.
|
interface |
CounterCell
A column that represents a partitioned counter.
|
interface |
CounterUpdateCell
A counter update while it hasn't been applied yet by the leader replica.
|
interface |
DeletedCell |
interface |
ExpiringCell
Alternative to Cell that have an expiring time.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractCell |
class |
AbstractNativeCell
Packs a CellName AND a Cell into one off-heap representation.
|
class |
BufferCell |
class |
BufferCounterCell |
class |
BufferCounterUpdateCell |
class |
BufferDeletedCell |
class |
BufferExpiringCell |
class |
NativeCell |
class |
NativeCounterCell |
class |
NativeDeletedCell |
class |
NativeExpiringCell |
class |
RangeTombstone |
Modifier and Type | Method and Description |
---|---|
OnDiskAtom |
OnDiskAtom.Serializer.deserializeFromSSTable(java.io.DataInput in,
ColumnSerializer.Flag flag,
int expireBefore,
Descriptor.Version version) |
OnDiskAtom |
OnDiskAtom.Serializer.deserializeFromSSTable(java.io.DataInput in,
Descriptor.Version version) |
OnDiskAtom |
AtomDeserializer.readNext()
Returns the next atom.
|
Modifier and Type | Method and Description |
---|---|
static java.util.Iterator<OnDiskAtom> |
AbstractCell.onDiskIterator(java.io.DataInput in,
ColumnSerializer.Flag flag,
int expireBefore,
Descriptor.Version version,
CellNameType type) |
static java.util.Iterator<OnDiskAtom> |
SuperColumns.onDiskIterator(java.io.DataInput in,
int superColumnCount,
ColumnSerializer.Flag flag,
int expireBefore,
CellNameType type) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnIndex.Builder.add(OnDiskAtom column) |
void |
ColumnFamily.addAtom(OnDiskAtom atom) |
boolean |
DeletionTime.isDeleted(OnDiskAtom atom) |
long |
OnDiskAtom.Serializer.serializedSizeForSSTable(OnDiskAtom atom) |
void |
OnDiskAtom.Serializer.serializeForSSTable(OnDiskAtom atom,
DataOutputPlus out) |
void |
RangeTombstone.Tracker.update(OnDiskAtom atom,
boolean isExpired)
Update this tracker given an
atom . |
long |
RangeTombstone.Tracker.writeOpenedMarker(OnDiskAtom firstColumn,
DataOutputPlus out,
OnDiskAtom.Serializer atomSerializer)
Compute RangeTombstone that are needed at the beginning of an index
block starting with
firstColumn . |
Modifier and Type | Method and Description |
---|---|
ColumnIndex |
ColumnIndex.Builder.buildForCompaction(java.util.Iterator<OnDiskAtom> columns)
The important distinction wrt build() is that we may be building for a row that ends up
being compacted away entirely, i.e., the input consists only of expired tombstones (or
columns shadowed by expired tombstone).
|
Modifier and Type | Method and Description |
---|---|
protected OnDiskAtom |
LazyColumnIterator.computeNext() |
protected OnDiskAtom |
SSTableNamesIterator.computeNext() |
OnDiskAtom |
SSTableSliceIterator.next() |
Modifier and Type | Method and Description |
---|---|
java.util.Comparator<OnDiskAtom> |
AbstractCellNameType.onDiskAtomComparator() |
java.util.Comparator<OnDiskAtom> |
CellNameType.onDiskAtomComparator() |
Modifier and Type | Method and Description |
---|---|
void |
QueryFilter.collateOnDiskAtom(ColumnFamily returnCF,
java.util.Iterator<? extends OnDiskAtom> toCollate,
int gcBefore) |
static void |
QueryFilter.collateOnDiskAtom(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<? extends OnDiskAtom>> toCollate,
IDiskAtomFilter filter,
int gcBefore,
long timestamp) |
void |
QueryFilter.collateOnDiskAtom(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<? extends OnDiskAtom>> toCollate,
int gcBefore) |
static java.util.Iterator<Cell> |
QueryFilter.gatherTombstones(ColumnFamily returnCF,
java.util.Iterator<? extends OnDiskAtom> iter)
Given an iterator of on disk atom, returns an iterator that filters the tombstone range
markers adding them to
returnCF and returns the normal column. |
Modifier and Type | Method and Description |
---|---|
OnDiskAtom |
SSTableIdentityIterator.next() |
Copyright © 2014 The Apache Software Foundation