MiniBatchOperationInProgress (Apache HBase 2.5.0 API)

java.lang.Object
- org.apache.hadoop.hbase.regionserver.MiniBatchOperationInProgress<T>

```
@InterfaceAudience.LimitedPrivate(value="Coprocesssor")
public class MiniBatchOperationInProgress<T>
extends Object
```
Wraps together the mutations which are applied as a batch to the region and their operation status and WALEdits.

See Also:

RegionObserver.preBatchMutate( org.apache.hadoop.hbase.coprocessor.ObserverContext, MiniBatchOperationInProgress), RegionObserver.postBatchMutate( org.apache.hadoop.hbase.coprocessor.ObserverContext, MiniBatchOperationInProgress)

Field Summary

Fields
Modifier and Type	Field and Description
`private int`	`cellCount`
`private int`	`firstIndex`
`private int`	`lastIndexExclusive`
`private int`	`numOfAppends`
`private int`	`numOfDeletes`
`private int`	`numOfIncrements`
`private int`	`numOfPuts`
`private T[]`	`operations`
`private Mutation[][]`	`operationsFromCoprocessors`
`private int`	`readyToWriteCount`
`private OperationStatus[]`	`retCodeDetails`
`private WALEdit[]`	`walEditsFromCoprocessors`

Constructor Summary

Constructors
Constructor and Description
`MiniBatchOperationInProgress(T[] operations, OperationStatus[] retCodeDetails, WALEdit[] walEditsFromCoprocessors, int firstIndex, int lastIndexExclusive, int readyToWriteCount)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`addCellCount(int cellCount)`
`void`	`addOperationsFromCP(int index, Mutation[] newOperations)` Add more Mutations corresponding to the Mutation at the given index to be committed atomically in the same batch.
`private int`	`getAbsoluteIndex(int index)`
`int`	`getCellCount()`
`int`	`getLastIndexExclusive()`
`int`	`getNumOfAppends()`
`int`	`getNumOfDeletes()`
`int`	`getNumOfIncrements()`
`int`	`getNumOfPuts()`
`T`	`getOperation(int index)` n * @return The operation(Mutation) at the specified position.
`Mutation[]`	`getOperationsFromCoprocessors(int index)`
`OperationStatus`	`getOperationStatus(int index)` n * @return Gets the status code for the operation(Mutation) at the specified position.
`int`	`getReadyToWriteCount()`
`WALEdit`	`getWalEdit(int index)` n * @return Gets the walEdit for the operation(Mutation) at the specified position.
`void`	`incrementNumOfAppends()`
`void`	`incrementNumOfDeletes()`
`void`	`incrementNumOfIncrements()`
`void`	`incrementNumOfPuts()`
`void`	`setOperationStatus(int index, OperationStatus opStatus)` Sets the status code for the operation(Mutation) at the specified position.
`void`	`setWalEdit(int index, WALEdit walEdit)` Sets the walEdit for the operation(Mutation) at the specified position.
`int`	`size()` Returns The number of operations(Mutations) involved in this batch.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

operations
```
private final T[] operations
```

operationsFromCoprocessors

private Mutation[][] operationsFromCoprocessors

retCodeDetails

private final OperationStatus[] retCodeDetails

walEditsFromCoprocessors

private final WALEdit[] walEditsFromCoprocessors

firstIndex
```
private final int firstIndex
```

lastIndexExclusive
```
private final int lastIndexExclusive
```

readyToWriteCount
```
private int readyToWriteCount
```

cellCount
```
private int cellCount
```

numOfPuts
```
private int numOfPuts
```

numOfDeletes
```
private int numOfDeletes
```

numOfIncrements
```
private int numOfIncrements
```

numOfAppends
```
private int numOfAppends
```

Constructor Detail

MiniBatchOperationInProgress

public MiniBatchOperationInProgress(T[] operations,
                                    OperationStatus[] retCodeDetails,
                                    WALEdit[] walEditsFromCoprocessors,
                                    int firstIndex,
                                    int lastIndexExclusive,
                                    int readyToWriteCount)

Method Detail
- size
```
public int size()
```
  Returns The number of operations(Mutations) involved in this batch.
- getOperation
```
public T getOperation(int index)
```
  n * @return The operation(Mutation) at the specified position.
- setOperationStatus
```
public void setOperationStatus(int index,
                               OperationStatus opStatus)
```
  Sets the status code for the operation(Mutation) at the specified position. By setting this status, RegionObserver can make HRegion to skip Mutations. nn
- getOperationStatus
```
public OperationStatus getOperationStatus(int index)
```
  n * @return Gets the status code for the operation(Mutation) at the specified position.
- setWalEdit
```
public void setWalEdit(int index,
                       WALEdit walEdit)
```
  Sets the walEdit for the operation(Mutation) at the specified position. nn
- getWalEdit
```
public WALEdit getWalEdit(int index)
```
  n * @return Gets the walEdit for the operation(Mutation) at the specified position.
- getAbsoluteIndex
```
private int getAbsoluteIndex(int index)
```
- addOperationsFromCP
```
public void addOperationsFromCP(int index,
                                Mutation[] newOperations)
```
  Add more Mutations corresponding to the Mutation at the given index to be committed atomically in the same batch. These mutations are applied to the WAL and applied to the memstore as well. The timestamp of the cells in the given Mutations MUST be obtained from the original mutation. Note: The durability from CP will be replaced by the durability of corresponding mutation. Note: Currently only supports Put and Delete operations.
  
  Parameters:
  
  index - the index that corresponds to the original mutation index in the batch
  
  newOperations - the Mutations to add
- getOperationsFromCoprocessors
```
public Mutation[] getOperationsFromCoprocessors(int index)
```
- getReadyToWriteCount
```
public int getReadyToWriteCount()
```
- getLastIndexExclusive
```
public int getLastIndexExclusive()
```
- getCellCount
```
public int getCellCount()
```
- addCellCount
```
public void addCellCount(int cellCount)
```
- getNumOfPuts
```
public int getNumOfPuts()
```
- incrementNumOfPuts
```
public void incrementNumOfPuts()
```
- getNumOfDeletes
```
public int getNumOfDeletes()
```
- incrementNumOfDeletes
```
public void incrementNumOfDeletes()
```
- getNumOfIncrements
```
public int getNumOfIncrements()
```
- incrementNumOfIncrements
```
public void incrementNumOfIncrements()
```
- getNumOfAppends
```
public int getNumOfAppends()
```
- incrementNumOfAppends
```
public void incrementNumOfAppends()
```

Class MiniBatchOperationInProgress<T>

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

operations

operationsFromCoprocessors

retCodeDetails

walEditsFromCoprocessors

firstIndex

lastIndexExclusive

readyToWriteCount

cellCount

numOfPuts

numOfDeletes

numOfIncrements

numOfAppends

Constructor Detail

MiniBatchOperationInProgress

Method Detail

size

getOperation

setOperationStatus

getOperationStatus

setWalEdit

getWalEdit

getAbsoluteIndex

addOperationsFromCP

getOperationsFromCoprocessors

getReadyToWriteCount

getLastIndexExclusive

getCellCount

addCellCount

getNumOfPuts

incrementNumOfPuts

getNumOfDeletes

incrementNumOfDeletes

getNumOfIncrements

incrementNumOfIncrements

getNumOfAppends

incrementNumOfAppends