Uses of Interface
org.apache.cassandra.db.memtable.Memtable
Packages that use Memtable
Package
Description
-
Uses of Memtable in org.apache.cassandra.db
Fields in org.apache.cassandra.db with type parameters of type MemtableMethods in org.apache.cassandra.db that return MemtableModifier and TypeMethodDescriptionColumnFamilyStore.createMemtable(AtomicReference<CommitLogPosition> commitLogUpperBound) ColumnFamilyStore.getCurrentMemtable()Methods in org.apache.cassandra.db that return types with arguments of type MemtableModifier and TypeMethodDescriptionColumnFamilyStore.activeMemtables()ColumnFamilyStore.getIndexMemtables()Methods in org.apache.cassandra.db with parameters of type MemtableModifier and TypeMethodDescriptionColumnFamilyStore.signalFlushRequired(Memtable memtable, ColumnFamilyStore.FlushReason reason) ColumnFamilyStore.switchMemtableIfCurrent(Memtable memtable, ColumnFamilyStore.FlushReason reason) Switches the memtable iff the live memtable is the one providedConstructor parameters in org.apache.cassandra.db with type arguments of type MemtableModifierConstructorDescriptionRefViewFragment(List<SSTableReader> sstables, Iterable<Memtable> memtables, Refs<SSTableReader> refs) ViewFragment(List<SSTableReader> sstables, Iterable<Memtable> memtables) -
Uses of Memtable in org.apache.cassandra.db.lifecycle
Fields in org.apache.cassandra.db.lifecycle with type parameters of type MemtableModifier and TypeFieldDescriptionView.flushingMemtablescontains all memtables that are no longer referenced for writing and are queued for / in the process of being flushed.View.liveMemtablesordinarily 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.Methods in org.apache.cassandra.db.lifecycle that return MemtableModifier and TypeMethodDescriptionView.getCurrentMemtable()Tracker.getMemtableFor(OpOrder.Group opGroup, CommitLogPosition commitLogPosition) get the Memtable that the ordered writeOp should be directed toTracker.switchMemtable(boolean truncating, Memtable newMemtable) Switch the current memtable.Methods in org.apache.cassandra.db.lifecycle that return types with arguments of type MemtableMethods in org.apache.cassandra.db.lifecycle with parameters of type MemtableModifier and TypeMethodDescriptionvoidTracker.markFlushing(Memtable memtable) voidTracker.notifyDiscarded(Memtable discarded) voidTracker.notifyRenewed(Memtable renewed) voidTracker.notifySwitched(Memtable previous, Memtable next) voidTracker.replaceFlushed(Memtable memtable, Collection<SSTableReader> sstables) void(Re)initializes the tracker, purging all references.Tracker.switchMemtable(boolean truncating, Memtable newMemtable) Switch the current memtable.Constructors in org.apache.cassandra.db.lifecycle with parameters of type MemtableModifierConstructorDescriptionTracker(ColumnFamilyStore columnFamilyStore, Memtable memtable, boolean loadsstables) -
Uses of Memtable in org.apache.cassandra.db.memtable
Classes in org.apache.cassandra.db.memtable that implement MemtableModifier and TypeClassDescriptionclassA memtable that uses memory tracked and maybe allocated via a MemtableAllocator from a MemtablePool.classclassMemtable that uses a commit log for persistence.classclassA proof-of-concept sharded memtable implementation.classclassTrie memtable implementation.Methods in org.apache.cassandra.db.memtable that return MemtableModifier and TypeMethodDescriptionMemtable.Factory.create(AtomicReference<CommitLogPosition> commitLogLowerBound, TableMetadataRef metadaRef, Memtable.Owner owner) Create a memtable.SkipListMemtableFactory.create(AtomicReference<CommitLogPosition> commitLogLowerBound, TableMetadataRef metadaRef, Memtable.Owner owner) Memtable.Owner.getCurrentMemtable()Get the current memtable for this owner.Memtable.FlushablePartitionSet.memtable()Methods in org.apache.cassandra.db.memtable that return types with arguments of type MemtableModifier and TypeMethodDescriptionMemtable.Owner.getIndexMemtables()Collect the index memtables flushed together with this.Methods in org.apache.cassandra.db.memtable with parameters of type MemtableModifier and TypeMethodDescriptiondefault intOrder memtables by time as reflected in the commit log position at time of constructionstatic List<Flushing.FlushRunnable>Flushing.flushRunnables(ColumnFamilyStore cfs, Memtable memtable, LifecycleTransaction txn) static Memtable.MemoryUsageMemtable.getMemoryUsage(Memtable memtable) Shorthand for the getting a given table's memory usage.Memtable.Owner.signalFlushRequired(Memtable memtable, ColumnFamilyStore.FlushReason reason) Signal to the owner that a flush is required (e.g. -
Uses of Memtable in org.apache.cassandra.index
Methods in org.apache.cassandra.index with parameters of type MemtableModifier and TypeMethodDescriptionvoidSecondaryIndexManager.flushAllNonCFSBackedIndexesBlocking(Memtable baseCfsMemtable) Performs a blocking flush of all custom indexesdefault Callable<?>Index.getBlockingFlushTask(Memtable baseCfs) Return a task which performs a blocking flush of the index's data corresponding to the provided base table's Memtable.Index.Group.indexerFor(Predicate<Index> indexSelector, DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) Creates an newIndexerobject for updates to a given partition.Index.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) Creates an newIndexerobject for updates to a given partition.SingletonIndexGroup.indexerFor(Predicate<Index> indexSelector, DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) SecondaryIndexManager.newUpdateTransaction(PartitionUpdate update, WriteContext ctx, long nowInSec, Memtable memtable) Transaction for updates on the write path. -
Uses of Memtable in org.apache.cassandra.index.internal
Methods in org.apache.cassandra.index.internal with parameters of type MemtableModifier and TypeMethodDescriptionCassandraIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) -
Uses of Memtable in org.apache.cassandra.index.sai
Methods in org.apache.cassandra.index.sai with parameters of type MemtableModifier and TypeMethodDescriptionStorageAttachedIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext writeContext, IndexTransaction.Type transactionType, Memtable memtable) StorageAttachedIndexGroup.indexerFor(Predicate<Index> indexSelector, DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable) -
Uses of Memtable in org.apache.cassandra.index.sai.disk.v1.vector
Constructors in org.apache.cassandra.index.sai.disk.v1.vector with parameters of type MemtableModifierConstructorDescriptionOnHeapGraph(AbstractType<?> termComparator, IndexWriterConfig indexWriterConfig, Memtable memtable) -
Uses of Memtable in org.apache.cassandra.index.sai.memory
Methods in org.apache.cassandra.index.sai.memory that return MemtableMethods in org.apache.cassandra.index.sai.memory with parameters of type MemtableModifier and TypeMethodDescriptionvoidMemtableIndexManager.discardMemtable(Memtable discarded) longMemtableIndexManager.index(DecoratedKey key, Row row, Memtable mt) voidMemtableIndexManager.maybeInitializeMemtableIndex(Memtable memtable) voidMemtableIndexManager.renewMemtable(Memtable renewed) longMemtableIndexManager.update(DecoratedKey key, Row oldRow, Row newRow, Memtable memtable) Constructors in org.apache.cassandra.index.sai.memory with parameters of type MemtableModifierConstructorDescriptionMemtableIndex(StorageAttachedIndex index, Memtable memtable) VectorMemoryIndex(StorageAttachedIndex index, Memtable memtable) -
Uses of Memtable in org.apache.cassandra.index.sasi
Methods in org.apache.cassandra.index.sasi with parameters of type MemtableModifier and TypeMethodDescriptionSASIIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext context, IndexTransaction.Type transactionType, Memtable memtable) -
Uses of Memtable in org.apache.cassandra.index.sasi.conf
Methods in org.apache.cassandra.index.sasi.conf with parameters of type MemtableModifier and TypeMethodDescriptionvoidColumnIndex.discardMemtable(Memtable parent) voidColumnIndex.switchMemtable(Memtable parent) -
Uses of Memtable in org.apache.cassandra.notifications
Fields in org.apache.cassandra.notifications declared as MemtableModifier and TypeFieldDescriptionfinal MemtableMemtableDiscardedNotification.memtablefinal MemtableMemtableSwitchedNotification.nextfinal MemtableMemtableSwitchedNotification.previousfinal MemtableMemtableRenewedNotification.renewedMethods in org.apache.cassandra.notifications that return types with arguments of type MemtableModifier and TypeMethodDescriptionSSTableAddedNotification.memtable()Returns the memtable from which the tables come when they have been added due to a memtable flush.Constructors in org.apache.cassandra.notifications with parameters of type MemtableModifierConstructorDescriptionMemtableDiscardedNotification(Memtable discarded) MemtableRenewedNotification(Memtable renewed) MemtableSwitchedNotification(Memtable switched, Memtable next) SSTableAddedNotification(Iterable<SSTableReader> added, Memtable memtable) Creates a newSSTableAddedNotificationfor the specified SSTables and optional memtable. -
Uses of Memtable in org.apache.cassandra.service.paxos.uncommitted
Methods in org.apache.cassandra.service.paxos.uncommitted with parameters of type MemtableModifier and TypeMethodDescriptionPaxosUncommittedIndex.flushIterator(Memtable flushing) PaxosUncommittedTracker.UpdateSupplier.flushIterator(Memtable paxos) Callable<?>PaxosUncommittedIndex.getBlockingFlushTask(Memtable paxos) PaxosUncommittedIndex.indexerFor(DecoratedKey key, RegularAndStaticColumns columns, long nowInSec, WriteContext ctx, IndexTransaction.Type transactionType, Memtable memtable)