Constructor Detail

• MiniBatchOperationInProgress

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

Method Detail

• size

  public int size()

  Returns:

  The number of operations(Mutations) involved in this batch.

• getOperation

  public T getOperation(int index)

  Parameters:

  index -

  Returns:

  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.

  Parameters:

  index -

  opStatus -

• getOperationStatus

  public OperationStatus getOperationStatus(int index)

  Parameters:

  index -

  Returns:

  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.

  Parameters:

  index -

  walEdit -

• getWalEdit

  public WALEdit getWalEdit(int index)

  Parameters:

  index -

  Returns:

  Gets the walEdit for the operation(Mutation) at the specified position.

• 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.

  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)