org.apache.hadoop.hbase.thrift2.client

Class ThriftTable.CheckAndMutateBuilderImpl

java.lang.Object

org.apache.hadoop.hbase.thrift2.client.ThriftTable.CheckAndMutateBuilderImpl

All Implemented Interfaces:

Table.CheckAndMutateBuilder

Enclosing class:

ThriftTable

private class ThriftTable.CheckAndMutateBuilderImpl
extends Object
implements Table.CheckAndMutateBuilder

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
Table.CheckAndMutateBuilder	ifMatches(CompareOperator compareOp, byte[] value)
Table.CheckAndMutateBuilder	ifNotExists() Check for lack of column.
private void	preCheck()
Table.CheckAndMutateBuilder	qualifier(byte[] qualifier)
boolean	thenDelete(Delete delete)
boolean	thenMutate(RowMutations mutation)
boolean	thenPut(Put put)
Table.CheckAndMutateBuilder	timeRange(TimeRange 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.Table.CheckAndMutateBuilder

ifEquals

Field Detail

row

private final byte[] row

family

private final byte[] family

qualifier

private byte[] qualifier

op

private CompareOperator op

value

private byte[] value

Constructor Detail

CheckAndMutateBuilderImpl

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

Method Detail

qualifier

public Table.CheckAndMutateBuilder qualifier(byte[] qualifier)

Specified by:

qualifier in interface Table.CheckAndMutateBuilder

Parameters:

qualifier - column qualifier to check.

timeRange

public Table.CheckAndMutateBuilder timeRange(TimeRange timeRange)

Specified by:

timeRange in interface Table.CheckAndMutateBuilder

Parameters:

timeRange - timeRange to check

ifNotExists

public Table.CheckAndMutateBuilder ifNotExists()

Description copied from interface: Table.CheckAndMutateBuilder

Check for lack of column.

Specified by:

ifNotExists in interface Table.CheckAndMutateBuilder

ifMatches

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

Specified by:

ifMatches in interface Table.CheckAndMutateBuilder

Parameters:

compareOp - comparison operator to use

value - the expected value

preCheck

private void preCheck()

thenPut

public boolean thenPut(Put put)
                throws IOException

Specified by:

thenPut in interface Table.CheckAndMutateBuilder

Parameters:

put - data to put if check succeeds

Returns:

true if the new put was executed, false otherwise.

Throws:

IOException

thenDelete

public boolean thenDelete(Delete delete)
                   throws IOException

Specified by:

thenDelete in interface Table.CheckAndMutateBuilder

Parameters:

delete - data to delete if check succeeds

Returns:

true if the new delete was executed, false otherwise.

Throws:

IOException

thenMutate

public boolean thenMutate(RowMutations mutation)
                   throws IOException

Specified by:

thenMutate in interface Table.CheckAndMutateBuilder

Parameters:

mutation - mutations to perform if check succeeds

Returns:

true if the new mutation was executed, false otherwise.

Throws:

IOException