Uses of Class
org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl.WriteEntry
Package
Description
-
Uses of MultiVersionConcurrencyControl.WriteEntry in org.apache.hadoop.hbase.regionserver
Modifier and TypeFieldDescriptionprivate final LinkedList<MultiVersionConcurrencyControl.WriteEntry>
MultiVersionConcurrencyControl.writeQueue
Modifier and TypeMethodDescriptionMultiVersionConcurrencyControl.begin()
CallMultiVersionConcurrencyControl.begin(Runnable)
with an emptyRunnable
.Start a write transaction.HRegion.doWALAppend
(WALEdit walEdit, HRegion.BatchOperation<?> batchOp, MiniBatchOperationInProgress<Mutation> miniBatchOp, long now, NonceKey nonceKey) Returns writeEntry associated with this appendHRegion.BatchOperation.writeMiniBatchOperationsToMemStore
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry, long now) Write mini-batch operations to MemStoreHRegion.MutationBatchOperation.writeMiniBatchOperationsToMemStore
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry, long now) HRegion.ReplayBatchOperation.writeMiniBatchOperationsToMemStore
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry, long now) Deprecated.Modifier and TypeMethodDescriptionprivate void
HRegion.attachRegionReplicationInWALAppend
(HRegion.BatchOperation<?> batchOp, MiniBatchOperationInProgress<Mutation> miniBatchOp, WALKeyImpl walKey, WALEdit walEdit, MultiVersionConcurrencyControl.WriteEntry writeEntry) AttachRegionReplicationSink.add(org.apache.hadoop.hbase.wal.WALKeyImpl, org.apache.hadoop.hbase.wal.WALEdit, org.apache.hadoop.hbase.ipc.ServerCall<?>)
to the mvcc writeEntry for replicating to region replica.private void
HRegion.attachRegionReplicationToFlushOpSeqIdMVCCEntry
(MultiVersionConcurrencyControl.WriteEntry flushOpSeqIdMVCCEntry, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor desc, RegionReplicationSink sink) CreateWALEdit
forWALProtos.FlushDescriptor
and attachRegionReplicationSink.add(org.apache.hadoop.hbase.wal.WALKeyImpl, org.apache.hadoop.hbase.wal.WALEdit, org.apache.hadoop.hbase.ipc.ServerCall<?>)
to the flushOpSeqIdMVCCEntry.private void
HRegion.MutationBatchOperation.attachRegionReplicationToMVCCEntry
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry mvccWriteEntry, long now) CreateWALKeyImpl
and getWALEdit
from miniBatchOp and attachRegionReplicationSink.add(org.apache.hadoop.hbase.wal.WALKeyImpl, org.apache.hadoop.hbase.wal.WALEdit, org.apache.hadoop.hbase.ipc.ServerCall<?>)
to the mvccWriteEntry.boolean
MultiVersionConcurrencyControl.complete
(MultiVersionConcurrencyControl.WriteEntry writeEntry) Mark theMultiVersionConcurrencyControl.WriteEntry
as complete and advance the read point as much as possible.void
MultiVersionConcurrencyControl.completeAndWait
(MultiVersionConcurrencyControl.WriteEntry e) Complete aMultiVersionConcurrencyControl.WriteEntry
that was created byMultiVersionConcurrencyControl.begin()
then wait until the read point catches up to our write.void
HRegion.BatchOperation.completeMiniBatchOperations
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) This method completes mini-batch operations by calling postBatchMutate() CP hook (if required) and completing mvcc.void
HRegion.MutationBatchOperation.completeMiniBatchOperations
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) void
HRegion.ReplayBatchOperation.completeMiniBatchOperations
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) Deprecated.private void
HRegion.doAttachReplicateRegionReplicaAction
(WALKeyImpl walKey, WALEdit walEdit, MultiVersionConcurrencyControl.WriteEntry writeEntry) AttachRegionReplicationSink.add(org.apache.hadoop.hbase.wal.WALKeyImpl, org.apache.hadoop.hbase.wal.WALEdit, org.apache.hadoop.hbase.ipc.ServerCall<?>)
to the mvcc writeEntry for replicating to region replica.(package private) void
MultiVersionConcurrencyControl.waitForRead
(MultiVersionConcurrencyControl.WriteEntry e) Wait for the global readPoint to advance up to the passed in write entry number.private boolean
HRegion.writeCanNotFlushMarkerToWAL
(MultiVersionConcurrencyControl.WriteEntry flushOpSeqIdMVCCEntry, WAL wal, boolean writeFlushWalMarker) This method is only used when we flush but the memstore is empty,if writeFlushWalMarker is true,we write theWALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH
flush marker to WAL when the memstore is empty.HRegion.BatchOperation.writeMiniBatchOperationsToMemStore
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry, long now) Write mini-batch operations to MemStoreHRegion.MutationBatchOperation.writeMiniBatchOperationsToMemStore
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry, long now) HRegion.ReplayBatchOperation.writeMiniBatchOperationsToMemStore
(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry, long now) Deprecated. -
Uses of MultiVersionConcurrencyControl.WriteEntry in org.apache.hadoop.hbase.regionserver.wal
Modifier and TypeMethodDescription(package private) long
FSWALEntry.stampRegionSequenceId
(MultiVersionConcurrencyControl.WriteEntry we) Here is where a WAL edit gets its sequenceid. -
Uses of MultiVersionConcurrencyControl.WriteEntry in org.apache.hadoop.hbase.wal
Modifier and TypeFieldDescriptionWALKeyImpl.writeEntry
Set in a way visible to multiple threads; e.g.Modifier and TypeMethodDescriptionWALKeyImpl.getWriteEntry()
Use it to complete mvcc transaction.Modifier and TypeMethodDescriptionvoid
WALKeyImpl.setWriteEntry
(MultiVersionConcurrencyControl.WriteEntry writeEntry)