Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<Pair<K,V>> |
AutoSavingCache.CacheSerializer.deserialize(java.io.DataInputStream in,
ColumnFamilyStore cfs) |
void |
AutoSavingCache.CacheSerializer.load(java.util.Set<java.nio.ByteBuffer> buffer,
ColumnFamilyStore cfs)
Deprecated.
|
int |
AutoSavingCache.loadSaved(ColumnFamilyStore cfs) |
Modifier and Type | Method and Description |
---|---|
AbstractCompactionStrategy |
CFMetaData.createCompactionStrategyInstance(ColumnFamilyStore cfs) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
Memtable.cfs |
ColumnFamilyStore |
SliceQueryPager.cfs |
ColumnFamilyStore |
DataTracker.cfstore |
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Table table,
java.lang.String columnFamily,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Table table,
java.lang.String columnFamily,
IPartitioner partitioner,
CFMetaData metadata) |
ColumnFamilyStore |
Table.getColumnFamilyStore(java.lang.String cfName) |
ColumnFamilyStore |
Table.getColumnFamilyStore(java.util.UUID id) |
static ColumnFamilyStore |
SystemTable.schemaCFS(java.lang.String cfName) |
Modifier and Type | Method and Description |
---|---|
static java.lang.Iterable<ColumnFamilyStore> |
ColumnFamilyStore.all() |
static java.util.List<ColumnFamilyStore> |
ColumnFamilyStore.allUserDefined() |
java.lang.Iterable<ColumnFamilyStore> |
ColumnFamilyStore.concatWithIndexes() |
java.util.Collection<ColumnFamilyStore> |
Table.getColumnFamilyStores() |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<Row> |
RowIteratorFactory.getIterator(java.lang.Iterable<Memtable> memtables,
java.util.Collection<SSTableReader> sstables,
RowPosition startWith,
RowPosition stopAt,
QueryFilter filter,
ColumnFamilyStore cfs)
Get a row iterator over the provided memtables and sstables, between the provided keys
and filtered by the queryfilter.
|
static void |
Table.indexRow(DecoratedKey key,
ColumnFamilyStore cfs,
java.util.Set<java.lang.String> idxNames) |
IColumn |
Column.localCopy(ColumnFamilyStore cfs) |
IColumn |
CounterColumn.localCopy(ColumnFamilyStore cfs) |
CounterColumn |
CounterUpdateColumn.localCopy(ColumnFamilyStore cfs) |
IColumn |
DeletedColumn.localCopy(ColumnFamilyStore cfs) |
IColumn |
ExpiringColumn.localCopy(ColumnFamilyStore cfs) |
IColumn |
IColumn.localCopy(ColumnFamilyStore cfs)
clones the column for the row cache, interning column names and making copies of other underlying byte buffers
|
IColumn |
SuperColumn.localCopy(ColumnFamilyStore cfs) |
IColumn |
Column.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
IColumn |
CounterColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
IColumn |
CounterUpdateColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
IColumn |
DeletedColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
IColumn |
ExpiringColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
IColumn |
IColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator)
clones the column for the memtable, interning column names and making copies of other underlying byte buffers.
|
IColumn |
SuperColumn.localCopy(ColumnFamilyStore cfs,
Allocator allocator) |
static void |
SystemTable.saveTruncationRecord(ColumnFamilyStore cfs,
long truncatedAt,
ReplayPosition position) |
Constructor and Description |
---|
CollationController(ColumnFamilyStore cfs,
boolean mutableColumns,
QueryFilter filter,
int gcBefore) |
DataTracker(ColumnFamilyStore cfstore) |
Memtable(ColumnFamilyStore cfs) |
SliceQueryPager(ColumnFamilyStore cfs,
DecoratedKey key,
ColumnSlice[] slices) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
AbstractCompactionStrategy.cfs |
protected ColumnFamilyStore |
AbstractCompactionTask.cfs |
ColumnFamilyStore |
CompactionController.cfs |
ColumnFamilyStore |
Scrubber.cfs |
Modifier and Type | Method and Description |
---|---|
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
java.lang.Iterable<SSTableReader> sstables) |
static SSTableWriter |
CompactionManager.maybeCreateWriter(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
int expectedBloomFilterSize,
SSTableWriter writer,
java.util.Collection<SSTableReader> sstables) |
void |
CompactionManager.performCleanup(ColumnFamilyStore cfStore,
CounterId.OneShotRenewer renewer) |
void |
CompactionManager.performMaximal(ColumnFamilyStore cfStore) |
void |
CompactionManager.performScrub(ColumnFamilyStore cfStore) |
void |
CompactionManager.performSSTableRewrite(ColumnFamilyStore cfStore,
boolean excludeCurrentVersion) |
java.util.List<java.util.concurrent.Future<?>> |
CompactionManager.submitBackground(ColumnFamilyStore cfs)
Call this whenever a compaction might be needed on the given columnfamily.
|
java.util.concurrent.Future<?> |
CompactionManager.submitMaximal(ColumnFamilyStore cfStore,
int gcBefore) |
java.util.concurrent.Future<?> |
CompactionManager.submitTruncate(ColumnFamilyStore main,
long truncatedAt) |
java.util.concurrent.Future<?> |
CompactionManager.submitUserDefined(ColumnFamilyStore cfs,
java.util.Collection<Descriptor> dataFiles,
int gcBefore) |
java.util.concurrent.Future<java.lang.Object> |
CompactionManager.submitValidation(ColumnFamilyStore cfStore,
AntiEntropyService.Validator validator)
Does not mutate data, so is not scheduled.
|
static java.io.File |
LeveledManifest.tryGetManifest(ColumnFamilyStore cfs) |
Constructor and Description |
---|
AbstractCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
AbstractCompactionTask(ColumnFamilyStore cfs,
java.util.Collection<SSTableReader> sstables) |
CompactionController(ColumnFamilyStore cfs,
java.util.Collection<SSTableReader> sstables,
int gcBefore) |
CompactionController(ColumnFamilyStore cfs,
int maxValue)
Constructor that subclasses may use when overriding shouldPurge to not need overlappingTree
|
CompactionTask(ColumnFamilyStore cfs,
java.util.Collection<SSTableReader> sstables,
int gcBefore) |
LeveledCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
LeveledCompactionTask(ColumnFamilyStore cfs,
java.util.Collection<SSTableReader> sstables,
int gcBefore,
int sstableSizeInMB) |
Scrubber(ColumnFamilyStore cfs,
SSTableReader sstable) |
Scrubber(ColumnFamilyStore cfs,
SSTableReader sstable,
OutputHandler outputHandler,
boolean isOffline) |
SizeTieredCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
SSTableSplitter.SplitController(ColumnFamilyStore cfs,
java.util.Collection<SSTableReader> toCompact) |
SSTableSplitter.SplittingCompactionTask(ColumnFamilyStore cfs,
SSTableReader sstable,
int sstableSizeInMB) |
SSTableSplitter(ColumnFamilyStore cfs,
SSTableReader sstable,
int sstableSizeInMB) |
Upgrader(ColumnFamilyStore cfs,
SSTableReader sstable,
OutputHandler outputHandler) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
ExtendedFilter.cfs |
Modifier and Type | Method and Description |
---|---|
static ExtendedFilter |
ExtendedFilter.create(ColumnFamilyStore cfs,
IDiskAtomFilter filter,
java.util.List<IndexExpression> clause,
int maxResults,
boolean countCQL3Rows,
boolean isPaging) |
Constructor and Description |
---|
ExtendedFilter(ColumnFamilyStore cfs,
IDiskAtomFilter filter,
int maxResults,
boolean countCQL3Rows,
boolean isPaging) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
SecondaryIndex.baseCfs
Base CF that has many indexes
|
ColumnFamilyStore |
SecondaryIndexManager.baseCfs
The underlying column family containing the source data for these indexes
|
protected ColumnFamilyStore |
SecondaryIndexSearcher.baseCfs |
Modifier and Type | Method and Description |
---|---|
ColumnFamilyStore |
SecondaryIndex.getBaseCfs() |
ColumnFamilyStore |
AbstractSimplePerColumnSecondaryIndex.getIndexCfs() |
abstract ColumnFamilyStore |
SecondaryIndex.getIndexCfs()
Allow access to the underlying column family store if there is one
|
Modifier and Type | Method and Description |
---|---|
java.util.Collection<ColumnFamilyStore> |
SecondaryIndexManager.getIndexesBackedByCfs() |
Modifier and Type | Method and Description |
---|---|
static SecondaryIndex |
SecondaryIndex.createInstance(ColumnFamilyStore baseCfs,
ColumnDefinition cdef)
This is the primary way to create a secondary index instance for a CF column.
|
Constructor and Description |
---|
SecondaryIndexBuilder(ColumnFamilyStore cfs,
java.util.Set<java.lang.String> idxNames,
ReducingKeyIterator iter) |
SecondaryIndexManager(ColumnFamilyStore baseCfs) |
Constructor and Description |
---|
ColumnFamilyMetrics(ColumnFamilyStore cfs)
Creates metrics for given
ColumnFamilyStore . |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<ColumnFamilyStore> |
StorageService.getValidColumnFamilies(boolean allowIndexes,
boolean autoAddIndexes,
java.lang.String tableName,
java.lang.String... cfNames) |
Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<Pair<RowCacheKey,IRowCacheEntry>> |
CacheService.RowCacheSerializer.deserialize(java.io.DataInputStream in,
ColumnFamilyStore cfs) |
java.util.concurrent.Future<Pair<KeyCacheKey,RowIndexEntry>> |
CacheService.KeyCacheSerializer.deserialize(java.io.DataInputStream input,
ColumnFamilyStore cfs) |
void |
CacheService.RowCacheSerializer.load(java.util.Set<java.nio.ByteBuffer> buffers,
ColumnFamilyStore cfs) |
void |
CacheService.KeyCacheSerializer.load(java.util.Set<java.nio.ByteBuffer> buffers,
ColumnFamilyStore cfs) |
void |
AntiEntropyService.Validator.prepare(ColumnFamilyStore cfs) |
Modifier and Type | Field and Description |
---|---|
protected java.lang.Iterable<ColumnFamilyStore> |
StreamRequest.columnFamilies |
Modifier and Type | Method and Description |
---|---|
static void |
StreamIn.requestRanges(java.net.InetAddress source,
java.lang.String tableName,
java.util.Collection<ColumnFamilyStore> columnFamilies,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Request ranges to be transferred from specific CFs
|
static void |
StreamOut.transferRanges(java.net.InetAddress target,
Table table,
java.lang.Iterable<ColumnFamilyStore> cfses,
java.util.Collection<Range<Token>> ranges,
IStreamCallback callback,
OperationType type)
Stream the given ranges to the target endpoint for provided CFs in the given keyspace.
|
static void |
StreamOut.transferRanges(StreamOutSession session,
java.lang.Iterable<ColumnFamilyStore> cfses,
java.util.Collection<Range<Token>> ranges,
OperationType type)
Stream the given ranges to the target endpoint from each of the given CFs.
|
static void |
StreamOut.transferRanges(StreamOutSession session,
java.lang.Iterable<ColumnFamilyStore> cfses,
java.util.Collection<Range<Token>> ranges,
OperationType type,
boolean flushTables)
Stream the given ranges to the target endpoint from each of the given CFs.
|
Copyright © 2014 The Apache Software Foundation