public class ColumnFamilyStore extends java.lang.Object implements ColumnFamilyStoreMBean
| Modifier and Type | Class and Description |
|---|---|
static class |
ColumnFamilyStore.AbstractScanIterator |
static class |
ColumnFamilyStore.FlushLargestColumnFamily
Finds the largest memtable, as a percentage of *either* on- or off-heap memory limits, and immediately
queues it for flushing.
|
static class |
ColumnFamilyStore.RefViewFragment |
static class |
ColumnFamilyStore.ViewFragment |
| Modifier and Type | Field and Description |
|---|---|
static com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> |
CANONICAL_SSTABLES |
Directories |
directories |
SecondaryIndexManager |
indexManager |
Keyspace |
keyspace |
CFMetaData |
metadata |
ColumnFamilyMetrics |
metric |
java.lang.String |
name |
IPartitioner |
partitioner |
OpOrder |
readOrdering |
long |
sampleLatencyNanos |
static com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> |
UNREPAIRED_SSTABLES |
| Modifier and Type | Method and Description |
|---|---|
void |
addSSTable(SSTableReader sstable) |
void |
addSSTables(java.util.Collection<SSTableReader> sstables) |
static java.lang.Iterable<ColumnFamilyStore> |
all() |
void |
apply(DecoratedKey key,
ColumnFamily columnFamily,
SecondaryIndexManager.Updater indexer,
OpOrder.Group opGroup,
ReplayPosition replayPosition)
Insert/Update the column family for this key.
|
void |
beginLocalSampling(java.lang.String sampler,
int capacity)
begin sampling for a specific sampler with a given capacity.
|
void |
cleanupCache() |
protected static void |
clearEphemeralSnapshots(Directories directories) |
void |
clearSnapshot(java.lang.String snapshotName)
Clear all the snapshots for a given column family.
|
void |
clearUnsafe()
For testing.
|
java.lang.Iterable<ColumnFamilyStore> |
concatWithIndexes() |
boolean |
containsCachedRow(DecoratedKey key) |
static ColumnFamilyStore |
createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
boolean loadSSTables) |
static ColumnFamilyStore |
createColumnFamilyStore(Keyspace keyspace,
java.lang.String columnFamily,
IPartitioner partitioner,
CFMetaData metadata) |
void |
disableAutoCompaction() |
ReplayPosition |
discardSSTables(long truncatedAt)
Discard all SSTables that were created before given timestamp.
|
void |
enableAutoCompaction() |
void |
enableAutoCompaction(boolean waitForFutures)
used for tests - to be able to check things after a minor compaction
|
long |
estimatedKeysForRange(Range<Token> range) |
long |
estimateKeys() |
java.util.List<Row> |
filter(ColumnFamilyStore.AbstractScanIterator rowIterator,
ExtendedFilter filter) |
javax.management.openmbean.CompositeData |
finishLocalSampling(java.lang.String sampler,
int count) |
void |
forceBlockingFlush() |
CompactionManager.AllSSTableOpStatus |
forceCleanup() |
com.google.common.util.concurrent.ListenableFuture<?> |
forceFlush() |
com.google.common.util.concurrent.ListenableFuture<?> |
forceFlush(ReplayPosition flushIfDirtyBefore)
Flush if there is unflushed data that was written to the CommitLog before @param flushIfDirtyBefore
(inclusive).
|
void |
forceMajorCompaction()
force a major compaction of this column family
|
int |
gcBefore(long now) |
Refs<SSTableReader> |
getAndReferenceOverlappingSSTables(java.lang.Iterable<SSTableReader> sstables)
like getOverlappingSSTables, but acquires references before returning
|
static java.lang.Runnable |
getBackgroundCompactionTaskSubmitter() |
long |
getBloomFilterDiskSpaceUsed() |
long |
getBloomFilterFalsePositives() |
double |
getBloomFilterFalseRatio() |
long |
getBloomFilterOffHeapMemoryUsed() |
java.util.List<java.lang.String> |
getBuiltIndexes()
Returns a list of the names of the built column indexes for current store
|
ClockAndCount |
getCachedCounter(java.nio.ByteBuffer partitionKey,
CellName cellName) |
ColumnFamily |
getColumnFamily(DecoratedKey key,
Composite start,
Composite finish,
boolean reversed,
int limit,
long timestamp) |
ColumnFamily |
getColumnFamily(QueryFilter filter)
get a list of columns starting from a given column, in a specified order.
|
java.lang.String |
getColumnFamilyName() |
java.util.Map<java.lang.String,java.lang.String> |
getCompactionParameters() |
java.lang.String |
getCompactionParametersJson() |
AbstractCompactionStrategy |
getCompactionStrategy() |
java.lang.String |
getCompactionStrategyClass()
Gets the compaction strategy class name
|
CellNameType |
getComparator() |
long |
getCompressionMetadataOffHeapMemoryUsed() |
java.util.Map<java.lang.String,java.lang.String> |
getCompressionParameters()
Get the compression parameters
|
double |
getCompressionRatio() |
DataTracker |
getDataTracker()
Package protected for access from the CompactionManager.
|
double |
getDroppableTombstoneRatio()
Get the ratio of droppable tombstones to real columns (and non-droppable tombstones)
|
long[] |
getEstimatedColumnCountHistogram() |
long[] |
getEstimatedRowSizeHistogram() |
long |
getExpectedCompactedFileSize(java.lang.Iterable<SSTableReader> sstables,
OperationType operation)
Calculate expected file size of SSTable after compaction.
|
long |
getIndexSummaryOffHeapMemoryUsed() |
long[] |
getLifetimeRangeLatencyHistogramMicros() |
long[] |
getLifetimeReadLatencyHistogramMicros() |
long[] |
getLifetimeWriteLatencyHistogramMicros() |
double |
getLiveCellsPerSlice()
Number of live cells retreived during the last slicequery
|
long |
getLiveDiskSpaceUsed() |
int |
getLiveSSTableCount() |
int |
getMaximumCompactionThreshold()
Gets the maximum number of sstables in queue before compaction kicks off
|
long |
getMaxRowSize() |
SSTableReader |
getMaxSizeFile(java.lang.Iterable<SSTableReader> sstables) |
int |
getMeanColumns() |
long |
getMeanRowSize() |
long |
getMemtableColumnsCount()
Returns the total number of columns present in the memtable.
|
long |
getMemtableDataSize()
Returns the total amount of data stored in the memtable, including
column related overhead.
|
int |
getMemtableSwitchCount()
Returns the number of times that a flush has resulted in the
memtable being switched out.
|
int |
getMinimumCompactionThreshold()
Gets the minimum number of sstables in queue before compaction kicks off
|
long |
getMinRowSize() |
java.util.Collection<SSTableReader> |
getOverlappingSSTables(java.lang.Iterable<SSTableReader> sstables) |
int |
getPendingTasks() |
long |
getRangeCount() |
java.util.List<Row> |
getRangeSlice(AbstractBounds<RowPosition> range,
java.util.List<IndexExpression> rowFilter,
IDiskAtomFilter columnFilter,
int maxResults) |
java.util.List<Row> |
getRangeSlice(AbstractBounds<RowPosition> range,
java.util.List<IndexExpression> rowFilter,
IDiskAtomFilter columnFilter,
int maxResults,
long now) |
java.util.List<Row> |
getRangeSlice(AbstractBounds<RowPosition> range,
java.util.List<IndexExpression> rowFilter,
IDiskAtomFilter columnFilter,
int maxResults,
long now,
boolean countCQL3Rows,
boolean isPaging) |
java.util.List<Row> |
getRangeSlice(ExtendedFilter filter) |
ColumnFamily |
getRawCachedRow(DecoratedKey key) |
long |
getReadCount() |
long |
getRecentBloomFilterFalsePositives() |
double |
getRecentBloomFilterFalseRatio() |
long[] |
getRecentRangeLatencyHistogramMicros() |
double |
getRecentRangeLatencyMicros() |
long[] |
getRecentReadLatencyHistogramMicros() |
double |
getRecentReadLatencyMicros() |
long[] |
getRecentSSTablesPerReadHistogram() |
long[] |
getRecentWriteLatencyHistogramMicros() |
double |
getRecentWriteLatencyMicros() |
java.util.Set<SSTableReader> |
getRepairedSSTables() |
long |
getSnapshotCreationTime(java.lang.String snapshotName) |
java.util.Map<java.lang.String,Pair<java.lang.Long,java.lang.Long>> |
getSnapshotDetails() |
Refs<SSTableReader> |
getSnapshotSSTableReader(java.lang.String tag) |
int[] |
getSSTableCountPerLevel() |
java.util.Collection<SSTableReader> |
getSSTables() |
java.util.List<java.lang.String> |
getSSTablesForKey(java.lang.String key)
Returns a list of filenames that contain the given key on this node
|
long[] |
getSSTablesPerReadHistogram() |
java.lang.String |
getTempSSTablePath(java.io.File directory) |
double |
getTombstonesPerSlice()
Number of tombstoned cells retreived during the last slicequery
|
ColumnFamily |
getTopLevelColumns(QueryFilter filter,
int gcBefore) |
long |
getTotalDiskSpaceUsed() |
long |
getTotalRangeLatencyMicros() |
long |
getTotalReadLatencyMicros() |
long |
getTotalWriteLatencyMicros() |
java.util.Set<SSTableReader> |
getUncompactingSSTables() |
int |
getUnleveledSSTables() |
java.util.Set<SSTableReader> |
getUnrepairedSSTables() |
long |
getWriteCount() |
void |
invalidate()
call when dropping or renaming a CF.
|
void |
invalidateCachedRow(DecoratedKey key) |
void |
invalidateCachedRow(RowCacheKey key) |
int |
invalidateCounterCache(java.util.Collection<Bounds<Token>> boundsToInvalidate) |
int |
invalidateRowCache(java.util.Collection<Bounds<Token>> boundsToInvalidate) |
boolean |
isAutoCompactionDisabled() |
boolean |
isCounterCacheEnabled() |
boolean |
isEmpty() |
boolean |
isFilterFullyCoveredBy(IDiskAtomFilter filter,
ColumnFamily cachedCf,
long now) |
boolean |
isIndex()
true if this CFS contains secondary index data
|
boolean |
isKeyCacheEnabled() |
boolean |
isRowCacheEnabled() |
boolean |
isValid() |
java.lang.Iterable<DecoratedKey> |
keySamples(Range<Token> range) |
void |
loadNewSSTables()
#Scan through Keyspace/ColumnFamily's data directory
determine which SSTables should be loaded and load them
|
static void |
loadNewSSTables(java.lang.String ksName,
java.lang.String cfName)
See #
StorageService.loadNewSSTables(String, String) for more info |
ExtendedFilter |
makeExtendedFilter(AbstractBounds<RowPosition> range,
IDiskAtomFilter columnFilter,
java.util.List<IndexExpression> rowFilter,
int maxResults,
boolean countCQL3Rows,
boolean isPaging,
long timestamp) |
ExtendedFilter |
makeExtendedFilter(AbstractBounds<RowPosition> keyRange,
SliceQueryFilter columnRange,
Composite columnStart,
Composite columnStop,
java.util.List<IndexExpression> rowFilter,
int maxResults,
boolean countCQL3Rows,
long now)
Allows generic range paging with the slice column filter.
|
java.lang.Iterable<SSTableReader> |
markAllCompacting() |
void |
markObsolete(java.util.Collection<SSTableReader> sstables,
OperationType compactionType) |
void |
maybeUpdateRowCache(DecoratedKey key) |
long |
oldestUnflushedMemtable()
Returns the creation time of the oldest memtable not fully flushed yet.
|
void |
putCachedCounter(java.nio.ByteBuffer partitionKey,
CellName cellName,
ClockAndCount clockAndCount) |
SliceQueryFilter |
readFilterForCache() |
void |
rebuildSecondaryIndex(java.lang.String idxName) |
static void |
rebuildSecondaryIndex(java.lang.String ksName,
java.lang.String cfName,
java.lang.String... idxNames) |
void |
reload() |
static ColumnFamily |
removeDeleted(ColumnFamily cf,
int gcBefore)
Removes deleted columns and purges gc-able tombstones.
|
static ColumnFamily |
removeDeleted(ColumnFamily cf,
int gcBefore,
SecondaryIndexManager.Updater indexer) |
static ColumnFamily |
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 |
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).
|
static void |
removeUnfinishedCompactionLeftovers(CFMetaData metadata,
java.util.Map<java.lang.Integer,java.util.UUID> unfinishedCompactions)
Replacing compacted sstables is atomic as far as observers of DataTracker are concerned, but not on the
filesystem: first the new sstables are renamed to "live" status (i.e., the tmp marker is removed), then
their ancestors are removed.
|
<V> V |
runWithCompactionsDisabled(java.util.concurrent.Callable<V> callable,
boolean interruptValidation) |
CompactionManager.AllSSTableOpStatus |
scrub(boolean disableSnapshot,
boolean skipCorrupted,
boolean checkData) |
static void |
scrubDataDirectories(CFMetaData metadata)
Removes unnecessary files from the cf directory at startup: these include temp files, orphans, zero-length files
and compacted sstables.
|
java.util.List<Row> |
search(AbstractBounds<RowPosition> range,
java.util.List<IndexExpression> clause,
IDiskAtomFilter dataFilter,
int maxResults) |
java.util.List<Row> |
search(AbstractBounds<RowPosition> range,
java.util.List<IndexExpression> clause,
IDiskAtomFilter dataFilter,
int maxResults,
long now) |
java.util.List<Row> |
search(ExtendedFilter filter) |
ColumnFamilyStore.ViewFragment |
select(com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> filter) |
ColumnFamilyStore.RefViewFragment |
selectAndReference(com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> filter) |
void |
setCompactionParameters(java.util.Map<java.lang.String,java.lang.String> options)
Sets the compaction parameters locally for this node
Note that this will be set until an ALTER with compaction = {..} is executed or the node is restarted
|
void |
setCompactionParametersJson(java.lang.String options)
Sets the compaction parameters locally for this node
Note that this will be set until an ALTER with compaction = {..} is executed or the node is restarted
|
void |
setCompactionStrategyClass(java.lang.String compactionStrategyClass)
Sets the compaction strategy by class name
|
void |
setCompactionThresholds(int minThreshold,
int maxThreshold)
Sets the maximum and maximum number of SSTables in queue before compaction kicks off
|
void |
setCompressionParameters(java.util.Map<java.lang.String,java.lang.String> opts)
Set the compression parameters
|
void |
setCrcCheckChance(double crcCheckChance)
Set new crc check chance
|
void |
setMaximumCompactionThreshold(int maxCompactionThreshold)
Sets the maximum number of sstables in queue before compaction kicks off
|
void |
setMinimumCompactionThreshold(int minCompactionThreshold)
Sets the minimum number of sstables in queue before compaction kicks off
|
static void |
shutdownPostFlushExecutor() |
void |
snapshot(java.lang.String snapshotName)
Take a snap shot of this columnfamily store.
|
void |
snapshot(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral) |
boolean |
snapshotExists(java.lang.String snapshotName) |
void |
snapshotWithoutFlush(java.lang.String snapshotName) |
void |
snapshotWithoutFlush(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral) |
CompactionManager.AllSSTableOpStatus |
sstablesRewrite(boolean excludeCurrentVersion) |
com.google.common.util.concurrent.ListenableFuture<?> |
switchMemtable() |
java.util.concurrent.Future<?> |
switchMemtableIfCurrent(Memtable memtable)
Switches the memtable iff the live memtable is the one provided
|
java.lang.String |
toString() |
long |
trueSnapshotsSize() |
void |
truncateBlocking()
Truncate deletes the entire column family's data with no expensive tombstone creation
|
com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> |
viewFilter(AbstractBounds<RowPosition> rowBounds) |
com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> |
viewFilter(DecoratedKey key) |
public final Keyspace keyspace
public final java.lang.String name
public final CFMetaData metadata
public final IPartitioner partitioner
public final OpOrder readOrdering
public final SecondaryIndexManager indexManager
public final Directories directories
public final ColumnFamilyMetrics metric
public volatile long sampleLatencyNanos
public static final com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> CANONICAL_SSTABLES
public static final com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> UNREPAIRED_SSTABLES
public static void shutdownPostFlushExecutor()
throws java.lang.InterruptedException
java.lang.InterruptedExceptionpublic void reload()
public static java.lang.Runnable getBackgroundCompactionTaskSubmitter()
public void setCompactionParametersJson(java.lang.String options)
ColumnFamilyStoreMBeansetCompactionParametersJson in interface ColumnFamilyStoreMBeanoptions - compaction options with the same syntax as when doing ALTER ... WITH compaction = {..}public java.lang.String getCompactionParametersJson()
getCompactionParametersJson in interface ColumnFamilyStoreMBeanpublic void setCompactionParameters(java.util.Map<java.lang.String,java.lang.String> options)
ColumnFamilyStoreMBeansetCompactionParameters in interface ColumnFamilyStoreMBeanoptions - compaction options mappublic java.util.Map<java.lang.String,java.lang.String> getCompactionParameters()
getCompactionParameters in interface ColumnFamilyStoreMBeanpublic void setCompactionStrategyClass(java.lang.String compactionStrategyClass)
ColumnFamilyStoreMBeansetCompactionStrategyClass in interface ColumnFamilyStoreMBeancompactionStrategyClass - the name of the compaction strategy classpublic java.lang.String getCompactionStrategyClass()
ColumnFamilyStoreMBeangetCompactionStrategyClass in interface ColumnFamilyStoreMBeanpublic java.util.Map<java.lang.String,java.lang.String> getCompressionParameters()
ColumnFamilyStoreMBeangetCompressionParameters in interface ColumnFamilyStoreMBeanpublic void setCompressionParameters(java.util.Map<java.lang.String,java.lang.String> opts)
ColumnFamilyStoreMBeansetCompressionParameters in interface ColumnFamilyStoreMBeanopts - map of string names to valuespublic void setCrcCheckChance(double crcCheckChance)
ColumnFamilyStoreMBeansetCrcCheckChance in interface ColumnFamilyStoreMBeanpublic void invalidate()
public long getMinRowSize()
getMinRowSize in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.minRowSizepublic long getMaxRowSize()
getMaxRowSize in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.maxRowSizepublic long getMeanRowSize()
getMeanRowSize in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.meanRowSizepublic int getMeanColumns()
public static ColumnFamilyStore createColumnFamilyStore(Keyspace keyspace, java.lang.String columnFamily, boolean loadSSTables)
public static ColumnFamilyStore createColumnFamilyStore(Keyspace keyspace, java.lang.String columnFamily, IPartitioner partitioner, CFMetaData metadata)
public static void scrubDataDirectories(CFMetaData metadata)
public static void removeUnfinishedCompactionLeftovers(CFMetaData metadata, java.util.Map<java.lang.Integer,java.util.UUID> unfinishedCompactions)
public static void loadNewSSTables(java.lang.String ksName,
java.lang.String cfName)
StorageService.loadNewSSTables(String, String) for more infoksName - The keyspace namecfName - The columnFamily namepublic void loadNewSSTables()
loadNewSSTables in interface ColumnFamilyStoreMBeanpublic void rebuildSecondaryIndex(java.lang.String idxName)
public static void rebuildSecondaryIndex(java.lang.String ksName,
java.lang.String cfName,
java.lang.String... idxNames)
public java.lang.String getColumnFamilyName()
getColumnFamilyName in interface ColumnFamilyStoreMBeanpublic java.lang.String getTempSSTablePath(java.io.File directory)
public java.util.concurrent.Future<?> switchMemtableIfCurrent(Memtable memtable)
memtable - public com.google.common.util.concurrent.ListenableFuture<?> switchMemtable()
public com.google.common.util.concurrent.ListenableFuture<?> forceFlush()
public com.google.common.util.concurrent.ListenableFuture<?> forceFlush(ReplayPosition flushIfDirtyBefore)
public void forceBlockingFlush()
public void maybeUpdateRowCache(DecoratedKey key)
public void apply(DecoratedKey key, ColumnFamily columnFamily, SecondaryIndexManager.Updater indexer, OpOrder.Group opGroup, ReplayPosition replayPosition)
public static ColumnFamily removeDeletedCF(ColumnFamily cf, int gcBefore)
gcBefore - a timestamp (in seconds); tombstones with a localDeletionTime before this will be purgedpublic static ColumnFamily removeDeleted(ColumnFamily cf, int gcBefore)
public static ColumnFamily removeDeleted(ColumnFamily cf, int gcBefore, SecondaryIndexManager.Updater indexer)
public static ColumnFamily removeDeletedColumnsOnly(ColumnFamily cf, int gcBefore, SecondaryIndexManager.Updater indexer)
public java.util.Collection<SSTableReader> getOverlappingSSTables(java.lang.Iterable<SSTableReader> sstables)
sstables - public Refs<SSTableReader> getAndReferenceOverlappingSSTables(java.lang.Iterable<SSTableReader> sstables)
public void addSSTable(SSTableReader sstable)
public void addSSTables(java.util.Collection<SSTableReader> sstables)
public long getExpectedCompactedFileSize(java.lang.Iterable<SSTableReader> sstables, OperationType operation)
CLEANUP and we're not dealing with an index sstable,
then we calculate expected file size with checking token range to be eliminated.
Otherwise, we just add up all the files' size, which is the worst case file
size for compaction of all the list of files given.sstables - SSTables to calculate expected compacted file sizeoperation - Operation typepublic SSTableReader getMaxSizeFile(java.lang.Iterable<SSTableReader> sstables)
public CompactionManager.AllSSTableOpStatus forceCleanup() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionExceptionjava.lang.InterruptedExceptionpublic CompactionManager.AllSSTableOpStatus scrub(boolean disableSnapshot, boolean skipCorrupted, boolean checkData) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionExceptionjava.lang.InterruptedExceptionpublic CompactionManager.AllSSTableOpStatus sstablesRewrite(boolean excludeCurrentVersion) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionExceptionjava.lang.InterruptedExceptionpublic void markObsolete(java.util.Collection<SSTableReader> sstables, OperationType compactionType)
public boolean isValid()
public long getMemtableColumnsCount()
ColumnFamilyStoreMBeangetMemtableColumnsCount in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.memtableColumnsCountpublic long getMemtableDataSize()
ColumnFamilyStoreMBeangetMemtableDataSize in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.memtableOnHeapSizepublic int getMemtableSwitchCount()
ColumnFamilyStoreMBeangetMemtableSwitchCount in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.memtableSwitchCountpublic DataTracker getDataTracker()
public java.util.Collection<SSTableReader> getSSTables()
public java.util.Set<SSTableReader> getUncompactingSSTables()
public long[] getRecentSSTablesPerReadHistogram()
getRecentSSTablesPerReadHistogram in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.recentSSTablesPerReadpublic long[] getSSTablesPerReadHistogram()
getSSTablesPerReadHistogram in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.sstablesPerReadHistogrampublic long getReadCount()
getReadCount in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.readLatencypublic double getRecentReadLatencyMicros()
getRecentReadLatencyMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.readLatencypublic long[] getLifetimeReadLatencyHistogramMicros()
getLifetimeReadLatencyHistogramMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.readLatencypublic long[] getRecentReadLatencyHistogramMicros()
getRecentReadLatencyHistogramMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.readLatencypublic long getTotalReadLatencyMicros()
getTotalReadLatencyMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.readLatencypublic int getPendingTasks()
getPendingTasks in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.pendingFlushespublic long getWriteCount()
getWriteCount in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.writeLatencypublic long getTotalWriteLatencyMicros()
getTotalWriteLatencyMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.writeLatencypublic double getRecentWriteLatencyMicros()
getRecentWriteLatencyMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.writeLatencypublic long[] getLifetimeWriteLatencyHistogramMicros()
getLifetimeWriteLatencyHistogramMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.writeLatencypublic long[] getRecentWriteLatencyHistogramMicros()
getRecentWriteLatencyHistogramMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.writeLatencypublic long getRangeCount()
getRangeCount in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.rangeLatencypublic double getRecentRangeLatencyMicros()
getRecentRangeLatencyMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.rangeLatencypublic long[] getLifetimeRangeLatencyHistogramMicros()
getLifetimeRangeLatencyHistogramMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.rangeLatencypublic long[] getRecentRangeLatencyHistogramMicros()
getRecentRangeLatencyHistogramMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.rangeLatencypublic long getTotalRangeLatencyMicros()
getTotalRangeLatencyMicros in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.rangeLatencypublic ColumnFamily getColumnFamily(DecoratedKey key, Composite start, Composite finish, boolean reversed, int limit, long timestamp)
public SliceQueryFilter readFilterForCache()
public boolean isFilterFullyCoveredBy(IDiskAtomFilter filter, ColumnFamily cachedCf, long now)
public int gcBefore(long now)
public ColumnFamily getColumnFamily(QueryFilter filter)
public java.util.Set<SSTableReader> getUnrepairedSSTables()
public java.util.Set<SSTableReader> getRepairedSSTables()
public ColumnFamilyStore.RefViewFragment selectAndReference(com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> filter)
public ColumnFamilyStore.ViewFragment select(com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> filter)
public com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> viewFilter(DecoratedKey key)
public com.google.common.base.Function<DataTracker.View,java.util.List<SSTableReader>> viewFilter(AbstractBounds<RowPosition> rowBounds)
public java.util.List<java.lang.String> getSSTablesForKey(java.lang.String key)
ColumnFamilyStoreMBeangetSSTablesForKey in interface ColumnFamilyStoreMBeanpublic ColumnFamily getTopLevelColumns(QueryFilter filter, int gcBefore)
public void beginLocalSampling(java.lang.String sampler,
int capacity)
ColumnFamilyStoreMBeanbeginLocalSampling in interface ColumnFamilyStoreMBeanpublic javax.management.openmbean.CompositeData finishLocalSampling(java.lang.String sampler,
int count)
throws javax.management.openmbean.OpenDataException
finishLocalSampling in interface ColumnFamilyStoreMBeanjavax.management.openmbean.OpenDataExceptionpublic void cleanupCache()
public java.util.List<Row> getRangeSlice(AbstractBounds<RowPosition> range, java.util.List<IndexExpression> rowFilter, IDiskAtomFilter columnFilter, int maxResults)
public java.util.List<Row> getRangeSlice(AbstractBounds<RowPosition> range, java.util.List<IndexExpression> rowFilter, IDiskAtomFilter columnFilter, int maxResults, long now)
public ExtendedFilter makeExtendedFilter(AbstractBounds<RowPosition> keyRange, SliceQueryFilter columnRange, Composite columnStart, Composite columnStop, java.util.List<IndexExpression> rowFilter, int maxResults, boolean countCQL3Rows, long now)
public java.util.List<Row> getRangeSlice(AbstractBounds<RowPosition> range, java.util.List<IndexExpression> rowFilter, IDiskAtomFilter columnFilter, int maxResults, long now, boolean countCQL3Rows, boolean isPaging)
public ExtendedFilter makeExtendedFilter(AbstractBounds<RowPosition> range, IDiskAtomFilter columnFilter, java.util.List<IndexExpression> rowFilter, int maxResults, boolean countCQL3Rows, boolean isPaging, long timestamp)
public java.util.List<Row> getRangeSlice(ExtendedFilter filter)
public java.util.List<Row> search(AbstractBounds<RowPosition> range, java.util.List<IndexExpression> clause, IDiskAtomFilter dataFilter, int maxResults)
public java.util.List<Row> search(AbstractBounds<RowPosition> range, java.util.List<IndexExpression> clause, IDiskAtomFilter dataFilter, int maxResults, long now)
public java.util.List<Row> search(ExtendedFilter filter)
public java.util.List<Row> filter(ColumnFamilyStore.AbstractScanIterator rowIterator, ExtendedFilter filter)
public CellNameType getComparator()
public void snapshotWithoutFlush(java.lang.String snapshotName)
public void snapshotWithoutFlush(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral)
ephemeral - If this flag is set to true, the snapshot will be cleaned during next startupprotected static void clearEphemeralSnapshots(Directories directories)
public Refs<SSTableReader> getSnapshotSSTableReader(java.lang.String tag) throws java.io.IOException
java.io.IOExceptionpublic void snapshot(java.lang.String snapshotName)
snapshotName - the name of the associated with the snapshotpublic void snapshot(java.lang.String snapshotName,
com.google.common.base.Predicate<SSTableReader> predicate,
boolean ephemeral)
ephemeral - If this flag is set to true, the snapshot will be cleaned up during next startuppublic boolean snapshotExists(java.lang.String snapshotName)
public long getSnapshotCreationTime(java.lang.String snapshotName)
public void clearSnapshot(java.lang.String snapshotName)
snapshotName - the user supplied snapshot name. If left empty,
all the snapshots will be cleaned.public java.util.Map<java.lang.String,Pair<java.lang.Long,java.lang.Long>> getSnapshotDetails()
public long getTotalDiskSpaceUsed()
getTotalDiskSpaceUsed in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.totalDiskSpaceUsedpublic long getLiveDiskSpaceUsed()
getLiveDiskSpaceUsed in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.liveDiskSpaceUsedpublic int getLiveSSTableCount()
getLiveSSTableCount in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.liveSSTableCountpublic ColumnFamily getRawCachedRow(DecoratedKey key)
public int invalidateRowCache(java.util.Collection<Bounds<Token>> boundsToInvalidate)
public int invalidateCounterCache(java.util.Collection<Bounds<Token>> boundsToInvalidate)
public boolean containsCachedRow(DecoratedKey key)
public void invalidateCachedRow(RowCacheKey key)
public void invalidateCachedRow(DecoratedKey key)
public ClockAndCount getCachedCounter(java.nio.ByteBuffer partitionKey, CellName cellName)
public void putCachedCounter(java.nio.ByteBuffer partitionKey,
CellName cellName,
ClockAndCount clockAndCount)
public void forceMajorCompaction()
throws java.lang.InterruptedException,
java.util.concurrent.ExecutionException
ColumnFamilyStoreMBeanforceMajorCompaction in interface ColumnFamilyStoreMBeanjava.lang.InterruptedExceptionjava.util.concurrent.ExecutionExceptionpublic static java.lang.Iterable<ColumnFamilyStore> all()
public java.lang.Iterable<DecoratedKey> keySamples(Range<Token> range)
public void clearUnsafe()
public void truncateBlocking()
public <V> V runWithCompactionsDisabled(java.util.concurrent.Callable<V> callable,
boolean interruptValidation)
public java.lang.Iterable<SSTableReader> markAllCompacting()
public long getBloomFilterFalsePositives()
getBloomFilterFalsePositives in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.bloomFilterFalsePositivespublic long getRecentBloomFilterFalsePositives()
getRecentBloomFilterFalsePositives in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.recentBloomFilterFalsePositivespublic double getBloomFilterFalseRatio()
getBloomFilterFalseRatio in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.bloomFilterFalseRatiopublic double getRecentBloomFilterFalseRatio()
getRecentBloomFilterFalseRatio in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.recentBloomFilterFalseRatiopublic long getBloomFilterDiskSpaceUsed()
getBloomFilterDiskSpaceUsed in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.bloomFilterDiskSpaceUsedpublic long getBloomFilterOffHeapMemoryUsed()
getBloomFilterOffHeapMemoryUsed in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.bloomFilterOffHeapMemoryUsedpublic long getIndexSummaryOffHeapMemoryUsed()
getIndexSummaryOffHeapMemoryUsed in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.indexSummaryOffHeapMemoryUsedpublic long getCompressionMetadataOffHeapMemoryUsed()
getCompressionMetadataOffHeapMemoryUsed in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.compressionMetadataOffHeapMemoryUsedpublic java.lang.String toString()
toString in class java.lang.Objectpublic void disableAutoCompaction()
public void enableAutoCompaction()
public void enableAutoCompaction(boolean waitForFutures)
waitForFutures - if we should block until autocompaction is donepublic boolean isAutoCompactionDisabled()
isAutoCompactionDisabled in interface ColumnFamilyStoreMBeanpublic AbstractCompactionStrategy getCompactionStrategy()
public void setCompactionThresholds(int minThreshold,
int maxThreshold)
ColumnFamilyStoreMBeansetCompactionThresholds in interface ColumnFamilyStoreMBeanpublic int getMinimumCompactionThreshold()
ColumnFamilyStoreMBeangetMinimumCompactionThreshold in interface ColumnFamilyStoreMBeanpublic void setMinimumCompactionThreshold(int minCompactionThreshold)
ColumnFamilyStoreMBeansetMinimumCompactionThreshold in interface ColumnFamilyStoreMBeanpublic int getMaximumCompactionThreshold()
ColumnFamilyStoreMBeangetMaximumCompactionThreshold in interface ColumnFamilyStoreMBeanpublic void setMaximumCompactionThreshold(int maxCompactionThreshold)
ColumnFamilyStoreMBeansetMaximumCompactionThreshold in interface ColumnFamilyStoreMBeanpublic double getTombstonesPerSlice()
ColumnFamilyStoreMBeangetTombstonesPerSlice in interface ColumnFamilyStoreMBeanpublic double getLiveCellsPerSlice()
ColumnFamilyStoreMBeangetLiveCellsPerSlice in interface ColumnFamilyStoreMBeanpublic long estimateKeys()
estimateKeys in interface ColumnFamilyStoreMBeanpublic long[] getEstimatedRowSizeHistogram()
getEstimatedRowSizeHistogram in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.estimatedRowSizeHistogrampublic long[] getEstimatedColumnCountHistogram()
getEstimatedColumnCountHistogram in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.estimatedColumnCountHistogrampublic double getCompressionRatio()
getCompressionRatio in interface ColumnFamilyStoreMBeanColumnFamilyMetrics.compressionRatiopublic boolean isIndex()
public java.lang.Iterable<ColumnFamilyStore> concatWithIndexes()
public java.util.List<java.lang.String> getBuiltIndexes()
ColumnFamilyStoreMBeangetBuiltIndexes in interface ColumnFamilyStoreMBeanpublic int getUnleveledSSTables()
getUnleveledSSTables in interface ColumnFamilyStoreMBeanpublic int[] getSSTableCountPerLevel()
getSSTableCountPerLevel in interface ColumnFamilyStoreMBeanpublic long oldestUnflushedMemtable()
public boolean isEmpty()
public boolean isRowCacheEnabled()
public boolean isCounterCacheEnabled()
public boolean isKeyCacheEnabled()
public ReplayPosition discardSSTables(long truncatedAt)
truncatedAt - The timestamp of the truncation
(all SSTables before that timestamp are going be marked as compacted)public double getDroppableTombstoneRatio()
ColumnFamilyStoreMBeangetDroppableTombstoneRatio in interface ColumnFamilyStoreMBeanpublic long trueSnapshotsSize()
trueSnapshotsSize in interface ColumnFamilyStoreMBeanCopyright © 2015 The Apache Software Foundation