protected void |
HRegion.BatchOperation.addNonSkipWALMutationsToWALEdit(MiniBatchOperationInProgress<Mutation> miniBatchOp,
WALEdit walEdit,
List<Cell> cellsFromCP,
Map<byte[],List<Cell>> familyCellMap) |
protected void |
HRegion.MutationBatchOperation.addNonSkipWALMutationsToWALEdit(MiniBatchOperationInProgress<Mutation> miniBatchOp,
WALEdit walEdit,
List<Cell> cellsFromCP,
Map<byte[],List<Cell>> familyCellMap) |
private void |
HRegion.attachRegionReplicationInWALAppend(HRegion.BatchOperation<?> batchOp,
MiniBatchOperationInProgress<Mutation> miniBatchOp,
WALKeyImpl walKey,
WALEdit walEdit,
MultiVersionConcurrencyControl.WriteEntry writeEntry)
|
private void |
HRegion.MutationBatchOperation.attachRegionReplicationToMVCCEntry(MiniBatchOperationInProgress<Mutation> miniBatchOp,
MultiVersionConcurrencyControl.WriteEntry mvccWriteEntry,
long now)
|
List<Pair<NonceKey,WALEdit>> |
HRegion.BatchOperation.buildWALEdits(MiniBatchOperationInProgress<Mutation> miniBatchOp)
Builds separate WALEdit per nonce by applying input mutations.
|
List<Pair<NonceKey,WALEdit>> |
HRegion.MutationBatchOperation.buildWALEdits(MiniBatchOperationInProgress<Mutation> miniBatchOp) |
protected abstract void |
HRegion.BatchOperation.cacheSkipWALMutationForRegionReplication(MiniBatchOperationInProgress<Mutation> miniBatchOp,
List<Pair<NonceKey,WALEdit>> walEdits,
Map<byte[],List<Cell>> familyCellMap) |
protected void |
HRegion.MutationBatchOperation.cacheSkipWALMutationForRegionReplication(MiniBatchOperationInProgress<Mutation> miniBatchOp,
List<Pair<NonceKey,WALEdit>> nonceKeyAndWALEdits,
Map<byte[],List<Cell>> familyCellMap)
|
protected void |
HRegion.ReplayBatchOperation.cacheSkipWALMutationForRegionReplication(MiniBatchOperationInProgress<Mutation> miniBatchOp,
List<Pair<NonceKey,WALEdit>> walEdits,
Map<byte[],List<Cell>> familyCellMap)
Deprecated.
|
private void |
HRegion.MutationBatchOperation.checkAndMergeCPMutations(MiniBatchOperationInProgress<Mutation> miniBatchOp,
List<Region.RowLock> acquiredRowLocks,
long timestamp) |
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.
|
protected WALEdit |
HRegion.BatchOperation.createWALEdit(MiniBatchOperationInProgress<Mutation> miniBatchOp) |
private WALEdit |
HRegion.MutationBatchOperation.createWALEditForReplicateSkipWAL(MiniBatchOperationInProgress<Mutation> miniBatchOp,
List<Pair<NonceKey,WALEdit>> nonceKeyAndWALEdits) |
private void |
HRegion.BatchOperation.doFinishHotnessProtector(MiniBatchOperationInProgress<Mutation> miniBatchOp) |
void |
HRegion.BatchOperation.doPostOpCleanupForMiniBatch(MiniBatchOperationInProgress<Mutation> miniBatchOp,
WALEdit walEdit,
boolean success) |
void |
HRegion.MutationBatchOperation.doPostOpCleanupForMiniBatch(MiniBatchOperationInProgress<Mutation> miniBatchOp,
WALEdit walEdit,
boolean success) |
private MultiVersionConcurrencyControl.WriteEntry |
HRegion.doWALAppend(WALEdit walEdit,
HRegion.BatchOperation<?> batchOp,
MiniBatchOperationInProgress<Mutation> miniBatchOp,
long now,
NonceKey nonceKey)
Returns writeEntry associated with this append
|
void |
RegionCoprocessorHost.postBatchMutate(MiniBatchOperationInProgress<Mutation> miniBatchOp) |
void |
RegionCoprocessorHost.postBatchMutateIndispensably(MiniBatchOperationInProgress<Mutation> miniBatchOp,
boolean success) |
void |
RegionCoprocessorHost.preBatchMutate(MiniBatchOperationInProgress<Mutation> miniBatchOp) |
abstract void |
HRegion.BatchOperation.prepareMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp,
long timestamp,
List<Region.RowLock> acquiredRowLocks)
If necessary, calls preBatchMutate() CP hook for a mini-batch and updates metrics, cell
count, tags and timestamp for all cells of all operations in a mini-batch.
|
void |
HRegion.MutationBatchOperation.prepareMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp,
long timestamp,
List<Region.RowLock> acquiredRowLocks) |
void |
HRegion.ReplayBatchOperation.prepareMiniBatchOperations(MiniBatchOperationInProgress<Mutation> miniBatchOp,
long timestamp,
List<Region.RowLock> acquiredRowLocks)
Deprecated.
|
protected void |
HRegion.BatchOperation.writeMiniBatchOperationsToMemStore(MiniBatchOperationInProgress<Mutation> miniBatchOp,
long writeNumber) |
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.
|