Modifier and Type | Method and Description |
---|---|
Cell |
CQL3Row.getColumn(ColumnIdentifier name) |
Cell |
UpdateParameters.makeColumn(CellName name,
java.nio.ByteBuffer value) |
Cell |
UpdateParameters.makeCounter(CellName name,
long delta) |
Cell |
UpdateParameters.makeTombstone(CellName name) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Iterator<Cell> |
ColumnCondition.Bound.collectionColumns(CellName collection,
ColumnFamily cf,
long now) |
java.util.List<Cell> |
CQL3Row.getCollection(ColumnIdentifier name) |
java.util.List<Cell> |
UpdateParameters.getPrefetchedList(java.nio.ByteBuffer rowKey,
ColumnIdentifier cql3ColumnName) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
ColumnCondition.Bound.isSatisfiedByValue(java.nio.ByteBuffer value,
Cell c,
AbstractType<?> type,
Relation.Type operator,
long now) |
Modifier and Type | Method and Description |
---|---|
CQL3Row.RowIterator |
CQL3Row.Builder.group(java.util.Iterator<Cell> cells) |
Modifier and Type | Method and Description |
---|---|
void |
Selection.ResultSetBuilder.add(Cell c) |
Modifier and Type | Interface and Description |
---|---|
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 |
Modifier and Type | Method and Description |
---|---|
static Cell |
AbstractCell.create(CellName name,
java.nio.ByteBuffer value,
long timestamp,
int ttl,
CFMetaData metadata) |
static Cell |
BufferExpiringCell.create(CellName name,
java.nio.ByteBuffer value,
long timestamp,
int timeToLive,
int localExpirationTime,
int expireBefore,
ColumnSerializer.Flag flag) |
Cell |
ColumnSerializer.deserialize(java.io.DataInput in) |
Cell |
ColumnSerializer.deserialize(java.io.DataInput in,
ColumnSerializer.Flag flag) |
Cell |
ColumnSerializer.deserialize(java.io.DataInput in,
ColumnSerializer.Flag flag,
int expireBefore) |
Cell |
AbstractCell.diff(Cell cell) |
Cell |
BufferCounterCell.diff(Cell cell) |
Cell |
BufferCounterUpdateCell.diff(Cell cell) |
Cell |
Cell.diff(Cell cell) |
Cell |
NativeCounterCell.diff(Cell cell) |
Cell |
AbstractCell.diffCounter(Cell cell) |
Cell |
ArrayBackedSortedColumns.getColumn(CellName name) |
Cell |
AtomicBTreeColumns.getColumn(CellName name) |
abstract Cell |
ColumnFamily.getColumn(CellName name)
Get a column given its name, returning null if the column is not
present.
|
Cell |
BufferCell.localCopy(CFMetaData metadata,
AbstractAllocator allocator) |
Cell |
BufferCounterUpdateCell.localCopy(CFMetaData metadata,
AbstractAllocator allocator) |
Cell |
Cell.localCopy(CFMetaData metadata,
AbstractAllocator allocator) |
Cell |
NativeCell.localCopy(CFMetaData metadata,
AbstractAllocator allocator) |
Cell |
BufferCell.localCopy(CFMetaData metadata,
MemtableAllocator allocator,
OpOrder.Group opGroup) |
Cell |
BufferCounterUpdateCell.localCopy(CFMetaData metadata,
MemtableAllocator allocator,
OpOrder.Group opGroup) |
Cell |
Cell.localCopy(CFMetaData metaData,
MemtableAllocator allocator,
OpOrder.Group opGroup) |
Cell |
NativeCell.localCopy(CFMetaData metadata,
MemtableAllocator allocator,
OpOrder.Group opGroup) |
Cell |
BufferCounterCell.markLocalToBeCleared() |
Cell |
CounterCell.markLocalToBeCleared() |
Cell |
NativeCounterCell.markLocalToBeCleared() |
Cell |
AbstractCell.reconcile(Cell cell) |
Cell |
BufferCounterCell.reconcile(Cell cell) |
Cell |
BufferCounterUpdateCell.reconcile(Cell cell) |
Cell |
BufferDeletedCell.reconcile(Cell cell) |
Cell |
BufferExpiringCell.reconcile(Cell cell) |
Cell |
Cell.reconcile(Cell cell) |
Cell |
NativeCounterCell.reconcile(Cell cell) |
Cell |
NativeDeletedCell.reconcile(Cell cell) |
Cell |
NativeExpiringCell.reconcile(Cell cell) |
Cell |
AbstractCell.reconcileCounter(Cell cell)
This is temporary until we start creating Cells of the different type (buffer vs.
|
Cell |
AbstractNativeCell.withUpdatedName(CellName newName) |
Cell |
BufferCell.withUpdatedName(CellName newName) |
Cell |
BufferCounterCell.withUpdatedName(CellName newName) |
Cell |
BufferCounterUpdateCell.withUpdatedName(CellName newName) |
Cell |
BufferDeletedCell.withUpdatedName(CellName newName) |
Cell |
BufferExpiringCell.withUpdatedName(CellName newName) |
Cell |
Cell.withUpdatedName(CellName newName) |
Cell |
AbstractNativeCell.withUpdatedTimestamp(long newTimestamp) |
Cell |
BufferCell.withUpdatedTimestamp(long newTimestamp) |
Cell |
BufferDeletedCell.withUpdatedTimestamp(long newTimestamp) |
Cell |
BufferExpiringCell.withUpdatedTimestamp(long newTimestamp) |
Cell |
Cell.withUpdatedTimestamp(long newTimestamp) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Cell> |
ArrayBackedSortedColumns.getReverseSortedColumns() |
java.util.Collection<Cell> |
AtomicBTreeColumns.getReverseSortedColumns() |
abstract java.util.Collection<Cell> |
ColumnFamily.getReverseSortedColumns()
Returns the columns of this column map as a collection.
|
java.util.Collection<Cell> |
ArrayBackedSortedColumns.getSortedColumns() |
java.util.Collection<Cell> |
AtomicBTreeColumns.getSortedColumns() |
abstract java.util.Collection<Cell> |
ColumnFamily.getSortedColumns()
Returns the columns of this column map as a collection.
|
java.util.Iterator<Cell> |
ColumnFamily.iterator() |
java.util.Iterator<Cell> |
ArrayBackedSortedColumns.iterator(ColumnSlice[] slices) |
java.util.Iterator<Cell> |
AtomicBTreeColumns.iterator(ColumnSlice[] slices) |
abstract java.util.Iterator<Cell> |
ColumnFamily.iterator(ColumnSlice[] slices)
Returns an iterator over the columns of this map that returns only the matching @param slices.
|
java.util.Iterator<Cell> |
ColumnFamily.reverseIterator() |
java.util.Iterator<Cell> |
ArrayBackedSortedColumns.reverseIterator(ColumnSlice[] slices) |
java.util.Iterator<Cell> |
AtomicBTreeColumns.reverseIterator(ColumnSlice[] slices) |
abstract java.util.Iterator<Cell> |
ColumnFamily.reverseIterator(ColumnSlice[] slices)
Returns a reversed iterator over the columns of this map that returns only the matching @param slices.
|
Modifier and Type | Method and Description |
---|---|
void |
ArrayBackedSortedColumns.addColumn(Cell cell) |
void |
AtomicBTreeColumns.addColumn(Cell column) |
abstract void |
ColumnFamily.addColumn(Cell cell)
Adds a cell to this cell map.
|
protected void |
AbstractNativeCell.construct(Cell from) |
protected void |
NativeCounterCell.construct(Cell from) |
protected void |
NativeExpiringCell.construct(Cell from) |
Cell |
AbstractCell.diff(Cell cell) |
Cell |
BufferCounterCell.diff(Cell cell) |
Cell |
BufferCounterUpdateCell.diff(Cell cell) |
Cell |
Cell.diff(Cell cell) |
Cell |
NativeCounterCell.diff(Cell cell) |
Cell |
AbstractCell.diffCounter(Cell cell) |
boolean |
AbstractCell.equals(Cell cell) |
boolean |
BufferCounterCell.equals(Cell cell) |
boolean |
BufferDeletedCell.equals(Cell cell) |
boolean |
BufferExpiringCell.equals(Cell cell) |
boolean |
NativeCounterCell.equals(Cell cell) |
boolean |
NativeDeletedCell.equals(Cell cell) |
boolean |
NativeExpiringCell.equals(Cell cell) |
boolean |
DeletionInfo.isDeleted(Cell cell)
Return whether a given cell is deleted by the container having this deletion info.
|
boolean |
DeletionInfo.InOrderTester.isDeleted(Cell cell) |
boolean |
RangeTombstone.Tracker.isDeleted(Cell cell) |
boolean |
RangeTombstoneList.isDeleted(Cell cell)
Returns whether the given name/timestamp pair is deleted by one of the tombstone
of this RangeTombstoneList.
|
boolean |
RangeTombstoneList.InOrderTester.isDeleted(Cell cell) |
void |
ArrayBackedSortedColumns.maybeAppendColumn(Cell cell,
DeletionInfo.InOrderTester tester,
int gcBefore)
Adds a cell, assuming that:
- it's non-gc-able (if a tombstone) or not a tombstone
- it has a more recent timestamp than any partition/range tombstone shadowing it
- it sorts *strictly after* the current-last cell in the array.
|
void |
AtomicBTreeColumns.maybeAppendColumn(Cell cell,
DeletionInfo.InOrderTester tester,
int gcBefore) |
abstract void |
ColumnFamily.maybeAppendColumn(Cell cell,
DeletionInfo.InOrderTester tester,
int gcBefore)
Adds a cell if it's non-gc-able and isn't shadowed by a partition/range tombstone with a higher timestamp.
|
Cell |
AbstractCell.reconcile(Cell cell) |
Cell |
BufferCounterCell.reconcile(Cell cell) |
Cell |
BufferCounterUpdateCell.reconcile(Cell cell) |
Cell |
BufferDeletedCell.reconcile(Cell cell) |
Cell |
BufferExpiringCell.reconcile(Cell cell) |
Cell |
Cell.reconcile(Cell cell) |
Cell |
NativeCounterCell.reconcile(Cell cell) |
Cell |
NativeDeletedCell.reconcile(Cell cell) |
Cell |
NativeExpiringCell.reconcile(Cell cell) |
Cell |
AbstractCell.reconcileCounter(Cell cell)
This is temporary until we start creating Cells of the different type (buffer vs.
|
void |
ColumnSerializer.serialize(Cell cell,
DataOutputPlus out) |
long |
ColumnSerializer.serializedSize(Cell cell,
TypeSizes typeSizes) |
protected int |
AbstractNativeCell.sizeOf(Cell cell) |
protected int |
NativeCounterCell.sizeOf(Cell cell) |
protected int |
NativeExpiringCell.sizeOf(Cell cell) |
Constructor and Description |
---|
AbstractNativeCell(NativeAllocator allocator,
OpOrder.Group writeOp,
Cell copyOf) |
NativeCell(NativeAllocator allocator,
OpOrder.Group writeOp,
Cell copyOf) |
Modifier and Type | Method and Description |
---|---|
java.util.Comparator<Cell> |
AbstractCellNameType.columnComparator(boolean isRightNative) |
java.util.Comparator<Cell> |
CellNameType.columnComparator(boolean isRightNative) |
java.util.Comparator<Cell> |
AbstractCellNameType.columnReverseComparator() |
java.util.Comparator<Cell> |
CellNameType.columnReverseComparator() |
protected java.util.Comparator<Cell> |
AbstractCType.getByteOrderColumnComparator(boolean isRightNative) |
protected java.util.Comparator<Cell> |
AbstractSimpleCellNameType.getByteOrderColumnComparator(boolean isRightNative) |
Modifier and Type | Method and Description |
---|---|
static java.lang.String |
CellNames.getColumnsString(CellNameType type,
java.lang.Iterable<Cell> columns) |
Modifier and Type | Method and Description |
---|---|
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. |
java.util.Comparator<Cell> |
IDiskAtomFilter.getColumnComparator(CellNameType comparator) |
java.util.Comparator<Cell> |
NamesQueryFilter.getColumnComparator(CellNameType comparator) |
java.util.Comparator<Cell> |
SliceQueryFilter.getColumnComparator(CellNameType comparator) |
java.util.Iterator<Cell> |
IDiskAtomFilter.getColumnIterator(ColumnFamily cf)
returns an iterator that returns columns from the given columnFamily
matching the Filter criteria in sorted order.
|
java.util.Iterator<Cell> |
NamesQueryFilter.getColumnIterator(ColumnFamily cf) |
java.util.Iterator<Cell> |
SliceQueryFilter.getColumnIterator(ColumnFamily cf) |
java.util.Iterator<Cell> |
QueryFilter.getIterator(ColumnFamily cf) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnCounter.count(Cell cell,
DeletionInfo.InOrderTester tester) |
void |
ColumnCounter.GroupByPrefix.count(Cell cell,
DeletionInfo.InOrderTester tester) |
protected static boolean |
ColumnCounter.isLive(Cell cell,
DeletionInfo.InOrderTester tester,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
static void |
QueryFilter.collateColumns(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<Cell>> toCollate,
IDiskAtomFilter filter,
int gcBefore,
long timestamp) |
void |
QueryFilter.collateColumns(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<Cell>> toCollate,
int gcBefore) |
void |
IDiskAtomFilter.collectReducedColumns(ColumnFamily container,
java.util.Iterator<Cell> reducedColumns,
int gcBefore,
long now)
collects columns from reducedColumns into returnCF.
|
void |
NamesQueryFilter.collectReducedColumns(ColumnFamily container,
java.util.Iterator<Cell> reducedColumns,
int gcBefore,
long now) |
void |
SliceQueryFilter.collectReducedColumns(ColumnFamily container,
java.util.Iterator<Cell> reducedColumns,
int gcBefore,
long now) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSimplePerColumnSecondaryIndex.delete(java.nio.ByteBuffer rowKey,
Cell cell,
OpOrder.Group opGroup) |
abstract void |
PerColumnSecondaryIndex.delete(java.nio.ByteBuffer rowKey,
Cell col,
OpOrder.Group opGroup)
Delete a column from the index.
|
protected abstract java.nio.ByteBuffer |
AbstractSimplePerColumnSecondaryIndex.getIndexedValue(java.nio.ByteBuffer rowKey,
Cell cell) |
boolean |
SecondaryIndexManager.indexes(Cell cell) |
void |
AbstractSimplePerColumnSecondaryIndex.insert(java.nio.ByteBuffer rowKey,
Cell cell,
OpOrder.Group opGroup) |
abstract void |
PerColumnSecondaryIndex.insert(java.nio.ByteBuffer rowKey,
Cell col,
OpOrder.Group opGroup)
insert a column to the index
|
void |
SecondaryIndexManager.Updater.insert(Cell cell)
called when constructing the index against pre-existing data
|
protected abstract CellName |
AbstractSimplePerColumnSecondaryIndex.makeIndexColumnName(java.nio.ByteBuffer rowKey,
Cell cell) |
void |
SecondaryIndexManager.Updater.remove(Cell current)
called when lazy-updating the index during compaction (CASSANDRA-2897)
|
void |
AbstractSimplePerColumnSecondaryIndex.update(java.nio.ByteBuffer rowKey,
Cell oldCol,
Cell col,
OpOrder.Group opGroup) |
abstract void |
PerColumnSecondaryIndex.update(java.nio.ByteBuffer rowKey,
Cell oldCol,
Cell col,
OpOrder.Group opGroup)
update a column from the index
|
void |
SecondaryIndexManager.Updater.update(Cell oldCell,
Cell cell)
called when updating the index from a memtable
|
boolean |
PerColumnSecondaryIndex.validate(Cell cell) |
boolean |
PerRowSecondaryIndex.validate(Cell cell) |
abstract boolean |
SecondaryIndex.validate(Cell cell) |
boolean |
SecondaryIndexManager.validate(Cell cell) |
Modifier and Type | Method and Description |
---|---|
void |
SecondaryIndexManager.deleteFromIndexes(DecoratedKey key,
java.util.List<Cell> indexedColumnsInRow,
OpOrder.Group opGroup)
Delete all columns from all indexes for this row.
|
Modifier and Type | Method and Description |
---|---|
abstract CompositesIndex.IndexedEntry |
CompositesIndex.decodeEntry(DecoratedKey indexedValue,
Cell indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnClusteringKey.decodeEntry(DecoratedKey indexedValue,
Cell indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnCollectionKey.decodeEntry(DecoratedKey indexedValue,
Cell indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnCollectionValue.decodeEntry(DecoratedKey indexedValue,
Cell indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnPartitionKey.decodeEntry(DecoratedKey indexedValue,
Cell indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnRegular.decodeEntry(DecoratedKey indexedValue,
Cell indexEntry) |
protected java.nio.ByteBuffer |
CompositesIndexOnClusteringKey.getIndexedValue(java.nio.ByteBuffer rowKey,
Cell cell) |
protected java.nio.ByteBuffer |
CompositesIndexOnCollectionKey.getIndexedValue(java.nio.ByteBuffer rowKey,
Cell cell) |
protected java.nio.ByteBuffer |
CompositesIndexOnCollectionValue.getIndexedValue(java.nio.ByteBuffer rowKey,
Cell cell) |
protected java.nio.ByteBuffer |
CompositesIndexOnPartitionKey.getIndexedValue(java.nio.ByteBuffer rowKey,
Cell cell) |
protected java.nio.ByteBuffer |
CompositesIndexOnRegular.getIndexedValue(java.nio.ByteBuffer rowKey,
Cell cell) |
protected CellName |
CompositesIndex.makeIndexColumnName(java.nio.ByteBuffer rowKey,
Cell cell) |
Modifier and Type | Method and Description |
---|---|
protected java.nio.ByteBuffer |
KeysIndex.getIndexedValue(java.nio.ByteBuffer rowKey,
Cell cell) |
protected CellName |
KeysIndex.makeIndexColumnName(java.nio.ByteBuffer rowKey,
Cell cell) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Cell> |
CollectionType.enforceLimit(java.util.List<Cell> cells,
int version) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Cell> |
CollectionType.enforceLimit(java.util.List<Cell> cells,
int version) |
abstract java.util.List<java.nio.ByteBuffer> |
CollectionType.serializedValues(java.util.List<Cell> cells) |
java.util.List<java.nio.ByteBuffer> |
ListType.serializedValues(java.util.List<Cell> cells) |
java.util.List<java.nio.ByteBuffer> |
MapType.serializedValues(java.util.List<Cell> cells) |
java.util.List<java.nio.ByteBuffer> |
SetType.serializedValues(java.util.List<Cell> cells) |
java.nio.ByteBuffer |
CollectionType.serializeForNativeProtocol(java.util.List<Cell> cells,
int version) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<java.nio.ByteBuffer,java.util.SortedMap<java.nio.ByteBuffer,Cell>> |
ColumnFamilyInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
java.util.SortedMap<java.nio.ByteBuffer,Cell> |
ColumnFamilyRecordReader.createValue() |
java.util.SortedMap<java.nio.ByteBuffer,Cell> |
ColumnFamilyRecordReader.getCurrentValue() |
org.apache.hadoop.mapred.RecordReader<java.nio.ByteBuffer,java.util.SortedMap<java.nio.ByteBuffer,Cell>> |
ColumnFamilyInputFormat.getRecordReader(org.apache.hadoop.mapred.InputSplit split,
org.apache.hadoop.mapred.JobConf jobConf,
org.apache.hadoop.mapred.Reporter reporter) |
Modifier and Type | Method and Description |
---|---|
boolean |
ColumnFamilyRecordReader.next(java.nio.ByteBuffer key,
java.util.SortedMap<java.nio.ByteBuffer,Cell> value) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.pig.data.Tuple |
AbstractCassandraStorage.columnToTuple(Cell col,
AbstractCassandraStorage.CfInfo cfInfo,
AbstractType comparator)
convert a column to a tuple
|
protected java.lang.Object |
CqlStorage.cqlColumnToObj(Cell col,
CfDef cfDef)
convert a cql column to an object
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractSSTableSimpleWriter.addColumn(Cell cell) |
protected void |
SSTableSimpleUnsortedWriter.addColumn(Cell cell) |
protected void |
SSTableSimpleUnsortedWriter.countColumn(Cell cell) |
Modifier and Type | Method and Description |
---|---|
java.util.List<ColumnOrSuperColumn> |
CassandraServer.thriftifyColumns(java.util.Collection<Cell> cells,
boolean reverseOrder,
long now) |
Modifier and Type | Method and Description |
---|---|
abstract Cell |
MemtableAllocator.clone(Cell cell,
CFMetaData cfm,
OpOrder.Group writeOp) |
Cell |
MemtableBufferAllocator.clone(Cell cell,
CFMetaData cfm,
OpOrder.Group writeOp) |
Cell |
NativeAllocator.clone(Cell cell,
CFMetaData cfm,
OpOrder.Group writeOp) |
Modifier and Type | Method and Description |
---|---|
abstract Cell |
MemtableAllocator.clone(Cell cell,
CFMetaData cfm,
OpOrder.Group writeOp) |
Cell |
MemtableBufferAllocator.clone(Cell cell,
CFMetaData cfm,
OpOrder.Group writeOp) |
Cell |
NativeAllocator.clone(Cell cell,
CFMetaData cfm,
OpOrder.Group writeOp) |
MemtableAllocator.DataReclaimer |
MemtableAllocator.DataReclaimer.reclaim(Cell cell) |
MemtableAllocator.DataReclaimer |
MemtableAllocator.DataReclaimer.reclaimImmediately(Cell cell) |
Copyright © 2014 The Apache Software Foundation