Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<Pair<K,V>> |
AutoSavingCache.CacheSerializer.deserialize(java.io.DataInputStream in,
ColumnFamilyStore cfs) |
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 |
DataTracker.cfstore |
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
IPartitioner partitioner,
CFMetaData metadata) |
ColumnFamilyStore |
Keyspace.getColumnFamilyStore(java.lang.String cfName) |
ColumnFamilyStore |
Keyspace.getColumnFamilyStore(java.util.UUID id) |
static ColumnFamilyStore |
SystemKeyspace.schemaCFS(java.lang.String cfName) |
Modifier and Type | Method and Description |
---|---|
static java.lang.Iterable<ColumnFamilyStore> |
ColumnFamilyStore.all() |
java.lang.Iterable<ColumnFamilyStore> |
ColumnFamilyStore.concatWithIndexes() |
java.util.Collection<ColumnFamilyStore> |
Keyspace.getColumnFamilyStores() |
Modifier and Type | Method and Description |
---|---|
static CloseableIterator<Row> |
RowIteratorFactory.getIterator(java.lang.Iterable<Memtable> memtables,
java.util.Collection<SSTableReader> sstables,
DataRange range,
ColumnFamilyStore cfs,
long now)
Get a row iterator over the provided memtables and sstables, between the provided keys
and filtered by the queryfilter.
|
static void |
Keyspace.indexRow(DecoratedKey key,
ColumnFamilyStore cfs,
java.util.Set<java.lang.String> idxNames) |
Column |
Column.localCopy(ColumnFamilyStore cfs) |
Column |
CounterColumn.localCopy(ColumnFamilyStore cfs) |
CounterColumn |
CounterUpdateColumn.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) |
static void |
SystemKeyspace.saveTruncationRecord(ColumnFamilyStore cfs,
long truncatedAt,
ReplayPosition position) |
static java.util.UUID |
SystemKeyspace.startCompaction(ColumnFamilyStore cfs,
java.lang.Iterable<SSTableReader> toCompact)
Write compaction log, except columfamilies under system keyspace.
|
Constructor and Description |
---|
CollationController(ColumnFamilyStore cfs,
QueryFilter filter,
int gcBefore) |
DataTracker(ColumnFamilyStore cfstore) |
Memtable(ColumnFamilyStore cfs) |
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,
SizeTieredCompactionStrategyOptions options) |
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
java.util.List<SSTableReader> sstables) |
static SSTableWriter |
CompactionManager.createWriter(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
int expectedBloomFilterSize,
SSTableReader sstable) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.util.Set<SSTableReader> compacting,
java.util.Set<SSTableReader> overlapping,
int gcBefore)
Finds expired sstables
works something like this;
1.
|
void |
CompactionManager.performCleanup(ColumnFamilyStore cfStore,
CounterId.OneShotRenewer renewer) |
void |
CompactionManager.performMaximal(ColumnFamilyStore cfStore) |
void |
CompactionManager.performScrub(ColumnFamilyStore cfStore,
boolean skipCorrupted) |
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.submitUserDefined(ColumnFamilyStore cfs,
java.util.Collection<Descriptor> dataFiles,
int gcBefore) |
java.util.concurrent.Future<java.lang.Object> |
CompactionManager.submitValidation(ColumnFamilyStore cfStore,
Validator validator)
Does not mutate data, so is not scheduled.
|
Modifier and Type | Method and Description |
---|---|
boolean |
CompactionManager.isCompacting(java.lang.Iterable<ColumnFamilyStore> cfses) |
Constructor and Description |
---|
AbstractCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
AbstractCompactionTask(ColumnFamilyStore cfs,
java.lang.Iterable<SSTableReader> sstables) |
CompactionController(ColumnFamilyStore cfs,
int maxValue)
Constructor that subclasses may use when overriding shouldPurge to not need overlappingTree
|
CompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore) |
CompactionTask(ColumnFamilyStore cfs,
java.lang.Iterable<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 level,
int gcBefore,
long maxSSTableBytes) |
Scrubber(ColumnFamilyStore cfs,
SSTableReader sstable,
boolean skipCorrupted) |
Scrubber(ColumnFamilyStore cfs,
SSTableReader sstable,
boolean skipCorrupted,
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,
DataRange dataRange,
java.util.List<IndexExpression> clause,
int maxResults,
boolean countCQL3Rows,
long timestamp) |
Constructor and Description |
---|
ExtendedFilter.WithClauses(ColumnFamilyStore cfs,
DataRange range,
java.util.List<IndexExpression> clause,
int maxResults,
boolean countCQL3Rows,
long timestamp) |
ExtendedFilter(ColumnFamilyStore cfs,
DataRange dataRange,
int maxResults,
boolean countCQL3Rows,
long timestamp) |
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 |
protected ColumnFamilyStore |
AbstractSimplePerColumnSecondaryIndex.indexCfs |
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.Set<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 |
---|---|
void |
Validator.prepare(ColumnFamilyStore cfs) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<ColumnFamilyStore> |
StorageService.getValidColumnFamilies(boolean allowIndexes,
boolean autoAddIndexes,
java.lang.String keyspaceName,
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) |
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 | Method and Description |
---|---|
protected SSTableWriter |
StreamReader.createWriter(ColumnFamilyStore cfs,
long totalSize) |
protected void |
StreamReader.writeRow(SSTableWriter writer,
java.io.DataInput in,
ColumnFamilyStore cfs) |
Copyright © 2014 The Apache Software Foundation