Uses of Class
org.apache.hadoop.hbase.regionserver.MultiVersionConcurrencyControl.WriteEntry
Packages that use MultiVersionConcurrencyControl.WriteEntry
Package
Description
-
Uses of MultiVersionConcurrencyControl.WriteEntry in org.apache.hadoop.hbase.regionserver
Fields in org.apache.hadoop.hbase.regionserver with type parameters of type MultiVersionConcurrencyControl.WriteEntryModifier and TypeFieldDescriptionprivate final LinkedList<MultiVersionConcurrencyControl.WriteEntry>MultiVersionConcurrencyControl.writeQueueMethods in org.apache.hadoop.hbase.regionserver that return MultiVersionConcurrencyControl.WriteEntryModifier 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.Methods in org.apache.hadoop.hbase.regionserver with parameters of type MultiVersionConcurrencyControl.WriteEntryModifier and TypeMethodDescriptionprivate voidHRegion.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 voidHRegion.attachRegionReplicationToFlushOpSeqIdMVCCEntry(MultiVersionConcurrencyControl.WriteEntry flushOpSeqIdMVCCEntry, org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor desc, RegionReplicationSink sink) CreateWALEditforWALProtos.FlushDescriptorand attachRegionReplicationSink.add(org.apache.hadoop.hbase.wal.WALKeyImpl, org.apache.hadoop.hbase.wal.WALEdit, org.apache.hadoop.hbase.ipc.ServerCall<?>)to the flushOpSeqIdMVCCEntry.private voidHRegion.MutationBatchOperation.attachRegionReplicationToMVCCEntry(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry mvccWriteEntry, long now) CreateWALKeyImpland getWALEditfrom 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.booleanMultiVersionConcurrencyControl.complete(MultiVersionConcurrencyControl.WriteEntry writeEntry) Mark theMultiVersionConcurrencyControl.WriteEntryas complete and advance the read point as much as possible.voidMultiVersionConcurrencyControl.completeAndWait(MultiVersionConcurrencyControl.WriteEntry e) Complete aMultiVersionConcurrencyControl.WriteEntrythat was created byMultiVersionConcurrencyControl.begin()then wait until the read point catches up to our write.voidHRegion.BatchOperation.completeMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) This method completes mini-batch operations by calling postBatchMutate() CP hook (if required) and completing mvcc.voidHRegion.MutationBatchOperation.completeMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) voidHRegion.ReplayBatchOperation.completeMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp, MultiVersionConcurrencyControl.WriteEntry writeEntry) Deprecated.private voidHRegion.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) voidMultiVersionConcurrencyControl.waitForRead(MultiVersionConcurrencyControl.WriteEntry e) Wait for the global readPoint to advance up to the passed in write entry number.private booleanHRegion.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_FLUSHflush 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
Methods in org.apache.hadoop.hbase.regionserver.wal with parameters of type MultiVersionConcurrencyControl.WriteEntryModifier and TypeMethodDescription(package private) longFSWALEntry.stampRegionSequenceId(MultiVersionConcurrencyControl.WriteEntry we) Here is where a WAL edit gets its sequenceid. -
Uses of MultiVersionConcurrencyControl.WriteEntry in org.apache.hadoop.hbase.wal
Fields in org.apache.hadoop.hbase.wal declared as MultiVersionConcurrencyControl.WriteEntryModifier and TypeFieldDescriptionWALKeyImpl.writeEntrySet in a way visible to multiple threads; e.g.Methods in org.apache.hadoop.hbase.wal that return MultiVersionConcurrencyControl.WriteEntryModifier and TypeMethodDescriptionWALKeyImpl.getWriteEntry()Use it to complete mvcc transaction.Methods in org.apache.hadoop.hbase.wal with parameters of type MultiVersionConcurrencyControl.WriteEntryModifier and TypeMethodDescriptionvoidWALKeyImpl.setWriteEntry(MultiVersionConcurrencyControl.WriteEntry writeEntry)