Package | Description |
---|---|
org.apache.cassandra.db | |
org.apache.cassandra.db.compaction | |
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 | Method and Description |
---|---|
void |
AbstractCompactionStrategy.replaceFlushed(Memtable memtable,
java.util.Collection<SSTableReader> sstables)
Handle a flushed memtable.
|
void |
CompactionStrategyManager.replaceFlushed(Memtable memtable,
java.util.Collection<SSTableReader> sstables) |
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 |
Constructor and Description |
---|
MemtableDiscardedNotification(Memtable discarded) |
MemtableRenewedNotification(Memtable renewed) |
MemtableSwitchedNotification(Memtable switched) |
Copyright © 2020 The Apache Software Foundation