Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.lifecycle | |
org.apache.cassandra.index.sasi.conf | |
org.apache.cassandra.notifications |
Modifier and Type | Field and Description |
---|---|
java.lang.Iterable<Memtable> |
ColumnFamilyStore.ViewFragment.memtables |
Modifier and Type | Method and Description |
---|---|
int |
Memtable.compareTo(Memtable that) |
com.google.common.util.concurrent.ListenableFuture<CommitLogPosition> |
ColumnFamilyStore.switchMemtableIfCurrent(Memtable memtable)
Switches the memtable iff the live memtable is the one provided
|
Constructor and Description |
---|
RefViewFragment(java.util.List<SSTableReader> sstables,
java.lang.Iterable<Memtable> memtables,
Refs<SSTableReader> refs) |
ViewFragment(java.util.List<SSTableReader> sstables,
java.lang.Iterable<Memtable> memtables) |
Modifier and Type | Field and Description |
---|---|
java.util.List<Memtable> |
View.flushingMemtables
contains all memtables that are no longer referenced for writing and are queued for / in the process of being
flushed.
|
java.util.List<Memtable> |
View.liveMemtables
ordinarily a list of size 1, but when preparing to flush will contain both the memtable we will flush
and the new replacement memtable, until all outstanding write operations on the old table complete.
|
Modifier and Type | Method and Description |
---|---|
Memtable |
View.getCurrentMemtable() |
Memtable |
Tracker.getMemtableFor(OpOrder.Group opGroup,
CommitLogPosition commitLogPosition)
get the Memtable that the ordered writeOp should be directed to
|
Memtable |
Tracker.switchMemtable(boolean truncating,
Memtable newMemtable)
Switch the current memtable.
|
Modifier and Type | Method and Description |
---|---|
java.lang.Iterable<Memtable> |
View.getAllMemtables() |
Modifier and Type | Method and Description |
---|---|
void |
Tracker.markFlushing(Memtable memtable) |
void |
Tracker.notifyDiscarded(Memtable discarded) |
void |
Tracker.notifyRenewed(Memtable renewed) |
void |
Tracker.notifySwitched(Memtable previous) |
void |
Tracker.replaceFlushed(Memtable memtable,
java.lang.Iterable<SSTableReader> sstables) |
void |
Tracker.reset(Memtable memtable)
(Re)initializes the tracker, purging all references.
|
Memtable |
Tracker.switchMemtable(boolean truncating,
Memtable newMemtable)
Switch the current memtable.
|
Constructor and Description |
---|
Tracker(Memtable memtable,
boolean loadsstables) |
Modifier and Type | Method and Description |
---|---|
void |
ColumnIndex.discardMemtable(Memtable parent) |
void |
ColumnIndex.switchMemtable(Memtable parent) |
Modifier and Type | Field and Description |
---|---|
Memtable |
MemtableDiscardedNotification.memtable |
Memtable |
MemtableSwitchedNotification.memtable |
Memtable |
MemtableRenewedNotification.renewed |
Modifier and Type | Method and Description |
---|---|
java.util.Optional<Memtable> |
SSTableAddedNotification.memtable()
Returns the memtable from which the tables come when they have been added due to a memtable flush.
|
Constructor and Description |
---|
MemtableDiscardedNotification(Memtable discarded) |
MemtableRenewedNotification(Memtable renewed) |
MemtableSwitchedNotification(Memtable switched) |
SSTableAddedNotification(java.lang.Iterable<SSTableReader> added,
Memtable memtable)
Creates a new
SSTableAddedNotification for the specified SSTables and optional memtable. |
Copyright © 2009-2022 The Apache Software Foundation