Uses of Class
org.apache.cassandra.utils.concurrent.OpOrder.Group
Packages that use OpOrder.Group
Package
Description
-
Uses of OpOrder.Group in org.apache.cassandra.db
Methods in org.apache.cassandra.db that return OpOrder.GroupConstructors in org.apache.cassandra.db with parameters of type OpOrder.GroupModifierConstructorDescriptionCassandraWriteContext(OpOrder.Group opGroup, CommitLogPosition position) NativeClustering(NativeAllocator allocator, OpOrder.Group writeOp, Clustering<?> clustering) NativeDecoratedKey(Token token, NativeAllocator allocator, OpOrder.Group writeOp, byte[] keyBytes) NativeDecoratedKey(Token token, NativeAllocator allocator, OpOrder.Group writeOp, ByteBuffer key) -
Uses of OpOrder.Group in org.apache.cassandra.db.lifecycle
Methods in org.apache.cassandra.db.lifecycle with parameters of type OpOrder.GroupModifier and TypeMethodDescriptionTracker.getMemtableFor(OpOrder.Group opGroup, CommitLogPosition commitLogPosition) get the Memtable that the ordered writeOp should be directed to -
Uses of OpOrder.Group in org.apache.cassandra.db.memtable
Methods in org.apache.cassandra.db.memtable with parameters of type OpOrder.GroupModifier and TypeMethodDescriptionbooleanAbstractMemtableWithCommitlog.accepts(OpOrder.Group opGroup, CommitLogPosition commitLogPosition) booleanMemtable.accepts(OpOrder.Group opGroup, CommitLogPosition commitLogPosition) Decide if this memtable should take a write with the given parameters, or if the write should go to the next memtable.voidAbstractAllocatorMemtable.markExtraOffHeapUsed(long additionalSpace, OpOrder.Group opGroup) voidMemtable.markExtraOffHeapUsed(long additionalSpace, OpOrder.Group opGroup) Adjust the used off-heap space by the given size (e.g.voidAbstractAllocatorMemtable.markExtraOnHeapUsed(long additionalSpace, OpOrder.Group opGroup) voidMemtable.markExtraOnHeapUsed(long additionalSpace, OpOrder.Group opGroup) Adjust the used on-heap space by the given size (e.g.longMemtable.put(PartitionUpdate update, UpdateTransaction indexer, OpOrder.Group opGroup) Put new data in the memtable.longShardedSkipListMemtable.put(PartitionUpdate update, UpdateTransaction indexer, OpOrder.Group opGroup) Should only be called by ColumnFamilyStore.apply via Keyspace.apply, which supplies the appropriate OpOrdering.longSkipListMemtable.put(PartitionUpdate update, UpdateTransaction indexer, OpOrder.Group opGroup) Should only be called by ColumnFamilyStore.apply via Keyspace.apply, which supplies the appropriate OpOrdering.longTrieMemtable.put(PartitionUpdate update, UpdateTransaction indexer, OpOrder.Group opGroup) Should only be called by ColumnFamilyStore.apply via Keyspace.apply, which supplies the appropriate OpOrdering. -
Uses of OpOrder.Group in org.apache.cassandra.db.partitions
Methods in org.apache.cassandra.db.partitions with parameters of type OpOrder.GroupModifier and TypeMethodDescriptionAtomicBTreePartition.addAll(PartitionUpdate update, Cloner cloner, OpOrder.Group writeOp, UpdateTransaction indexer) Adds a given update to this in-memtable partition.Constructors in org.apache.cassandra.db.partitions with parameters of type OpOrder.GroupModifierConstructorDescriptionBTreePartitionUpdater(MemtableAllocator allocator, Cloner cloner, OpOrder.Group writeOp, UpdateTransaction indexer) -
Uses of OpOrder.Group in org.apache.cassandra.db.rows
Constructors in org.apache.cassandra.db.rows with parameters of type OpOrder.GroupModifierConstructorDescriptionNativeCell(NativeAllocator allocator, OpOrder.Group writeOp, Cell<?> cell) NativeCell(NativeAllocator allocator, OpOrder.Group writeOp, ColumnMetadata column, long timestamp, int ttl, int localDeletionTimeUnsignedInteger, ByteBuffer value, CellPath path) NativeCell(NativeAllocator allocator, OpOrder.Group writeOp, ColumnMetadata column, long timestamp, int ttl, long localDeletionTime, ByteBuffer value, CellPath path) -
Uses of OpOrder.Group in org.apache.cassandra.utils.concurrent
Methods in org.apache.cassandra.utils.concurrent that return OpOrder.GroupModifier and TypeMethodDescriptionOpOrder.getCurrent()OpOrder.Barrier.getSyncPoint()returns the Group we are waiting on - any Group with.compareTo(getSyncPoint()) <= 0must complete before await() returnsOpOrder.Group.prev()OpOrder.start()Start an operation against this OpOrder.Methods in org.apache.cassandra.utils.concurrent with parameters of type OpOrder.GroupModifier and TypeMethodDescriptionintOpOrder.Group.compareTo(OpOrder.Group that) booleanOpOrder.Barrier.isAfter(OpOrder.Group group) -
Uses of OpOrder.Group in org.apache.cassandra.utils.memory
Methods in org.apache.cassandra.utils.memory with parameters of type OpOrder.GroupModifier and TypeMethodDescriptionvoidMemtableAllocator.SubAllocator.adjust(long size, OpOrder.Group opGroup) Like allocate, but permits allocations to be negative.HeapPool.Allocator.allocate(int size, OpOrder.Group opGroup) voidMemtableAllocator.SubAllocator.allocate(long size, OpOrder.Group opGroup) abstract ByteBufferMemtableBufferAllocator.allocate(int size, OpOrder.Group opGroup) longNativeAllocator.allocate(int size, OpOrder.Group opGroup) SlabAllocator.allocate(int size, OpOrder.Group opGroup) protected ClonerMemtableBufferAllocator.allocator(OpOrder.Group opGroup) NativeAllocator.clone(DecoratedKey key, OpOrder.Group writeOp) HeapPool.Allocator.cloner(OpOrder.Group opGroup) abstract ClonerMemtableAllocator.cloner(OpOrder.Group opGroup) NativeAllocator.cloner(OpOrder.Group opGroup) SlabAllocator.cloner(OpOrder.Group writeOp) NativeAllocator.rowBuilder(OpOrder.Group opGroup)