org.apache.hadoop.hbase.client

Class RawAsyncTableImpl.CheckAndMutateBuilderImpl

java.lang.Object

org.apache.hadoop.hbase.client.RawAsyncTableImpl.CheckAndMutateBuilderImpl

All Implemented Interfaces:

AsyncTable.CheckAndMutateBuilder

Enclosing class:

RawAsyncTableImpl

private final class RawAsyncTableImpl.CheckAndMutateBuilderImpl
extends Object
implements AsyncTable.CheckAndMutateBuilder

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	family
private CompareOperator	op
private byte[]	qualifier
private byte[]	row
private TimeRange	timeRange
private byte[]	value

Constructor Summary

Constructors

Constructor and Description
CheckAndMutateBuilderImpl(byte[] row, byte[] family)

Method Summary

Modifier and Type	Method and Description
AsyncTable.CheckAndMutateBuilder	ifMatches(CompareOperator compareOp, byte[] value) Compare a value
AsyncTable.CheckAndMutateBuilder	ifNotExists() Check for lack of column.
private void	preCheck()
AsyncTable.CheckAndMutateBuilder	qualifier(byte[] qualifier) Match a qualifier.
CompletableFuture<Boolean>	thenDelete(Delete delete) Specify a Delete to commit if the check succeeds.
CompletableFuture<Boolean>	thenMutate(RowMutations mutations) Specify a RowMutations to commit if the check succeeds.
CompletableFuture<Boolean>	thenPut(Put put) Specify a Put to commit if the check succeeds.
AsyncTable.CheckAndMutateBuilder	timeRange(TimeRange timeRange) Match a timerange.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.client.AsyncTable.CheckAndMutateBuilder

ifEquals

Field Detail

row

private final byte[] row

family

private final byte[] family

qualifier

private byte[] qualifier

timeRange

private TimeRange timeRange

op

private CompareOperator op

value

private byte[] value

Constructor Detail

CheckAndMutateBuilderImpl

public CheckAndMutateBuilderImpl(byte[] row,
                                 byte[] family)

Method Detail

qualifier

public AsyncTable.CheckAndMutateBuilder qualifier(byte[] qualifier)

Description copied from interface: AsyncTable.CheckAndMutateBuilder

Match a qualifier.

Specified by:

qualifier in interface AsyncTable.CheckAndMutateBuilder

Parameters:

qualifier - column qualifier to check.

timeRange

public AsyncTable.CheckAndMutateBuilder timeRange(TimeRange timeRange)

Description copied from interface: AsyncTable.CheckAndMutateBuilder

Match a timerange.

Specified by:

timeRange in interface AsyncTable.CheckAndMutateBuilder

Parameters:

timeRange - time range to check.

ifNotExists

public AsyncTable.CheckAndMutateBuilder ifNotExists()

Description copied from interface: AsyncTable.CheckAndMutateBuilder

Check for lack of column.

Specified by:

ifNotExists in interface AsyncTable.CheckAndMutateBuilder

ifMatches

public AsyncTable.CheckAndMutateBuilder ifMatches(CompareOperator compareOp,
                                                  byte[] value)

Description copied from interface: AsyncTable.CheckAndMutateBuilder

Compare a value

Specified by:

ifMatches in interface AsyncTable.CheckAndMutateBuilder

Parameters:

compareOp - comparison operator to use

value - the expected value

preCheck

private void preCheck()

thenPut

public CompletableFuture<Boolean> thenPut(Put put)

Description copied from interface: AsyncTable.CheckAndMutateBuilder

Specify a Put to commit if the check succeeds.

Specified by:

thenPut in interface AsyncTable.CheckAndMutateBuilder

Parameters:

put - data to put if check succeeds

Returns:

true if the new put was executed, false otherwise. The return value will be wrapped by a CompletableFuture.

thenDelete

public CompletableFuture<Boolean> thenDelete(Delete delete)

Description copied from interface: AsyncTable.CheckAndMutateBuilder

Specify a Delete to commit if the check succeeds.

Specified by:

thenDelete in interface AsyncTable.CheckAndMutateBuilder

Parameters:

delete - data to delete if check succeeds

Returns:

true if the new delete was executed, false otherwise. The return value will be wrapped by a CompletableFuture.

thenMutate

public CompletableFuture<Boolean> thenMutate(RowMutations mutations)

Description copied from interface: AsyncTable.CheckAndMutateBuilder

Specify a RowMutations to commit if the check succeeds.

Specified by:

thenMutate in interface AsyncTable.CheckAndMutateBuilder

Parameters:

mutations - mutations to perform if check succeeds

Returns:

true if the new mutation was executed, false otherwise. The return value will be wrapped by a CompletableFuture.