|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.db.ColumnFamilyStore
public class ColumnFamilyStore
Field Summary | |
---|---|
java.lang.String |
columnFamily_
|
Method Summary | |
---|---|
void |
addSSTable(SSTableReader sstable)
|
void |
addToCompactedRowStats(java.lang.Long rowsize)
|
static java.lang.Iterable<ColumnFamilyStore> |
all()
|
java.lang.Iterable<IndexSummary.KeyPosition> |
allIndexPositions()
|
static ColumnFamilyStore |
createColumnFamilyStore(java.lang.String table,
java.lang.String columnFamily)
|
long |
estimateKeys()
|
void |
forceBlockingFlush()
|
java.util.concurrent.Future<?> |
forceFlush()
Triggers an immediate memtable flush. |
void |
forceFlushBinary()
|
void |
forceFlushIfExpired()
|
void |
forceMajorCompaction()
force a major compaction of this column family |
long |
getBloomFilterFalsePositives()
|
double |
getBloomFilterFalseRatio()
|
ColumnFamily |
getColumnFamily(QueryFilter filter)
|
ColumnFamily |
getColumnFamily(QueryFilter filter,
int gcBefore)
get a list of columns starting from a given column, in a specified order. |
ColumnFamily |
getColumnFamily(java.lang.String key,
QueryPath path,
byte[] start,
byte[] finish,
boolean reversed,
int limit)
|
java.lang.String |
getColumnFamilyName()
|
AbstractType |
getComparator()
|
java.lang.String |
getFlushPath()
|
static int |
getGenerationFromFileName(java.lang.String filename)
|
int |
getKeyCacheCapacity()
|
int |
getKeyCacheSize()
|
long[] |
getLifetimeReadLatencyHistogramMicros()
|
long[] |
getLifetimeWriteLatencyHistogramMicros()
|
long |
getLiveDiskSpaceUsed()
|
int |
getLiveSSTableCount()
|
long |
getMaxRowCompactedSize()
return the size of the largest compacted row |
long |
getMeanRowCompactedSize()
return the mean size of the rows compacted |
int |
getMemtableColumnsCount()
Returns the total number of columns present in the memtable. |
int |
getMemtableDataSize()
Returns the total amount of data stored in the memtable, including column related overhead. |
java.util.Set<Memtable> |
getMemtablesPendingFlush()
|
int |
getMemtableSwitchCount()
Returns the number of times that a flush has resulted in the memtable being switched out. |
long |
getMinRowCompactedSize()
return the size of the smallest compacted row |
int |
getPendingTasks()
|
RangeSliceReply |
getRangeSlice(byte[] super_column,
AbstractBounds range,
int keyMax,
SliceRange sliceRange,
java.util.List<byte[]> columnNames)
|
ColumnFamily |
getRawCachedRow(java.lang.String key)
raw cached row -- does not fetch the row if it is not present. |
long |
getReadCount()
|
long |
getRecentBloomFilterFalsePositives()
|
double |
getRecentBloomFilterFalseRatio()
|
long[] |
getRecentReadLatencyHistogramMicros()
|
double |
getRecentReadLatencyMicros()
|
long[] |
getRecentWriteLatencyHistogramMicros()
|
double |
getRecentWriteLatencyMicros()
|
int |
getRowCacheCapacity()
|
int |
getRowCacheSize()
|
java.util.Collection<SSTableReader> |
getSSTables()
|
Table |
getTable()
|
java.lang.String |
getTempSSTableFileName()
|
long |
getTotalDiskSpaceUsed()
|
long |
getTotalReadLatencyMicros()
|
long |
getTotalWriteLatencyMicros()
|
long |
getWriteCount()
|
boolean |
hasUnreclaimedSpace()
|
void |
initRowCache()
|
void |
invalidateRowCache()
invalidate the row cache; for use after bulk loading via BinaryMemtable |
boolean |
isKeyInRemainingSSTables(DecoratedKey key,
java.util.Set<SSTable> sstablesToIgnore)
Uses bloom filters to check if key may be present in any sstable in this ColumnFamilyStore, minus a set of provided ones. |
boolean |
isSuper()
|
java.util.Iterator<DecoratedKey> |
memtableKeyIterator(DecoratedKey startWith)
|
protected java.util.Set<java.lang.String> |
readSavedCache(java.io.File path,
boolean sort)
|
static ColumnFamily |
removeDeleted(ColumnFamily cf,
int gcBefore)
|
void |
snapshot(java.lang.String snapshotName)
Take a snap shot of this columnfamily store. |
java.util.concurrent.Future<?> |
submitKeyCacheWrite()
|
java.util.concurrent.Future<?> |
submitRowCacheWrite()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public final java.lang.String columnFamily_
Method Detail |
---|
protected java.util.Set<java.lang.String> readSavedCache(java.io.File path, boolean sort) throws java.io.IOException
java.io.IOException
public void initRowCache()
public java.util.concurrent.Future<?> submitKeyCacheWrite()
public java.util.concurrent.Future<?> submitRowCacheWrite()
public void addToCompactedRowStats(java.lang.Long rowsize)
public long getMinRowCompactedSize()
ColumnFamilyStoreMBean
getMinRowCompactedSize
in interface ColumnFamilyStoreMBean
public long getMaxRowCompactedSize()
ColumnFamilyStoreMBean
getMaxRowCompactedSize
in interface ColumnFamilyStoreMBean
public long getMeanRowCompactedSize()
ColumnFamilyStoreMBean
getMeanRowCompactedSize
in interface ColumnFamilyStoreMBean
public static ColumnFamilyStore createColumnFamilyStore(java.lang.String table, java.lang.String columnFamily) throws java.io.IOException
java.io.IOException
public java.lang.String getColumnFamilyName()
getColumnFamilyName
in interface ColumnFamilyStoreMBean
public static int getGenerationFromFileName(java.lang.String filename)
public java.lang.String getFlushPath()
public java.lang.String getTempSSTableFileName()
public void forceFlushIfExpired() throws java.io.IOException
java.io.IOException
public java.util.concurrent.Future<?> forceFlush() throws java.io.IOException
ColumnFamilyStoreMBean
forceFlush
in interface ColumnFamilyStoreMBean
java.io.IOException
public void forceBlockingFlush() throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.io.IOException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public void forceFlushBinary()
public static ColumnFamily removeDeleted(ColumnFamily cf, int gcBefore)
public boolean isKeyInRemainingSSTables(DecoratedKey key, java.util.Set<SSTable> sstablesToIgnore)
public void addSSTable(SSTableReader sstable)
public Table getTable()
public boolean isSuper()
public int getMemtableColumnsCount()
ColumnFamilyStoreMBean
getMemtableColumnsCount
in interface ColumnFamilyStoreMBean
public int getMemtableDataSize()
ColumnFamilyStoreMBean
getMemtableDataSize
in interface ColumnFamilyStoreMBean
public int getMemtableSwitchCount()
ColumnFamilyStoreMBean
getMemtableSwitchCount
in interface ColumnFamilyStoreMBean
public java.util.Iterator<DecoratedKey> memtableKeyIterator(DecoratedKey startWith) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public java.util.Collection<SSTableReader> getSSTables()
public long getReadCount()
getReadCount
in interface ColumnFamilyStoreMBean
public double getRecentReadLatencyMicros()
getRecentReadLatencyMicros
in interface ColumnFamilyStoreMBean
public long[] getLifetimeReadLatencyHistogramMicros()
getLifetimeReadLatencyHistogramMicros
in interface ColumnFamilyStoreMBean
public long[] getRecentReadLatencyHistogramMicros()
getRecentReadLatencyHistogramMicros
in interface ColumnFamilyStoreMBean
public long getTotalReadLatencyMicros()
getTotalReadLatencyMicros
in interface ColumnFamilyStoreMBean
public int getPendingTasks()
getPendingTasks
in interface ColumnFamilyStoreMBean
public long getWriteCount()
getWriteCount
in interface ColumnFamilyStoreMBean
public long getTotalWriteLatencyMicros()
getTotalWriteLatencyMicros
in interface ColumnFamilyStoreMBean
public double getRecentWriteLatencyMicros()
getRecentWriteLatencyMicros
in interface ColumnFamilyStoreMBean
public long[] getLifetimeWriteLatencyHistogramMicros()
getLifetimeWriteLatencyHistogramMicros
in interface ColumnFamilyStoreMBean
public long[] getRecentWriteLatencyHistogramMicros()
getRecentWriteLatencyHistogramMicros
in interface ColumnFamilyStoreMBean
public ColumnFamily getColumnFamily(java.lang.String key, QueryPath path, byte[] start, byte[] finish, boolean reversed, int limit) throws java.io.IOException
java.io.IOException
public ColumnFamily getColumnFamily(QueryFilter filter) throws java.io.IOException
java.io.IOException
public ColumnFamily getColumnFamily(QueryFilter filter, int gcBefore) throws java.io.IOException
java.io.IOException
public RangeSliceReply getRangeSlice(byte[] super_column, AbstractBounds range, int keyMax, SliceRange sliceRange, java.util.List<byte[]> columnNames) throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
super_column
- range:
- either a Bounds, which includes start key, or a Range, which does not.keyMax
- maximum number of keys to process, regardless of startKey/finishKeysliceRange
- may be null if columnNames is specified. specifies contiguous columns to return in what order.columnNames
- may be null if sliceRange is specified. specifies which columns to return in what order. @return list of key->listjava.io.IOException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public AbstractType getComparator()
public void snapshot(java.lang.String snapshotName) throws java.io.IOException
snapshotName
- the name of the associated with the snapshot
java.io.IOException
public boolean hasUnreclaimedSpace()
public long getTotalDiskSpaceUsed()
getTotalDiskSpaceUsed
in interface ColumnFamilyStoreMBean
public long getLiveDiskSpaceUsed()
getLiveDiskSpaceUsed
in interface ColumnFamilyStoreMBean
public int getLiveSSTableCount()
getLiveSSTableCount
in interface ColumnFamilyStoreMBean
public ColumnFamily getRawCachedRow(java.lang.String key)
public void forceMajorCompaction()
ColumnFamilyStoreMBean
forceMajorCompaction
in interface ColumnFamilyStoreMBean
public void invalidateRowCache()
ColumnFamilyStoreMBean
invalidateRowCache
in interface ColumnFamilyStoreMBean
public int getRowCacheCapacity()
public int getKeyCacheCapacity()
public int getRowCacheSize()
public int getKeyCacheSize()
public static java.lang.Iterable<ColumnFamilyStore> all()
public java.lang.Iterable<IndexSummary.KeyPosition> allIndexPositions()
public java.util.Set<Memtable> getMemtablesPendingFlush()
public long getBloomFilterFalsePositives()
getBloomFilterFalsePositives
in interface ColumnFamilyStoreMBean
public long getRecentBloomFilterFalsePositives()
getRecentBloomFilterFalsePositives
in interface ColumnFamilyStoreMBean
public double getBloomFilterFalseRatio()
getBloomFilterFalseRatio
in interface ColumnFamilyStoreMBean
public double getRecentBloomFilterFalseRatio()
getRecentBloomFilterFalseRatio
in interface ColumnFamilyStoreMBean
public long estimateKeys()
estimateKeys
in interface ColumnFamilyStoreMBean
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |