|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.cassandra.db.ColumnFamilyStore
public final class ColumnFamilyStore
Field Summary | |
---|---|
java.lang.String |
columnFamily_
|
Method Summary | |
---|---|
java.lang.String |
cfStats(java.lang.String newLineSeparator)
|
void |
flushMemtableOnRecovery()
|
void |
forceFlush()
Triggers an immediate memtable flush. |
void |
forceFlushBinary()
|
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()
|
static ColumnFamilyStore |
getColumnFamilyStore(java.lang.String table,
java.lang.String columnFamily)
|
AbstractType |
getComparator()
|
static int |
getDefaultGCBefore()
|
protected static int |
getIndexFromFileName(java.lang.String filename)
|
RangeReply |
getKeyRange(java.lang.String startWith,
java.lang.String stopAt,
int maxResults)
|
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. |
int |
getMemtableSwitchCount()
Returns the number of times that a flush has resulted in the memtable being switched out. |
int |
getPendingTasks()
|
int |
getReadCount()
|
double |
getReadLatency()
|
java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock |
getReadLock()
|
java.util.Collection<SSTableReader> |
getSSTables()
not threadsafe. |
static java.util.List<Memtable> |
getUnflushedMemtables(java.lang.String cfName)
|
int |
getWriteCount()
|
double |
getWriteLatency()
|
boolean |
isSuper()
|
java.util.Iterator<java.lang.String> |
memtableKeyIterator()
|
void |
snapshot(java.lang.String snapshotName)
Take a snap shot of this columnfamily store. |
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 |
---|
public static ColumnFamilyStore getColumnFamilyStore(java.lang.String table, java.lang.String columnFamily) throws java.io.IOException
java.io.IOException
public java.lang.String cfStats(java.lang.String newLineSeparator)
public java.lang.String getColumnFamilyName()
getColumnFamilyName
in interface ColumnFamilyStoreMBean
protected static int getIndexFromFileName(java.lang.String filename)
public void forceFlush()
ColumnFamilyStoreMBean
forceFlush
in interface ColumnFamilyStoreMBean
public void forceFlushBinary()
public static int getDefaultGCBefore()
public static java.util.List<Memtable> getUnflushedMemtables(java.lang.String cfName)
public boolean isSuper()
public void flushMemtableOnRecovery() throws java.io.IOException
java.io.IOException
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<java.lang.String> memtableKeyIterator() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public java.util.Collection<SSTableReader> getSSTables()
public java.util.concurrent.locks.ReentrantReadWriteLock.ReadLock getReadLock()
public int getReadCount()
getReadCount
in interface ColumnFamilyStoreMBean
public double getReadLatency()
getReadLatency
in interface ColumnFamilyStoreMBean
public int getPendingTasks()
getPendingTasks
in interface ColumnFamilyStoreMBean
public int getWriteCount()
getWriteCount
in interface ColumnFamilyStoreMBean
public double getWriteLatency()
getWriteLatency
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 RangeReply getKeyRange(java.lang.String startWith, java.lang.String stopAt, int maxResults) throws java.io.IOException, java.util.concurrent.ExecutionException, java.lang.InterruptedException
startWith
- key to start with, inclusive. empty string = start at beginning.stopAt
- key to stop at, inclusive. empty string = stop only when keys are exhausted.maxResults
-
java.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
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |