Modifier and Type | Method and Description |
---|---|
void |
CFMetaData.validateColumns(java.lang.Iterable<Column> columns) |
Modifier and Type | Method and Description |
---|---|
Column |
UpdateParameters.makeColumn(java.nio.ByteBuffer name,
java.nio.ByteBuffer value) |
Column |
UpdateParameters.makeTombstone(java.nio.ByteBuffer name) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Pair<java.nio.ByteBuffer,Column>> |
UpdateParameters.getPrefetchedList(java.nio.ByteBuffer rowKey,
java.nio.ByteBuffer cql3ColumnName) |
Modifier and Type | Method and Description |
---|---|
Column |
ColumnGroupMap.getSimple(java.nio.ByteBuffer key) |
Modifier and Type | Method and Description |
---|---|
java.util.List<Pair<java.nio.ByteBuffer,Column>> |
ColumnGroupMap.getCollection(java.nio.ByteBuffer key) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnGroupMap.Builder.add(Column c) |
void |
Selection.ResultSetBuilder.add(Column c) |
Modifier and Type | Class and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static Column |
Column.create(boolean value,
long timestamp,
java.lang.String... names) |
static Column |
Column.create(java.nio.ByteBuffer name,
java.nio.ByteBuffer value,
long timestamp,
int ttl,
CFMetaData metadata) |
static Column |
ExpiringColumn.create(java.nio.ByteBuffer name,
java.nio.ByteBuffer value,
long timestamp,
int timeToLive,
int localExpirationTime,
int expireBefore,
ColumnSerializer.Flag flag) |
static Column |
Column.create(java.nio.ByteBuffer value,
long timestamp,
java.lang.String... names) |
static Column |
Column.create(double value,
long timestamp,
java.lang.String... names) |
static Column |
Column.create(java.net.InetAddress value,
long timestamp,
java.lang.String... names) |
static Column |
Column.create(int value,
long timestamp,
java.lang.String... names) |
static Column |
Column.create(java.lang.String value,
long timestamp,
java.lang.String... names) |
Column |
ColumnSerializer.deserialize(java.io.DataInput in) |
Column |
ColumnSerializer.deserialize(java.io.DataInput in,
ColumnSerializer.Flag flag) |
Column |
ColumnSerializer.deserialize(java.io.DataInput in,
ColumnSerializer.Flag flag,
int expireBefore) |
Column |
Column.diff(Column column) |
Column |
CounterColumn.diff(Column column) |
Column |
CounterUpdateColumn.diff(Column column) |
Column |
ArrayBackedSortedColumns.getColumn(java.nio.ByteBuffer name) |
Column |
AtomicSortedColumns.getColumn(java.nio.ByteBuffer name) |
abstract Column |
ColumnFamily.getColumn(java.nio.ByteBuffer name)
Get a column given its name, returning null if the column is not
present.
|
Column |
EmptyColumns.getColumn(java.nio.ByteBuffer name) |
Column |
TreeMapBackedSortedColumns.getColumn(java.nio.ByteBuffer name) |
Column |
UnsortedColumns.getColumn(java.nio.ByteBuffer name) |
Column |
Column.localCopy(ColumnFamilyStore cfs) |
Column |
CounterColumn.localCopy(ColumnFamilyStore cfs) |
Column |
DeletedColumn.localCopy(ColumnFamilyStore cfs) |
Column |
ExpiringColumn.localCopy(ColumnFamilyStore cfs) |
Column |
Column.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
Column |
CounterColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
Column |
CounterUpdateColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
Column |
DeletedColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
Column |
ExpiringColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
Column |
CounterColumn.markLocalToBeCleared() |
Column |
Column.reconcile(Column column) |
Column |
Column.reconcile(Column column,
Allocator allocator) |
Column |
CounterColumn.reconcile(Column column,
Allocator allocator) |
Column |
CounterUpdateColumn.reconcile(Column column,
Allocator allocator) |
Column |
DeletedColumn.reconcile(Column column,
Allocator allocator) |
Column |
Column.withUpdatedName(java.nio.ByteBuffer newName) |
Column |
CounterColumn.withUpdatedName(java.nio.ByteBuffer newName) |
Column |
DeletedColumn.withUpdatedName(java.nio.ByteBuffer newName) |
Column |
ExpiringColumn.withUpdatedName(java.nio.ByteBuffer newName) |
Column |
Column.withUpdatedTimestamp(long newTimestamp) |
Column |
DeletedColumn.withUpdatedTimestamp(long newTimestamp) |
Column |
ExpiringColumn.withUpdatedTimestamp(long newTimestamp) |
Modifier and Type | Method and Description |
---|---|
java.util.Collection<Column> |
ArrayBackedSortedColumns.getReverseSortedColumns() |
java.util.Collection<Column> |
AtomicSortedColumns.getReverseSortedColumns() |
abstract java.util.Collection<Column> |
ColumnFamily.getReverseSortedColumns()
Returns the columns of this column map as a collection.
|
java.util.Collection<Column> |
EmptyColumns.getReverseSortedColumns() |
java.util.Collection<Column> |
TreeMapBackedSortedColumns.getReverseSortedColumns() |
java.util.Collection<Column> |
UnsortedColumns.getReverseSortedColumns() |
java.util.Collection<Column> |
ArrayBackedSortedColumns.getSortedColumns() |
java.util.Collection<Column> |
AtomicSortedColumns.getSortedColumns() |
abstract java.util.Collection<Column> |
ColumnFamily.getSortedColumns()
Returns the columns of this column map as a collection.
|
java.util.Collection<Column> |
EmptyColumns.getSortedColumns() |
java.util.Collection<Column> |
TreeMapBackedSortedColumns.getSortedColumns() |
java.util.Collection<Column> |
UnsortedColumns.getSortedColumns() |
java.util.Iterator<Column> |
ArrayBackedSortedColumns.iterator() |
java.util.Iterator<Column> |
ColumnFamily.iterator() |
java.util.Iterator<Column> |
TreeMapBackedSortedColumns.iterator() |
java.util.Iterator<Column> |
UnsortedColumns.iterator() |
java.util.Iterator<Column> |
ArrayBackedSortedColumns.iterator(ColumnSlice[] slices) |
java.util.Iterator<Column> |
AtomicSortedColumns.iterator(ColumnSlice[] slices) |
abstract java.util.Iterator<Column> |
ColumnFamily.iterator(ColumnSlice[] slices)
Returns an iterator over the columns of this map that returns only the matching @param slices.
|
java.util.Iterator<Column> |
EmptyColumns.iterator(ColumnSlice[] slices) |
java.util.Iterator<Column> |
TreeMapBackedSortedColumns.iterator(ColumnSlice[] slices) |
java.util.Iterator<Column> |
UnsortedColumns.iterator(ColumnSlice[] slices) |
java.util.Iterator<Column> |
ColumnFamily.reverseIterator() |
java.util.Iterator<Column> |
ArrayBackedSortedColumns.reverseIterator(ColumnSlice[] slices) |
java.util.Iterator<Column> |
AtomicSortedColumns.reverseIterator(ColumnSlice[] slices) |
abstract java.util.Iterator<Column> |
ColumnFamily.reverseIterator(ColumnSlice[] slices)
Returns a reversed iterator over the columns of this map that returns only the matching @param slices.
|
java.util.Iterator<Column> |
EmptyColumns.reverseIterator(ColumnSlice[] slices) |
java.util.Iterator<Column> |
TreeMapBackedSortedColumns.reverseIterator(ColumnSlice[] slices) |
java.util.Iterator<Column> |
UnsortedColumns.reverseIterator(ColumnSlice[] slices) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnFamily.addColumn(Column column) |
void |
ArrayBackedSortedColumns.addColumn(Column column,
Allocator allocator)
AddColumn throws an exception if the column added does not sort after
the last column in the map.
|
void |
AtomicSortedColumns.addColumn(Column column,
Allocator allocator) |
abstract void |
ColumnFamily.addColumn(Column column,
Allocator allocator)
Adds a column to this column map.
|
void |
EmptyColumns.addColumn(Column column,
Allocator allocator) |
void |
TreeMapBackedSortedColumns.addColumn(Column column,
Allocator allocator) |
void |
UnsortedColumns.addColumn(Column column,
Allocator allocator) |
void |
ColumnFamily.addIfRelevant(Column column,
DeletionInfo.InOrderTester tester,
int gcBefore) |
Column |
Column.diff(Column column) |
Column |
CounterColumn.diff(Column column) |
Column |
CounterUpdateColumn.diff(Column column) |
boolean |
DeletionInfo.isDeleted(Column column)
Return whether a given column is deleted by the container having this deletion info.
|
boolean |
DeletionInfo.InOrderTester.isDeleted(Column column) |
boolean |
DeletionTime.isDeleted(Column column) |
boolean |
RangeTombstone.Tracker.isDeleted(Column column) |
Column |
Column.reconcile(Column column) |
Column |
Column.reconcile(Column column,
Allocator allocator) |
Column |
CounterColumn.reconcile(Column column,
Allocator allocator) |
Column |
CounterUpdateColumn.reconcile(Column column,
Allocator allocator) |
Column |
DeletedColumn.reconcile(Column column,
Allocator allocator) |
boolean |
ArrayBackedSortedColumns.replace(Column oldColumn,
Column newColumn) |
boolean |
AtomicSortedColumns.replace(Column oldColumn,
Column newColumn) |
abstract boolean |
ColumnFamily.replace(Column oldColumn,
Column newColumn)
Replace oldColumn if present by newColumn.
|
boolean |
EmptyColumns.replace(Column oldColumn,
Column newColumn) |
boolean |
TreeMapBackedSortedColumns.replace(Column oldColumn,
Column newColumn) |
boolean |
UnsortedColumns.replace(Column oldColumn,
Column newColumn) |
void |
ColumnSerializer.serialize(Column column,
java.io.DataOutput out) |
long |
ColumnSerializer.serializedSize(Column column,
TypeSizes type) |
Modifier and Type | Method and Description |
---|---|
void |
ArrayBackedSortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
void |
ArrayBackedSortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
void |
AtomicSortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
void |
AtomicSortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
abstract void |
ColumnFamily.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation)
Adds all the columns of a given column map to this column map.
|
abstract void |
ColumnFamily.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation)
Adds all the columns of a given column map to this column map.
|
void |
EmptyColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
void |
EmptyColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
void |
TreeMapBackedSortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation)
We need to go through each column in the column container and resolve it before adding
|
void |
TreeMapBackedSortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation)
We need to go through each column in the column container and resolve it before adding
|
void |
UnsortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
void |
UnsortedColumns.addAll(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation) |
long |
AtomicSortedColumns.addAllWithSizeDelta(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation,
SecondaryIndexManager.Updater indexer)
This is only called by Memtable.resolve, so only AtomicSortedColumns needs to implement it.
|
long |
AtomicSortedColumns.addAllWithSizeDelta(ColumnFamily cm,
Allocator allocator,
com.google.common.base.Function<Column,Column> transformation,
SecondaryIndexManager.Updater indexer)
This is only called by Memtable.resolve, so only AtomicSortedColumns needs to implement it.
|
Modifier and Type | Method and Description |
---|---|
static void |
PrecompactedRow.merge(ColumnFamily returnCF,
java.util.List<CloseableIterator<Column>> data,
SecondaryIndexManager.Updater indexer) |
Modifier and Type | Method and Description |
---|---|
protected Column |
ColumnSlice.NavigableMapIterator.computeNext() |
Modifier and Type | Method and Description |
---|---|
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. |
java.util.Comparator<Column> |
IDiskAtomFilter.getColumnComparator(AbstractType<?> comparator) |
java.util.Comparator<Column> |
NamesQueryFilter.getColumnComparator(AbstractType<?> comparator) |
java.util.Comparator<Column> |
SliceQueryFilter.getColumnComparator(AbstractType<?> comparator) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnCounter.count(Column column,
DeletionInfo.InOrderTester tester) |
void |
ColumnCounter.GroupByPrefix.count(Column column,
DeletionInfo.InOrderTester tester) |
protected static boolean |
ColumnCounter.isLive(Column column,
DeletionInfo.InOrderTester tester,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
static void |
QueryFilter.collateColumns(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<Column>> toCollate,
IDiskAtomFilter filter,
int gcBefore,
long timestamp) |
void |
QueryFilter.collateColumns(ColumnFamily returnCF,
java.util.List<? extends java.util.Iterator<Column>> toCollate,
int gcBefore) |
void |
IDiskAtomFilter.collectReducedColumns(ColumnFamily container,
java.util.Iterator<Column> reducedColumns,
int gcBefore,
long now)
collects columns from reducedColumns into returnCF.
|
void |
NamesQueryFilter.collectReducedColumns(ColumnFamily container,
java.util.Iterator<Column> reducedColumns,
int gcBefore,
long now) |
void |
SliceQueryFilter.collectReducedColumns(ColumnFamily container,
java.util.Iterator<Column> reducedColumns,
int gcBefore,
long now) |
Constructor and Description |
---|
ColumnSlice.NavigableMapIterator(java.util.NavigableMap<java.nio.ByteBuffer,Column> map,
ColumnSlice[] slices) |
Modifier and Type | Method and Description |
---|---|
void |
AbstractSimplePerColumnSecondaryIndex.delete(java.nio.ByteBuffer rowKey,
Column column) |
abstract void |
PerColumnSecondaryIndex.delete(java.nio.ByteBuffer rowKey,
Column col)
Delete a column from the index
|
protected abstract java.nio.ByteBuffer |
AbstractSimplePerColumnSecondaryIndex.getIndexedValue(java.nio.ByteBuffer rowKey,
Column column) |
boolean |
SecondaryIndexManager.indexes(Column column) |
void |
AbstractSimplePerColumnSecondaryIndex.insert(java.nio.ByteBuffer rowKey,
Column column) |
abstract void |
PerColumnSecondaryIndex.insert(java.nio.ByteBuffer rowKey,
Column col)
insert a column to the index
|
void |
SecondaryIndexManager.Updater.insert(Column column)
called when constructing the index against pre-existing data
|
protected abstract java.nio.ByteBuffer |
AbstractSimplePerColumnSecondaryIndex.makeIndexColumnName(java.nio.ByteBuffer rowKey,
Column column) |
void |
SecondaryIndexManager.Updater.remove(Column current)
called when lazy-updating the index during compaction (CASSANDRA-2897)
|
void |
AbstractSimplePerColumnSecondaryIndex.update(java.nio.ByteBuffer rowKey,
Column col) |
abstract void |
PerColumnSecondaryIndex.update(java.nio.ByteBuffer rowKey,
Column col)
update a column from the index
|
void |
SecondaryIndexManager.Updater.update(Column oldColumn,
Column column)
called when updating the index from a memtable
|
boolean |
PerColumnSecondaryIndex.validate(Column column) |
boolean |
PerRowSecondaryIndex.validate(Column column) |
abstract boolean |
SecondaryIndex.validate(Column column) |
boolean |
SecondaryIndexManager.validate(Column column) |
Modifier and Type | Method and Description |
---|---|
void |
SecondaryIndexManager.deleteFromIndexes(DecoratedKey key,
java.util.List<Column> indexedColumnsInRow)
Delete all columns from all indexes for this row.
|
Modifier and Type | Method and Description |
---|---|
abstract CompositesIndex.IndexedEntry |
CompositesIndex.decodeEntry(DecoratedKey indexedValue,
Column indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnClusteringKey.decodeEntry(DecoratedKey indexedValue,
Column indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnPartitionKey.decodeEntry(DecoratedKey indexedValue,
Column indexEntry) |
CompositesIndex.IndexedEntry |
CompositesIndexOnRegular.decodeEntry(DecoratedKey indexedValue,
Column indexEntry) |
protected java.nio.ByteBuffer |
CompositesIndexOnClusteringKey.getIndexedValue(java.nio.ByteBuffer rowKey,
Column column) |
protected java.nio.ByteBuffer |
CompositesIndexOnPartitionKey.getIndexedValue(java.nio.ByteBuffer rowKey,
Column column) |
protected java.nio.ByteBuffer |
CompositesIndexOnRegular.getIndexedValue(java.nio.ByteBuffer rowKey,
Column column) |
protected java.nio.ByteBuffer |
CompositesIndex.makeIndexColumnName(java.nio.ByteBuffer rowKey,
Column column) |
Modifier and Type | Method and Description |
---|---|
protected java.nio.ByteBuffer |
KeysIndex.getIndexedValue(java.nio.ByteBuffer rowKey,
Column column) |
protected java.nio.ByteBuffer |
KeysIndex.makeIndexColumnName(java.nio.ByteBuffer rowKey,
Column column) |
Modifier and Type | Field and Description |
---|---|
java.util.Comparator<Column> |
AbstractType.columnComparator |
java.util.Comparator<Column> |
AbstractType.columnReverseComparator |
Modifier and Type | Method and Description |
---|---|
abstract Column |
AbstractCommutativeType.createColumn(java.nio.ByteBuffer name,
java.nio.ByteBuffer value,
long timestamp)
create commutative column
|
Column |
CounterColumnType.createColumn(java.nio.ByteBuffer name,
java.nio.ByteBuffer value,
long timestamp)
create commutative column
|
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Pair<java.nio.ByteBuffer,Column>> |
CollectionType.enforceLimit(java.util.List<Pair<java.nio.ByteBuffer,Column>> columns) |
Modifier and Type | Method and Description |
---|---|
protected java.util.List<Pair<java.nio.ByteBuffer,Column>> |
CollectionType.enforceLimit(java.util.List<Pair<java.nio.ByteBuffer,Column>> columns) |
java.lang.String |
AbstractType.getColumnsString(java.lang.Iterable<Column> columns) |
abstract java.nio.ByteBuffer |
CollectionType.serialize(java.util.List<Pair<java.nio.ByteBuffer,Column>> columns) |
java.nio.ByteBuffer |
ListType.serialize(java.util.List<Pair<java.nio.ByteBuffer,Column>> columns) |
java.nio.ByteBuffer |
MapType.serialize(java.util.List<Pair<java.nio.ByteBuffer,Column>> columns)
Creates the same output than serialize, but from the internal representation.
|
java.nio.ByteBuffer |
SetType.serialize(java.util.List<Pair<java.nio.ByteBuffer,Column>> columns) |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.mapreduce.RecordReader<java.nio.ByteBuffer,java.util.SortedMap<java.nio.ByteBuffer,Column>> |
ColumnFamilyInputFormat.createRecordReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) |
java.util.SortedMap<java.nio.ByteBuffer,Column> |
ColumnFamilyRecordReader.createValue() |
java.util.SortedMap<java.nio.ByteBuffer,Column> |
ColumnFamilyRecordReader.getCurrentValue() |
org.apache.hadoop.mapred.RecordReader<java.nio.ByteBuffer,java.util.SortedMap<java.nio.ByteBuffer,Column>> |
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,Column> value) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.pig.data.Tuple |
AbstractCassandraStorage.columnToTuple(Column col,
AbstractCassandraStorage.CfInfo cfInfo,
AbstractType comparator)
convert a column to a tuple
|
Modifier and Type | Method and Description |
---|---|
java.util.List<ColumnOrSuperColumn> |
CassandraServer.thriftifyColumns(java.util.Collection<Column> columns,
boolean reverseOrder,
long now) |
Copyright © 2014 The Apache Software Foundation