Modifier and Type | Method and Description |
---|---|
java.util.concurrent.Future<Pair<K,V>> |
AutoSavingCache.CacheSerializer.deserialize(DataInputPlus in,
ColumnFamilyStore cfs) |
void |
AutoSavingCache.CacheSerializer.serialize(K key,
DataOutputPlus out,
ColumnFamilyStore cfs) |
Modifier and Type | Method and Description |
---|---|
ColumnFamilyStore |
Schema.getColumnFamilyStoreIncludingIndexes(Pair<java.lang.String,java.lang.String> ksNameAndCFName)
Retrieve a CFS by name even if that CFS is an index
An index is identified by looking for '.' in the CF name and separating to find the base table
containing the index
|
ColumnFamilyStore |
Schema.getColumnFamilyStoreInstance(java.util.UUID cfId) |
Modifier and Type | Method and Description |
---|---|
static AbstractCompactionStrategy |
CFMetaData.createCompactionStrategyInstance(ColumnFamilyStore cfs,
CompactionParams compactionParams) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
AbstractReadCommandBuilder.cfs |
ColumnFamilyStore |
Memtable.cfs |
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
CFMetaData metadata,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
CFMetaData metadata,
boolean loadSSTables) |
static ColumnFamilyStore |
ColumnFamilyStore.createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
CFMetaData metadata,
Directories directories,
boolean loadSSTables,
boolean registerBookkeeping,
boolean offline)
This is only directly used by offline tools
|
ColumnFamilyStore |
Keyspace.getColumnFamilyStore(java.lang.String cfName) |
ColumnFamilyStore |
Keyspace.getColumnFamilyStore(java.util.UUID id) |
static ColumnFamilyStore |
ColumnFamilyStore.getIfExists(java.lang.String ksName,
java.lang.String cfName)
Returns a ColumnFamilyStore by ksname and cfname if it exists, null otherwise
Differently from others, this method does not throw exception if the keyspace or table does not exist.
|
static ColumnFamilyStore |
ColumnFamilyStore.getIfExists(java.util.UUID cfId)
Returns a ColumnFamilyStore by cfId if it exists, null otherwise
Differently from others, this method does not throw exception if the table does not exist.
|
static ColumnFamilyStore |
Keyspace.openAndGetStore(CFMetaData cfm) |
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() |
java.lang.Iterable<ColumnFamilyStore> |
Keyspace.getValidColumnFamilies(boolean allowIndexes,
boolean autoAddIndexes,
java.lang.String... cfNames) |
Constructor and Description |
---|
Memtable(java.util.concurrent.atomic.AtomicReference<CommitLogPosition> commitLogLowerBound,
ColumnFamilyStore cfs) |
MemtableUnfilteredPartitionIterator(ColumnFamilyStore cfs,
java.util.Iterator<java.util.Map.Entry<PartitionPosition,AtomicBTreePartition>> iter,
boolean isForThrift,
int minLocalDeletionTime,
ColumnFilter columnFilter,
DataRange dataRange) |
PartitionRangeBuilder(ColumnFamilyStore cfs) |
SinglePartitionBuilder(ColumnFamilyStore cfs,
DecoratedKey key) |
SinglePartitionSliceBuilder(ColumnFamilyStore cfs,
DecoratedKey key) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
AbstractCompactionStrategy.cfs |
protected ColumnFamilyStore |
AbstractCompactionTask.cfs |
ColumnFamilyStore |
CompactionController.cfs |
Modifier and Type | Method and Description |
---|---|
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
int fanoutSize,
java.lang.Iterable<SSTableReader> sstables,
SizeTieredCompactionStrategyOptions options) |
static LeveledManifest |
LeveledManifest.create(ColumnFamilyStore cfs,
int maxSSTableSize,
int fanoutSize,
java.util.List<SSTableReader> sstables) |
static SSTableWriter |
CompactionManager.createWriter(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
long expectedBloomFilterSize,
long repairedAt,
SSTableReader sstable,
LifecycleTransaction txn) |
static SSTableWriter |
CompactionManager.createWriterForAntiCompaction(ColumnFamilyStore cfs,
java.io.File compactionFileLocation,
int expectedBloomFilterSize,
long repairedAt,
java.util.Collection<SSTableReader> sstables,
LifecycleTransaction txn) |
void |
CompactionManager.forceCompactionForTokenRange(ColumnFamilyStore cfStore,
java.util.Collection<Range<Token>> ranges) |
abstract CompactionAwareWriter |
AbstractCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
CompactionAwareWriter |
CompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction transaction,
java.util.Set<SSTableReader> nonExpiredSSTables) |
CompactionAwareWriter |
LeveledCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
CompactionAwareWriter |
SSTableSplitter.SplittingCompactionTask.getCompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
static int |
CompactionManager.getDefaultGcBefore(ColumnFamilyStore cfs,
int nowInSec) |
static int |
SizeTieredCompactionStrategy.getEstimatedCompactionsByTasks(ColumnFamilyStore cfs,
java.util.List<java.util.List<SSTableReader>> tasks) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore) |
static java.util.Set<SSTableReader> |
CompactionController.getFullyExpiredSSTables(ColumnFamilyStore cfStore,
java.lang.Iterable<SSTableReader> compacting,
java.lang.Iterable<SSTableReader> overlapping,
int gcBefore,
boolean ignoreOverlaps)
Finds expired sstables
works something like this;
1.
|
void |
CompactionManager.performAnticompaction(ColumnFamilyStore cfs,
java.util.Collection<Range<Token>> ranges,
Refs<SSTableReader> validatedForRepair,
LifecycleTransaction txn,
long repairedAt,
java.util.UUID parentRepairSession)
Make sure the {validatedForRepair} are marked for compaction before calling this.
|
CompactionManager.AllSSTableOpStatus |
CompactionManager.performCleanup(ColumnFamilyStore cfStore,
int jobs) |
CompactionManager.AllSSTableOpStatus |
CompactionManager.performGarbageCollection(ColumnFamilyStore cfStore,
CompactionParams.TombstoneOption tombstoneOption,
int jobs) |
void |
CompactionManager.performMaximal(ColumnFamilyStore cfStore,
boolean splitOutput) |
CompactionManager.AllSSTableOpStatus |
CompactionManager.performScrub(ColumnFamilyStore cfs,
boolean skipCorrupted,
boolean checkData,
boolean reinsertOverflowedTTL,
int jobs) |
CompactionManager.AllSSTableOpStatus |
CompactionManager.performScrub(ColumnFamilyStore cfs,
boolean skipCorrupted,
boolean checkData,
int jobs) |
CompactionManager.AllSSTableOpStatus |
CompactionManager.performSSTableRewrite(ColumnFamilyStore cfs,
boolean excludeCurrentVersion,
int jobs) |
CompactionManager.AllSSTableOpStatus |
CompactionManager.performVerify(ColumnFamilyStore cfs,
boolean extendedVerify) |
CompactionManager.AllSSTableOpStatus |
CompactionManager.relocateSSTables(ColumnFamilyStore cfs,
int jobs) |
com.google.common.util.concurrent.ListenableFuture<?> |
CompactionManager.submitAntiCompaction(ColumnFamilyStore cfs,
java.util.Collection<Range<Token>> ranges,
Refs<SSTableReader> sstables,
long repairedAt,
java.util.UUID parentRepairSession)
Submit anti-compactions for a collection of SSTables over a set of repaired ranges and marks corresponding SSTables
as repaired.
|
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.List<java.util.concurrent.Future<?>> |
CompactionManager.submitMaximal(ColumnFamilyStore cfStore,
int gcBefore,
boolean splitOutput) |
java.util.concurrent.Future<?> |
CompactionManager.submitUserDefined(ColumnFamilyStore cfs,
java.util.Collection<Descriptor> dataFiles,
int gcBefore) |
java.util.concurrent.Future<?> |
CompactionManager.submitValidation(ColumnFamilyStore cfStore,
Validator validator)
Does not mutate data, so is not scheduled.
|
Modifier and Type | Method and Description |
---|---|
void |
CompactionManager.interruptCompactionForCFs(java.lang.Iterable<ColumnFamilyStore> cfss,
boolean interruptValidation) |
boolean |
CompactionManager.isCompacting(java.lang.Iterable<ColumnFamilyStore> cfses) |
void |
CompactionManager.waitForCessation(java.lang.Iterable<ColumnFamilyStore> cfss) |
Constructor and Description |
---|
AbstractCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
AbstractCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction transaction) |
CompactionController(ColumnFamilyStore cfs,
int maxValue) |
CompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore) |
CompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore,
com.google.common.util.concurrent.RateLimiter limiter,
CompactionParams.TombstoneOption tombstoneOption) |
CompactionLogger(ColumnFamilyStore cfs,
CompactionStrategyManager csm) |
CompactionStrategyManager(ColumnFamilyStore cfs) |
CompactionStrategyManager(ColumnFamilyStore cfs,
java.util.function.Supplier<DiskBoundaries> boundariesSupplier,
boolean partitionSSTablesByTokenRange) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore,
boolean keepOriginals) |
CompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore,
boolean offline,
boolean keepOriginals)
Deprecated.
|
DateTieredCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options)
Deprecated.
|
LeveledCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
LeveledCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int level,
int gcBefore,
long maxSSTableBytes,
boolean majorCompaction) |
Scrubber(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
boolean skipCorrupted,
boolean checkData) |
Scrubber(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
boolean skipCorrupted,
boolean checkData,
boolean reinsertOverflowedTTLRows) |
Scrubber(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
boolean skipCorrupted,
OutputHandler outputHandler,
boolean checkData,
boolean reinsertOverflowedTTLRows) |
SizeTieredCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
SplitController(ColumnFamilyStore cfs) |
SplittingCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
int sstableSizeInMB) |
SSTableSplitter(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
int sstableSizeInMB) |
TimeWindowCompactionController(ColumnFamilyStore cfs,
java.util.Set<SSTableReader> compacting,
int gcBefore,
boolean ignoreOverlaps) |
TimeWindowCompactionStrategy(ColumnFamilyStore cfs,
java.util.Map<java.lang.String,java.lang.String> options) |
TimeWindowCompactionTask(ColumnFamilyStore cfs,
LifecycleTransaction txn,
int gcBefore,
boolean ignoreOverlaps) |
Upgrader(ColumnFamilyStore cfs,
LifecycleTransaction txn,
OutputHandler outputHandler) |
Verifier(ColumnFamilyStore cfs,
SSTableReader sstable,
boolean isOffline) |
Verifier(ColumnFamilyStore cfs,
SSTableReader sstable,
OutputHandler outputHandler,
boolean isOffline) |
Modifier and Type | Field and Description |
---|---|
protected ColumnFamilyStore |
CompactionAwareWriter.cfs |
Constructor and Description |
---|
CompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean keepOriginals) |
CompactionAwareWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean offline,
boolean keepOriginals)
Deprecated.
|
DefaultCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
DefaultCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean offline,
boolean keepOriginals,
int sstableLevel)
Deprecated.
|
DefaultCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
boolean keepOriginals,
int sstableLevel) |
MajorLeveledCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize) |
MajorLeveledCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
boolean keepOriginals) |
MajorLeveledCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
boolean offline,
boolean keepOriginals)
Deprecated.
|
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level) |
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level,
boolean keepOriginals) |
MaxSSTableSizeWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long maxSSTableSize,
int level,
boolean offline,
boolean keepOriginals)
Deprecated.
|
SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables) |
SplittingSizeTieredCompactionWriter(ColumnFamilyStore cfs,
Directories directories,
LifecycleTransaction txn,
java.util.Set<SSTableReader> nonExpiredSSTables,
long smallestSSTable) |
Modifier and Type | Method and Description |
---|---|
abstract float |
DataLimits.estimateTotalResults(ColumnFamilyStore cfs)
Estimate the number of results (the definition of "results" will be rows for CQL queries
and partitions for thrift ones) that a full scan of the provided cfs would yield.
|
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
Tracker.cfstore |
Modifier and Type | Method and Description |
---|---|
static boolean |
LifecycleTransaction.removeUnfinishedLeftovers(ColumnFamilyStore cfs) |
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<ColumnFamilyStore> |
TableViews.allViewsCfs() |
Constructor and Description |
---|
View(ViewDefinition definition,
ColumnFamilyStore baseCfs) |
ViewBuilder(ColumnFamilyStore baseCfs,
View view) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
SecondaryIndexManager.baseCfs
The underlying column family containing the source data for these indexes
|
Modifier and Type | Method and Description |
---|---|
static ColumnFamilyStore |
SecondaryIndexManager.getParentCfs(ColumnFamilyStore cfs)
Returns the parent of the specified
ColumnFamilyStore . |
Modifier and Type | Method and Description |
---|---|
java.util.Set<ColumnFamilyStore> |
SecondaryIndexManager.getAllIndexColumnFamilyStores() |
java.util.Optional<ColumnFamilyStore> |
Index.getBackingTable()
If the index implementation uses a local table to store its index data this method should return a
handle to it.
|
Modifier and Type | Method and Description |
---|---|
SecondaryIndexBuilder |
Index.IndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs,
java.util.Set<Index> indexes,
java.util.Collection<SSTableReader> sstables) |
SecondaryIndexBuilder |
Index.CollatedViewIndexBuildingSupport.getIndexBuildTask(ColumnFamilyStore cfs,
java.util.Set<Index> indexes,
java.util.Collection<SSTableReader> sstables) |
static java.lang.String |
SecondaryIndexManager.getIndexName(ColumnFamilyStore cfs)
Returns the index name
|
static ColumnFamilyStore |
SecondaryIndexManager.getParentCfs(ColumnFamilyStore cfs)
Returns the parent of the specified
ColumnFamilyStore . |
static boolean |
SecondaryIndexManager.isIndexColumnFamilyStore(ColumnFamilyStore cfs)
Checks if the specified
ColumnFamilyStore is a secondary index. |
Constructor and Description |
---|
SecondaryIndexManager(ColumnFamilyStore baseCfs) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
CassandraIndex.baseCfs |
protected ColumnFamilyStore |
CassandraIndex.indexCfs |
Modifier and Type | Method and Description |
---|---|
ColumnFamilyStore |
CassandraIndex.getIndexCfs() |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<ColumnFamilyStore> |
CassandraIndex.getBackingTable() |
Modifier and Type | Method and Description |
---|---|
static CassandraIndex |
CassandraIndex.newIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexMetadata)
Factory method for new CassandraIndex instances
|
CassandraIndex |
CassandraIndexFunctions.newIndexInstance(ColumnFamilyStore baseCfs,
IndexMetadata indexMetadata) |
Constructor and Description |
---|
CassandraIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
CollatedViewIndexBuilder(ColumnFamilyStore cfs,
java.util.Set<Index> indexers,
ReducingKeyIterator iter) |
Constructor and Description |
---|
ClusteringColumnIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
CollectionEntryIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
CollectionKeyIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
CollectionKeyIndexBase(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
CollectionValueIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
PartitionKeyIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
RegularColumnIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
Constructor and Description |
---|
KeysIndex(ColumnFamilyStore baseCfs,
IndexMetadata indexDef) |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<ColumnFamilyStore> |
SASIIndex.getBackingTable() |
Constructor and Description |
---|
SASIIndex(ColumnFamilyStore baseCfs,
IndexMetadata config) |
Constructor and Description |
---|
QueryController(ColumnFamilyStore cfs,
PartitionRangeReadCommand command,
long timeQuotaMs) |
QueryPlan(ColumnFamilyStore cfs,
ReadCommand command,
long executionQuotaMs) |
Modifier and Type | Method and Description |
---|---|
static SSTableRewriter |
SSTableRewriter.construct(ColumnFamilyStore cfs,
LifecycleTransaction transaction,
boolean keepOriginals,
long maxAge) |
static SSTableTxnWriter |
SSTableTxnWriter.create(ColumnFamilyStore cfs,
Descriptor descriptor,
long keyCount,
long repairedAt,
int sstableLevel,
SerializationHeader header) |
static SSTableTxnWriter |
SSTableTxnWriter.create(ColumnFamilyStore cfs,
java.lang.String filename,
long keyCount,
long repairedAt,
int sstableLevel,
SerializationHeader header) |
static SSTableTxnWriter |
SSTableTxnWriter.create(ColumnFamilyStore cfs,
java.lang.String filename,
long keyCount,
long repairedAt,
SerializationHeader header) |
Modifier and Type | Field and Description |
---|---|
ColumnFamilyStore |
RangeAwareSSTableWriter.cfs |
Modifier and Type | Method and Description |
---|---|
SSTableReader |
SSTableReader.cloneWithNewSummarySamplingLevel(ColumnFamilyStore parent,
int samplingLevel)
Returns a new SSTableReader with the same properties as this SSTableReader except that a new IndexSummary will
be built at the target samplingLevel.
|
static SSTableReader |
SSTableReader.openNoValidation(Descriptor descriptor,
java.util.Set<Component> components,
ColumnFamilyStore cfs) |
Constructor and Description |
---|
RangeAwareSSTableWriter(ColumnFamilyStore cfs,
long estimatedKeys,
long repairedAt,
SSTableFormat.Type format,
int sstableLevel,
long totalSize,
LifecycleTransaction txn,
SerializationHeader header) |
Constructor and Description |
---|
TableMetrics(ColumnFamilyStore cfs)
Creates metrics for given
ColumnFamilyStore . |
Modifier and Type | Method and Description |
---|---|
void |
Validator.prepare(ColumnFamilyStore cfs,
MerkleTrees tree) |
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<CounterCacheKey,ClockAndCount>> |
CacheService.CounterCacheSerializer.deserialize(DataInputPlus in,
ColumnFamilyStore cfs) |
java.util.concurrent.Future<Pair<RowCacheKey,IRowCacheEntry>> |
CacheService.RowCacheSerializer.deserialize(DataInputPlus in,
ColumnFamilyStore cfs) |
java.util.concurrent.Future<Pair<KeyCacheKey,RowIndexEntry>> |
CacheService.KeyCacheSerializer.deserialize(DataInputPlus input,
ColumnFamilyStore cfs) |
void |
CacheService.CounterCacheSerializer.serialize(CounterCacheKey key,
DataOutputPlus out,
ColumnFamilyStore cfs) |
void |
CacheService.KeyCacheSerializer.serialize(KeyCacheKey key,
DataOutputPlus out,
ColumnFamilyStore cfs) |
void |
CacheService.RowCacheSerializer.serialize(RowCacheKey key,
DataOutputPlus out,
ColumnFamilyStore cfs) |
Modifier and Type | Method and Description |
---|---|
java.util.UUID |
ActiveRepairService.prepareForRepair(java.util.UUID parentRepairSession,
java.net.InetAddress coordinator,
java.util.Set<java.net.InetAddress> endpoints,
RepairOption options,
java.util.List<ColumnFamilyStore> columnFamilyStores) |
void |
ActiveRepairService.registerParentRepairSession(java.util.UUID parentRepairSession,
java.net.InetAddress coordinator,
java.util.List<ColumnFamilyStore> columnFamilyStores,
java.util.Collection<Range<Token>> ranges,
boolean isIncremental,
long timestamp,
boolean isGlobal) |
Constructor and Description |
---|
ParentRepairSession(java.net.InetAddress coordinator,
java.util.List<ColumnFamilyStore> columnFamilyStores,
java.util.Collection<Range<Token>> ranges,
boolean isIncremental,
long repairedAt,
boolean isGlobal) |
Modifier and Type | Method and Description |
---|---|
protected SSTableMultiWriter |
StreamReader.createWriter(ColumnFamilyStore cfs,
long totalSize,
long repairedAt,
SSTableFormat.Type format) |
void |
StreamHook.reportIncomingFile(ColumnFamilyStore cfs,
SSTableMultiWriter writer,
StreamSession session,
int sequenceNumber) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<StreamSession.SSTableStreamingSections> |
StreamSession.getSSTableSectionsForRanges(java.util.Collection<Range<Token>> ranges,
java.util.Collection<ColumnFamilyStore> stores,
long overriddenRepairedAt,
boolean isIncremental) |
Copyright © 2020 The Apache Software Foundation