Modifier and Type | Method and Description |
---|---|
java.util.Iterator<OnDiskAtom> |
CFMetaData.getOnDiskIterator(java.io.DataInput in,
int count,
ColumnSerializer.Flag flag,
int expireBefore,
Descriptor.Version version) |
java.util.Iterator<OnDiskAtom> |
CFMetaData.getOnDiskIterator(java.io.DataInput in,
int count,
Descriptor.Version version) |
Modifier and Type | Class and Description |
---|---|
class |
Column
Column is immutable, which prevents all kinds of confusion in a multithreaded environment.
|
class |
CounterColumn
A column that represents a partitioned counter.
|
class |
CounterUpdateColumn
A counter update while it hasn't been applied yet by the leader replica.
|
class |
DeletedColumn |
class |
ExpiringColumn
Alternative to Column that have an expiring time.
|
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) |
Modifier and Type | Method and Description |
---|---|
static java.util.Iterator<OnDiskAtom> |
SuperColumns.onDiskIterator(java.io.DataInput in,
int superColumnCount,
ColumnSerializer.Flag flag,
int expireBefore) |
static java.util.Iterator<OnDiskAtom> |
Column.onDiskIterator(java.io.DataInput in,
int count,
ColumnSerializer.Flag flag,
int expireBefore,
Descriptor.Version version)
For 2.0-formatted sstables (where column count is not stored), @param count should be Integer.MAX_VALUE,
and we will look for the end-of-row column name marker instead of relying on that.
|
Modifier and Type | Method and Description |
---|---|
void |
ColumnIndex.Builder.add(OnDiskAtom column) |
void |
ColumnFamily.addAtom(OnDiskAtom atom) |
void |
OnDiskAtom.Serializer.serializeForSSTable(OnDiskAtom atom,
java.io.DataOutput out) |
void |
RangeTombstone.Tracker.update(OnDiskAtom atom)
Update this tracker given an
atom . |
long |
RangeTombstone.Tracker.writeOpenedMarker(OnDiskAtom firstColumn,
java.io.DataOutput 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.Iterator<OnDiskAtom> |
LazilyCompactedRow.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
QueryFilter.collateOnDiskAtom(ColumnFamily returnCF,
java.util.Iterator<? extends OnDiskAtom> toCollate,
int gcBefore)
When there is only a single source of atoms, we can skip the collate step
|
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<Column> |
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 | Field and Description |
---|---|
java.util.Comparator<OnDiskAtom> |
AbstractType.onDiskAtomComparator |
Modifier and Type | Method and Description |
---|---|
OnDiskAtom |
SSTableIdentityIterator.next() |
Copyright © 2014 The Apache Software Foundation