Modifier and Type | Method and Description |
---|---|
abstract boolean |
ColumnCondition.Bound.appliesTo(Composite rowPrefix,
ColumnFamily current,
long now)
Validates whether this condition applies to
current . |
boolean |
ColumnCondition.CollectionInBound.appliesTo(Composite rowPrefix,
ColumnFamily current,
long now) |
protected java.util.Iterator<Cell> |
ColumnCondition.Bound.collectionColumns(CellName collection,
ColumnFamily cf,
long now) |
void |
Constants.Setter.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Constants.Adder.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Constants.Substracter.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Constants.Deleter.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Lists.Setter.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Lists.SetterByIndex.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Lists.Appender.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Lists.Prepender.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Lists.Discarder.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Lists.DiscarderByIndex.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Maps.Setter.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Maps.SetterByKey.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Maps.Putter.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Maps.DiscarderByKey.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
abstract void |
Operation.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params)
Execute the operation.
|
void |
Sets.Setter.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Sets.Adder.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
void |
Sets.Discarder.execute(java.nio.ByteBuffer rowKey,
ColumnFamily cf,
Composite prefix,
UpdateParameters params) |
Modifier and Type | Method and Description |
---|---|
ColumnFamily |
CQL3CasRequest.makeUpdates(ColumnFamily current) |
Modifier and Type | Method and Description |
---|---|
void |
DeleteStatement.addUpdateForKey(ColumnFamily cf,
java.nio.ByteBuffer key,
Composite prefix,
UpdateParameters params) |
abstract void |
ModificationStatement.addUpdateForKey(ColumnFamily updates,
java.nio.ByteBuffer key,
Composite prefix,
UpdateParameters params) |
void |
UpdateStatement.addUpdateForKey(ColumnFamily cf,
java.nio.ByteBuffer key,
Composite prefix,
UpdateParameters params) |
boolean |
CQL3CasRequest.appliesTo(ColumnFamily current) |
static ResultSet |
ModificationStatement.buildCasResultSet(java.lang.String ksName,
java.nio.ByteBuffer key,
java.lang.String cfName,
ColumnFamily cf,
java.lang.Iterable<ColumnDefinition> columnsWithConditions,
boolean isBatch,
QueryOptions options) |
ColumnFamily |
CQL3CasRequest.makeUpdates(ColumnFamily current) |
Modifier and Type | Method and Description |
---|---|
static void |
BatchStatement.verifyBatchSize(java.lang.Iterable<ColumnFamily> cfs)
Checks batch size to ensure threshold is met.
|
Modifier and Type | Class and Description |
---|---|
static class |
ColumnFamily.Factory<T extends ColumnFamily> |
Modifier and Type | Class and Description |
---|---|
class |
ArrayBackedSortedColumns
A ColumnFamily backed by an array.
|
class |
AtomicBTreeColumns
A thread-safe and atomic ISortedColumns implementation.
|
Modifier and Type | Field and Description |
---|---|
ColumnFamily |
CFRowAdder.cf |
ColumnFamily |
Row.cf |
Modifier and Type | Method and Description |
---|---|
<T extends ColumnFamily> |
ColumnFamily.cloneMeShallow(ColumnFamily.Factory<T> factory,
boolean reversedInsertOrder) |
Modifier and Type | Method and Description |
---|---|
ColumnFamily |
Mutation.addOrGet(CFMetaData cfm) |
ColumnFamily |
Mutation.addOrGet(java.lang.String cfName) |
ColumnFamily |
ArrayBackedSortedColumns.cloneMe() |
ColumnFamily |
AtomicBTreeColumns.cloneMe() |
abstract ColumnFamily |
ColumnFamily.cloneMe()
Clones the column map.
|
ColumnFamily |
ColumnFamily.cloneMeShallow() |
ColumnFamily |
ColumnFamilySerializer.deserialize(java.io.DataInput in,
ColumnFamily.Factory factory,
ColumnSerializer.Flag flag,
int version) |
ColumnFamily |
ColumnFamilySerializer.deserialize(java.io.DataInput in,
ColumnSerializer.Flag flag,
int version) |
ColumnFamily |
ColumnFamilySerializer.deserialize(java.io.DataInput in,
int version) |
ColumnFamily |
ColumnFamilySerializer.deserializeFromSSTable(java.io.DataInput in,
Descriptor.Version version) |
ColumnFamily |
ColumnFamily.diff(ColumnFamily cfComposite) |
static ColumnFamily |
ColumnFamily.diff(ColumnFamily cf1,
ColumnFamily cf2) |
static ColumnFamily |
ColumnFamily.fromBytes(java.nio.ByteBuffer bytes) |
ColumnFamily |
Memtable.getColumnFamily(DecoratedKey key) |
ColumnFamily |
ColumnFamilyStore.getColumnFamily(DecoratedKey key,
Composite start,
Composite finish,
boolean reversed,
int limit,
long timestamp) |
ColumnFamily |
ColumnFamilyStore.getColumnFamily(QueryFilter filter)
get a list of columns starting from a given column, in a specified order.
|
ColumnFamily |
Mutation.getColumnFamily(java.util.UUID cfId) |
ColumnFamily |
ColumnFamilyStore.getRawCachedRow(DecoratedKey key) |
ColumnFamily |
CollationController.getTopLevelColumns(boolean copyOnHeap) |
ColumnFamily |
ColumnFamilyStore.getTopLevelColumns(QueryFilter filter,
int gcBefore) |
static ColumnFamily |
ColumnFamilyStore.removeDeleted(ColumnFamily cf,
int gcBefore)
Removes deleted columns and purges gc-able tombstones.
|
static ColumnFamily |
ColumnFamilyStore.removeDeleted(ColumnFamily cf,
int gcBefore,
SecondaryIndexManager.Updater indexer) |
static ColumnFamily |
ColumnFamilyStore.removeDeletedCF(ColumnFamily cf,
int gcBefore)
Purges gc-able top-level and range tombstones, returning `cf` if there are any columns or tombstones left,
null otherwise.
|
static ColumnFamily |
ColumnFamilyStore.removeDeletedColumnsOnly(ColumnFamily cf,
int gcBefore,
SecondaryIndexManager.Updater indexer)
Removes only per-cell tombstones, cells that are shadowed by a row-level or range tombstone, or
columns that have been dropped from the schema (for CQL3 tables only).
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ColumnFamily> |
CounterMutation.getColumnFamilies() |
java.util.Collection<ColumnFamily> |
IMutation.getColumnFamilies() |
java.util.Collection<ColumnFamily> |
Mutation.getColumnFamilies() |
java.util.Iterator<java.util.Map.Entry<DecoratedKey,ColumnFamily>> |
Memtable.getEntryIterator(RowPosition startWith,
RowPosition stopAt) |
static java.util.Map<DecoratedKey,ColumnFamily> |
SystemKeyspace.getSchema(java.lang.String schemaCfName,
java.util.Set<java.lang.String> keyspaces) |
Modifier and Type | Method and Description |
---|---|
void |
Mutation.add(ColumnFamily columnFamily) |
void |
ArrayBackedSortedColumns.addAll(ColumnFamily other) |
void |
AtomicBTreeColumns.addAll(ColumnFamily cf) |
abstract void |
ColumnFamily.addAll(ColumnFamily cm)
Adds all the columns of a given column map to this column map.
|
long |
AtomicBTreeColumns.addAllWithSizeDelta(ColumnFamily cm,
MemtableAllocator allocator,
OpOrder.Group writeOp,
SecondaryIndexManager.Updater indexer)
This is only called by Memtable.resolve, so only AtomicBTreeColumns needs to implement it.
|
void |
ColumnFamilyStore.apply(DecoratedKey key,
ColumnFamily columnFamily,
SecondaryIndexManager.Updater indexer,
OpOrder.Group opGroup,
ReplayPosition replayPosition)
Insert/Update the column family for this key.
|
ColumnIndex |
ColumnIndex.Builder.build(ColumnFamily cf)
Serializes the index into in-memory structure with all required components
such as Bloom Filter, index block size, IndexInfo list
|
long |
ColumnFamilySerializer.contentSerializedSize(ColumnFamily cf,
TypeSizes typeSizes,
int version) |
void |
ColumnFamily.delete(ColumnFamily columns)
If `columns` has any tombstones (top-level or range tombstones), they will be applied to this set of columns.
|
static void |
SuperColumns.deserializerSuperColumnFamily(java.io.DataInput in,
ColumnFamily cf,
ColumnSerializer.Flag flag,
int version) |
ColumnFamily |
ColumnFamily.diff(ColumnFamily cfComposite) |
static ColumnFamily |
ColumnFamily.diff(ColumnFamily cf1,
ColumnFamily cf2) |
static java.nio.ByteBuffer |
ColumnFamily.digest(ColumnFamily cf) |
int |
DataRange.getLiveCount(ColumnFamily data,
long now) |
boolean |
ColumnFamilyStore.isFilterFullyCoveredBy(IDiskAtomFilter filter,
ColumnFamily cachedCf,
long now) |
static ArrayBackedSortedColumns |
ArrayBackedSortedColumns.localCopy(ColumnFamily original,
AbstractAllocator allocator) |
static ColumnFamily |
ColumnFamilyStore.removeDeleted(ColumnFamily cf,
int gcBefore)
Removes deleted columns and purges gc-able tombstones.
|
static ColumnFamily |
ColumnFamilyStore.removeDeleted(ColumnFamily cf,
int gcBefore,
SecondaryIndexManager.Updater indexer) |
static ColumnFamily |
ColumnFamilyStore.removeDeletedCF(ColumnFamily cf,
int gcBefore)
Purges gc-able top-level and range tombstones, returning `cf` if there are any columns or tombstones left,
null otherwise.
|
static ColumnFamily |
ColumnFamilyStore.removeDeletedColumnsOnly(ColumnFamily cf,
int gcBefore,
SecondaryIndexManager.Updater indexer)
Removes only per-cell tombstones, cells that are shadowed by a row-level or range tombstone, or
columns that have been dropped from the schema (for CQL3 tables only).
|
void |
ColumnFamilySerializer.serialize(ColumnFamily cf,
DataOutputPlus out,
int version) |
long |
ColumnFamilySerializer.serializedSize(ColumnFamily cf,
int version) |
long |
ColumnFamilySerializer.serializedSize(ColumnFamily cf,
TypeSizes typeSizes,
int version) |
void |
ColumnFamilySerializer.serializeForSSTable(ColumnFamily cf,
DataOutputPlus out) |
Constructor and Description |
---|
CFRowAdder(ColumnFamily cf,
Composite prefix,
long timestamp) |
ColumnIndex.Builder(ColumnFamily cf,
java.nio.ByteBuffer key,
DataOutputPlus output) |
Mutation(java.nio.ByteBuffer key,
ColumnFamily cf) |
Mutation(java.lang.String keyspaceName,
java.nio.ByteBuffer key,
ColumnFamily cf) |
Row(java.nio.ByteBuffer key,
ColumnFamily updates) |
Row(DecoratedKey key,
ColumnFamily cf) |
Constructor and Description |
---|
Mutation(java.lang.String keyspaceName,
java.nio.ByteBuffer key,
java.util.Map<java.util.UUID,ColumnFamily> modifications) |
Modifier and Type | Method and Description |
---|---|
ColumnFamily |
LazyColumnIterator.getColumnFamily() |
ColumnFamily |
OnDiskAtomIterator.getColumnFamily() |
ColumnFamily |
SSTableNamesIterator.getColumnFamily() |
ColumnFamily |
SSTableSliceIterator.getColumnFamily() |
Modifier and Type | Method and Description |
---|---|
abstract ColumnFamily |
ExtendedFilter.prune(DecoratedKey key,
ColumnFamily data) |
ColumnFamily |
ExtendedFilter.WithClauses.prune(DecoratedKey rowKey,
ColumnFamily data) |
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 |
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) |
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) |
ColumnCounter |
ColumnCounter.countAll(ColumnFamily container) |
void |
QueryFilter.delete(DeletionInfo target,
ColumnFamily source) |
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.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) |
OnDiskAtomIterator |
IDiskAtomFilter.getColumnIterator(DecoratedKey key,
ColumnFamily cf) |
OnDiskAtomIterator |
NamesQueryFilter.getColumnIterator(DecoratedKey key,
ColumnFamily cf) |
OnDiskAtomIterator |
SliceQueryFilter.getColumnIterator(DecoratedKey key,
ColumnFamily cf) |
abstract IDiskAtomFilter |
ExtendedFilter.getExtraFilter(DecoratedKey key,
ColumnFamily data)
Returns a filter to query the columns from the clause that the initial slice filter may not have caught.
|
IDiskAtomFilter |
ExtendedFilter.WithClauses.getExtraFilter(DecoratedKey rowKey,
ColumnFamily data) |
java.util.Iterator<Cell> |
QueryFilter.getIterator(ColumnFamily cf) |
int |
IDiskAtomFilter.getLiveCount(ColumnFamily cf,
long now) |
int |
NamesQueryFilter.getLiveCount(ColumnFamily cf,
long now) |
int |
SliceQueryFilter.getLiveCount(ColumnFamily cf,
long now) |
java.util.Iterator<RangeTombstone> |
IDiskAtomFilter.getRangeTombstoneIterator(ColumnFamily source) |
java.util.Iterator<RangeTombstone> |
NamesQueryFilter.getRangeTombstoneIterator(ColumnFamily source) |
java.util.Iterator<RangeTombstone> |
SliceQueryFilter.getRangeTombstoneIterator(ColumnFamily source) |
boolean |
IDiskAtomFilter.isFullyCoveredBy(ColumnFamily cf,
long now)
Whether the provided cf, that is assumed to contain the head of the
partition, contains enough data to cover this filter.
|
boolean |
NamesQueryFilter.isFullyCoveredBy(ColumnFamily cf,
long now) |
boolean |
SliceQueryFilter.isFullyCoveredBy(ColumnFamily cf,
long now) |
abstract boolean |
ExtendedFilter.isSatisfiedBy(DecoratedKey rowKey,
ColumnFamily data,
Composite prefix,
java.nio.ByteBuffer collectionElement) |
boolean |
ExtendedFilter.WithClauses.isSatisfiedBy(DecoratedKey rowKey,
ColumnFamily data,
Composite prefix,
java.nio.ByteBuffer collectionElement) |
int |
ExtendedFilter.lastCounted(ColumnFamily data) |
abstract ColumnFamily |
ExtendedFilter.prune(DecoratedKey key,
ColumnFamily data) |
ColumnFamily |
ExtendedFilter.WithClauses.prune(DecoratedKey rowKey,
ColumnFamily data) |
void |
SliceQueryFilter.trim(ColumnFamily cf,
int trimTo,
long now) |
Modifier and Type | Method and Description |
---|---|
abstract void |
PerRowSecondaryIndex.index(java.nio.ByteBuffer rowKey,
ColumnFamily cf)
Index the given row.
|
void |
SecondaryIndexManager.indexRow(java.nio.ByteBuffer key,
ColumnFamily cf,
OpOrder.Group opGroup)
When building an index against existing data, add the given row to the index
|
SecondaryIndexManager.Updater |
SecondaryIndexManager.updaterFor(DecoratedKey key,
ColumnFamily cf,
OpOrder.Group opGroup)
This helper acts as a closure around the indexManager
and updated cf data to ensure that down in
Memtable's ColumnFamily implementation, the index
can get updated.
|
Modifier and Type | Method and Description |
---|---|
abstract boolean |
CompositesIndex.isStale(CompositesIndex.IndexedEntry entry,
ColumnFamily data,
long now) |
boolean |
CompositesIndexOnClusteringKey.isStale(CompositesIndex.IndexedEntry entry,
ColumnFamily data,
long now) |
boolean |
CompositesIndexOnCollectionKey.isStale(CompositesIndex.IndexedEntry entry,
ColumnFamily data,
long now) |
boolean |
CompositesIndexOnCollectionValue.isStale(CompositesIndex.IndexedEntry entry,
ColumnFamily data,
long now) |
boolean |
CompositesIndexOnPartitionKey.isStale(CompositesIndex.IndexedEntry entry,
ColumnFamily data,
long now) |
boolean |
CompositesIndexOnRegular.isStale(CompositesIndex.IndexedEntry entry,
ColumnFamily data,
long now) |
Modifier and Type | Method and Description |
---|---|
boolean |
KeysIndex.isIndexEntryStale(java.nio.ByteBuffer indexedValue,
ColumnFamily data,
long now) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamily |
AbstractSSTableSimpleWriter.columnFamily |
Modifier and Type | Method and Description |
---|---|
protected ColumnFamily |
SSTableSimpleUnsortedWriter.createColumnFamily() |
protected abstract ColumnFamily |
AbstractSSTableSimpleWriter.getColumnFamily() |
ColumnFamily |
SSTableIdentityIterator.getColumnFamily() |
protected ColumnFamily |
SSTableSimpleUnsortedWriter.getColumnFamily() |
protected ColumnFamily |
SSTableSimpleWriter.getColumnFamily() |
Modifier and Type | Method and Description |
---|---|
void |
SSTableWriter.append(DecoratedKey decoratedKey,
ColumnFamily cf) |
static RowIndexEntry |
SSTableWriter.rawAppend(ColumnFamily cf,
long startPosition,
DecoratedKey key,
DataOutputPlus out) |
protected abstract void |
AbstractSSTableSimpleWriter.writeRow(DecoratedKey key,
ColumnFamily columnFamily) |
protected void |
SSTableSimpleUnsortedWriter.writeRow(DecoratedKey key,
ColumnFamily columnFamily) |
protected void |
SSTableSimpleWriter.writeRow(DecoratedKey key,
ColumnFamily columnFamily) |
Modifier and Type | Method and Description |
---|---|
static ColumnFamily |
StorageProxy.cas(java.lang.String keyspaceName,
java.lang.String cfName,
java.nio.ByteBuffer key,
CASRequest request,
ConsistencyLevel consistencyForPaxos,
ConsistencyLevel consistencyForCommit)
Apply @param updates if and only if the current values in the row for @param key
match the provided @param conditions.
|
ColumnFamily |
CASRequest.makeUpdates(ColumnFamily current)
The updates to perform of a CAS success.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CASRequest.appliesTo(ColumnFamily current)
Returns whether the provided CF, that represents the values fetched using the
readFilter(), match the CAS conditions this object stands for.
|
ColumnFamily |
CASRequest.makeUpdates(ColumnFamily current)
The updates to perform of a CAS success.
|
static java.util.List<AsyncOneResponse> |
RowDataResolver.scheduleRepairs(ColumnFamily resolved,
java.lang.String keyspaceName,
DecoratedKey key,
java.util.List<ColumnFamily> versions,
java.util.List<java.net.InetAddress> endpoints)
For each row version, compare with resolved (the superset of all row versions);
if it is missing anything, send a mutation to the endpoint it come from.
|
Modifier and Type | Method and Description |
---|---|
static java.util.List<AsyncOneResponse> |
RowDataResolver.scheduleRepairs(ColumnFamily resolved,
java.lang.String keyspaceName,
DecoratedKey key,
java.util.List<ColumnFamily> versions,
java.util.List<java.net.InetAddress> endpoints)
For each row version, compare with resolved (the superset of all row versions);
if it is missing anything, send a mutation to the endpoint it come from.
|
Modifier and Type | Method and Description |
---|---|
static java.util.Iterator<ColumnFamily> |
QueryPagers.pageRowLocally(ColumnFamilyStore cfs,
java.nio.ByteBuffer key,
int pageSize)
Convenience method to (locally) page an internal row.
|
Modifier and Type | Field and Description |
---|---|
ColumnFamily |
Commit.update |
Modifier and Type | Method and Description |
---|---|
static Commit |
Commit.newProposal(java.nio.ByteBuffer key,
java.util.UUID ballot,
ColumnFamily update) |
Constructor and Description |
---|
Commit(java.nio.ByteBuffer key,
java.util.UUID ballot,
ColumnFamily update) |
Modifier and Type | Method and Description |
---|---|
protected java.util.Map<DecoratedKey,ColumnFamily> |
CassandraServer.readColumnFamily(java.util.List<ReadCommand> commands,
ConsistencyLevel consistency_level) |
Modifier and Type | Method and Description |
---|---|
static void |
Tracing.addColumn(ColumnFamily cf,
CellName name,
java.net.InetAddress address) |
static void |
Tracing.addColumn(ColumnFamily cf,
CellName name,
int value) |
static void |
Tracing.addColumn(ColumnFamily cf,
CellName name,
long value) |
static void |
Tracing.addColumn(ColumnFamily cf,
CellName name,
java.lang.String value) |
void |
Tracing.addParameterColumns(ColumnFamily cf,
java.util.Map<java.lang.String,java.lang.String> rawPayload) |
Modifier and Type | Method and Description |
---|---|
ColumnFamily |
TriggerExecutor.execute(java.nio.ByteBuffer key,
ColumnFamily updates) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Mutation> |
ITrigger.augment(java.nio.ByteBuffer partitionKey,
ColumnFamily update)
Called exactly once per CF update, returned mutations are atomically updated.
|
ColumnFamily |
TriggerExecutor.execute(java.nio.ByteBuffer key,
ColumnFamily updates) |
Copyright © 2014 The Apache Software Foundation