com.google.cloud.bigtable.hbase2_x
Class BigtableTable
- java.lang.Object
-
- com.google.cloud.bigtable.hbase.AbstractBigtableTable
-
- com.google.cloud.bigtable.hbase2_x.BigtableTable
-
- All Implemented Interfaces:
- Closeable, AutoCloseable, Table
public class BigtableTable extends AbstractBigtableTable
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.client.Table
Table.CheckAndMutateBuilder
-
-
Field Summary
-
Fields inherited from class com.google.cloud.bigtable.hbase.AbstractBigtableTable
bigtableConnection, clientWrapper, hbaseAdapter, LOG, options, tableName
-
-
Constructor Summary
Constructors Constructor and Description BigtableTable(AbstractBigtableConnection bigtableConnection, HBaseRequestAdapter hbaseAdapter)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method and Description boolean
checkAndDelete(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, Delete delete)
Table.CheckAndMutateBuilder
checkAndMutate(byte[] row, byte[] family)
boolean
checkAndMutate(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, RowMutations rm)
boolean
checkAndPut(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, Put put)
boolean[]
exists(List<Get> gets)
TableDescriptor
getDescriptor()
long
getOperationTimeout(TimeUnit arg0)
int
getReadRpcTimeout()
long
getReadRpcTimeout(TimeUnit arg0)
long
getRpcTimeout(TimeUnit arg0)
int
getWriteRpcTimeout()
long
getWriteRpcTimeout(TimeUnit arg0)
void
setReadRpcTimeout(int arg0)
void
setWriteRpcTimeout(int arg0)
static CompareFilter.CompareOp
toCompareOp(CompareOperator compareOp)
-
Methods inherited from class com.google.cloud.bigtable.hbase.AbstractBigtableTable
append, batch, batch, batchCallback, batchCallback, batchCoprocessorService, batchCoprocessorService, checkAndDelete, checkAndDelete, checkAndMutate, checkAndPut, checkAndPut, close, convertToResult, coprocessorService, coprocessorService, coprocessorService, delete, delete, exists, existsAll, get, get, getBatchExecutor, getConfiguration, getName, getOperationTimeout, getRpcTimeout, getScanner, getScanner, getScanner, getTableDescriptor, getWriteBufferSize, hasWhileMatchFilter, increment, incrementColumnValue, incrementColumnValue, mutateRow, put, put, setOperationTimeout, setRpcTimeout, setWriteBufferSize, toString
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.hadoop.hbase.client.Table
batchCoprocessorService, batchCoprocessorService, coprocessorService, coprocessorService
-
-
-
-
Constructor Detail
-
BigtableTable
public BigtableTable(AbstractBigtableConnection bigtableConnection, HBaseRequestAdapter hbaseAdapter)
-
-
Method Detail
-
toCompareOp
public static final CompareFilter.CompareOp toCompareOp(CompareOperator compareOp)
-
checkAndDelete
public boolean checkAndDelete(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, Delete delete) throws IOException
- Throws:
IOException
-
checkAndMutate
public boolean checkAndMutate(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, RowMutations rm) throws IOException
- Throws:
IOException
-
checkAndPut
public boolean checkAndPut(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, Put put) throws IOException
- Throws:
IOException
-
exists
public boolean[] exists(List<Get> gets) throws IOException
- Throws:
IOException
-
getDescriptor
public TableDescriptor getDescriptor() throws IOException
- Throws:
IOException
-
getOperationTimeout
public long getOperationTimeout(TimeUnit arg0)
-
getReadRpcTimeout
public int getReadRpcTimeout()
- Specified by:
getReadRpcTimeout
in interfaceTable
- Overrides:
getReadRpcTimeout
in classAbstractBigtableTable
-
getReadRpcTimeout
public long getReadRpcTimeout(TimeUnit arg0)
-
getRpcTimeout
public long getRpcTimeout(TimeUnit arg0)
-
getWriteRpcTimeout
public int getWriteRpcTimeout()
- Specified by:
getWriteRpcTimeout
in interfaceTable
- Overrides:
getWriteRpcTimeout
in classAbstractBigtableTable
-
getWriteRpcTimeout
public long getWriteRpcTimeout(TimeUnit arg0)
-
setReadRpcTimeout
public void setReadRpcTimeout(int arg0)
- Specified by:
setReadRpcTimeout
in interfaceTable
- Overrides:
setReadRpcTimeout
in classAbstractBigtableTable
-
setWriteRpcTimeout
public void setWriteRpcTimeout(int arg0)
- Specified by:
setWriteRpcTimeout
in interfaceTable
- Overrides:
setWriteRpcTimeout
in classAbstractBigtableTable
-
checkAndMutate
public Table.CheckAndMutateBuilder checkAndMutate(byte[] row, byte[] family)
-
-