private void |
HRegion.attachRegionReplicationInWALAppend(HRegion.BatchOperation<?> batchOp,
MiniBatchOperationInProgress<Mutation> miniBatchOp,
WALKeyImpl walKey,
WALEdit walEdit,
MultiVersionConcurrencyControl.WriteEntry writeEntry)
|
private void |
HRegion.attachRegionReplicationToFlushOpSeqIdMVCCEntry(MultiVersionConcurrencyControl.WriteEntry flushOpSeqIdMVCCEntry,
org.apache.hadoop.hbase.shaded.protobuf.generated.WALProtos.FlushDescriptor desc,
RegionReplicationSink sink)
|
private void |
HRegion.MutationBatchOperation.attachRegionReplicationToMVCCEntry(MiniBatchOperationInProgress<Mutation> miniBatchOp,
MultiVersionConcurrencyControl.WriteEntry mvccWriteEntry,
long now)
|
boolean |
MultiVersionConcurrencyControl.complete(MultiVersionConcurrencyControl.WriteEntry writeEntry)
|
void |
MultiVersionConcurrencyControl.completeAndWait(MultiVersionConcurrencyControl.WriteEntry e)
|
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)
|
(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 the WALProtos.FlushDescriptor.FlushAction.CANNOT_FLUSH flush marker to WAL when the memstore is
empty.
|
abstract MultiVersionConcurrencyControl.WriteEntry |
HRegion.BatchOperation.writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgress<Mutation> miniBatchOp,
MultiVersionConcurrencyControl.WriteEntry writeEntry,
long now)
Write mini-batch operations to MemStore
|
MultiVersionConcurrencyControl.WriteEntry |
HRegion.MutationBatchOperation.writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgress<Mutation> miniBatchOp,
MultiVersionConcurrencyControl.WriteEntry writeEntry,
long now) |
MultiVersionConcurrencyControl.WriteEntry |
HRegion.ReplayBatchOperation.writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgress<Mutation> miniBatchOp,
MultiVersionConcurrencyControl.WriteEntry writeEntry,
long now)
Deprecated.
|