com.alicloud.tablestore.hbase

Class TablestoreTable

java.lang.Object

com.alicloud.tablestore.hbase.TablestoreTable

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.client.Table

public class TablestoreTable
extends Object
implements org.apache.hadoop.hbase.client.Table

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.client.Table

org.apache.hadoop.hbase.client.Table.CheckAndMutateBuilder, org.apache.hadoop.hbase.client.Table.CheckAndMutateWithFilterBuilder

Constructor Summary

Constructors

Constructor and Description
TablestoreTable(TablestoreConnection connection, org.apache.hadoop.hbase.TableName tableName)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.client.Result	append(org.apache.hadoop.hbase.client.Append append)
void	batch(List<? extends org.apache.hadoop.hbase.client.Row> actions, Object[] results)
<R> void	batchCallback(List<? extends org.apache.hadoop.hbase.client.Row> actions, Object[] results, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
<R extends com.google.protobuf.Message> Map<byte[],R>	batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor methodDescriptor, com.google.protobuf.Message request, byte[] startKey, byte[] endKey, R responsePrototype)
<R extends com.google.protobuf.Message> void	batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor methodDescriptor, com.google.protobuf.Message request, byte[] startKey, byte[] endKey, R responsePrototype, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
boolean	checkAndDelete(byte[] row, byte[] family, byte[] qualifier, byte[] value, org.apache.hadoop.hbase.client.Delete delete)
boolean	checkAndDelete(byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.filter.CompareFilter.CompareOp compareOp, byte[] value, org.apache.hadoop.hbase.client.Delete delete)
boolean	checkAndMutate(byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.filter.CompareFilter.CompareOp compareOp, byte[] value, org.apache.hadoop.hbase.client.RowMutations mutation)
boolean	checkAndPut(byte[] row, byte[] family, byte[] qualifier, byte[] value, org.apache.hadoop.hbase.client.Put put)
boolean	checkAndPut(byte[] row, byte[] family, byte[] qualifier, org.apache.hadoop.hbase.filter.CompareFilter.CompareOp compareOp, byte[] value, org.apache.hadoop.hbase.client.Put put)
void	close()
org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel	coprocessorService(byte[] row)
<T extends com.google.protobuf.Service,R> Map<byte[],R>	coprocessorService(Class<T> service, byte[] startKey, byte[] endKey, org.apache.hadoop.hbase.client.coprocessor.Batch.Call<T,R> callable)
<T extends com.google.protobuf.Service,R> void	coprocessorService(Class<T> service, byte[] startKey, byte[] endKey, org.apache.hadoop.hbase.client.coprocessor.Batch.Call<T,R> callable, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
void	delete(org.apache.hadoop.hbase.client.Delete delete)
void	delete(List<org.apache.hadoop.hbase.client.Delete> deletes)
boolean	exists(org.apache.hadoop.hbase.client.Get get)
boolean[]	existsAll(List<org.apache.hadoop.hbase.client.Get> gets)
org.apache.hadoop.hbase.client.Result	get(org.apache.hadoop.hbase.client.Get get)
org.apache.hadoop.hbase.client.Result[]	get(List<org.apache.hadoop.hbase.client.Get> gets)
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.client.TableDescriptor	getDescriptor()
org.apache.hadoop.hbase.TableName	getName()
int	getOperationTimeout()
org.apache.hadoop.hbase.client.RegionLocator	getRegionLocator()
org.apache.hadoop.hbase.client.ResultScanner	getScanner(byte[] family)
org.apache.hadoop.hbase.client.ResultScanner	getScanner(byte[] family, byte[] qualifier)
org.apache.hadoop.hbase.client.ResultScanner	getScanner(org.apache.hadoop.hbase.client.Scan scan)
org.apache.hadoop.hbase.HTableDescriptor	getTableDescriptor()
org.apache.hadoop.hbase.client.Result	increment(org.apache.hadoop.hbase.client.Increment increment)
long	incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, long amount)
long	incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, long amount, org.apache.hadoop.hbase.client.Durability durability)
org.apache.hadoop.hbase.client.Result	mutateRow(org.apache.hadoop.hbase.client.RowMutations rm)
void	put(List<org.apache.hadoop.hbase.client.Put> puts)
void	put(org.apache.hadoop.hbase.client.Put put)

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

checkAndDelete, checkAndMutate, checkAndMutate, checkAndMutate, checkAndMutate, checkAndMutate, checkAndPut, exists, getOperationTimeout, getReadRpcTimeout, getReadRpcTimeout, getRpcTimeout, getRpcTimeout, getWriteRpcTimeout, getWriteRpcTimeout, setOperationTimeout, setReadRpcTimeout, setRpcTimeout, setWriteRpcTimeout

Constructor Detail

TablestoreTable

public TablestoreTable(TablestoreConnection connection,
                       org.apache.hadoop.hbase.TableName tableName)

Method Detail

getOperationTimeout

public int getOperationTimeout()

Specified by:

getOperationTimeout in interface org.apache.hadoop.hbase.client.Table

append

public org.apache.hadoop.hbase.client.Result append(org.apache.hadoop.hbase.client.Append append)
                                             throws IOException

Specified by:

append in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

getDescriptor

public org.apache.hadoop.hbase.client.TableDescriptor getDescriptor()
                                                             throws IOException

Specified by:

getDescriptor in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

getRegionLocator

public org.apache.hadoop.hbase.client.RegionLocator getRegionLocator()
                                                              throws IOException

Specified by:

getRegionLocator in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

batchCallback

public <R> void batchCallback(List<? extends org.apache.hadoop.hbase.client.Row> actions,
                              Object[] results,
                              org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
                       throws IOException,
                              InterruptedException

Specified by:

batchCallback in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

InterruptedException

batch

public void batch(List<? extends org.apache.hadoop.hbase.client.Row> actions,
                  Object[] results)
           throws IOException,
                  InterruptedException

Specified by:

batch in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

InterruptedException

checkAndDelete

public boolean checkAndDelete(byte[] row,
                              byte[] family,
                              byte[] qualifier,
                              byte[] value,
                              org.apache.hadoop.hbase.client.Delete delete)
                       throws IOException

Specified by:

checkAndDelete in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

checkAndDelete

public boolean checkAndDelete(byte[] row,
                              byte[] family,
                              byte[] qualifier,
                              org.apache.hadoop.hbase.filter.CompareFilter.CompareOp compareOp,
                              byte[] value,
                              org.apache.hadoop.hbase.client.Delete delete)
                       throws IOException

Specified by:

checkAndDelete in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

checkAndPut

public boolean checkAndPut(byte[] row,
                           byte[] family,
                           byte[] qualifier,
                           byte[] value,
                           org.apache.hadoop.hbase.client.Put put)
                    throws IOException

Specified by:

checkAndPut in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

checkAndPut

public boolean checkAndPut(byte[] row,
                           byte[] family,
                           byte[] qualifier,
                           org.apache.hadoop.hbase.filter.CompareFilter.CompareOp compareOp,
                           byte[] value,
                           org.apache.hadoop.hbase.client.Put put)
                    throws IOException

Specified by:

checkAndPut in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

coprocessorService

public org.apache.hadoop.hbase.ipc.CoprocessorRpcChannel coprocessorService(byte[] row)

Specified by:

coprocessorService in interface org.apache.hadoop.hbase.client.Table

coprocessorService

public <T extends com.google.protobuf.Service,R> Map<byte[],R> coprocessorService(Class<T> service,
                                                                                  byte[] startKey,
                                                                                  byte[] endKey,
                                                                                  org.apache.hadoop.hbase.client.coprocessor.Batch.Call<T,R> callable)
                                                                           throws com.google.protobuf.ServiceException,
                                                                                  Throwable

Specified by:

coprocessorService in interface org.apache.hadoop.hbase.client.Table

Throws:

com.google.protobuf.ServiceException

Throwable

coprocessorService

public <T extends com.google.protobuf.Service,R> void coprocessorService(Class<T> service,
                                                                         byte[] startKey,
                                                                         byte[] endKey,
                                                                         org.apache.hadoop.hbase.client.coprocessor.Batch.Call<T,R> callable,
                                                                         org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
                                                                  throws com.google.protobuf.ServiceException,
                                                                         Throwable

Specified by:

coprocessorService in interface org.apache.hadoop.hbase.client.Table

Throws:

com.google.protobuf.ServiceException

Throwable

delete

public void delete(org.apache.hadoop.hbase.client.Delete delete)
            throws IOException

Specified by:

delete in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

delete

public void delete(List<org.apache.hadoop.hbase.client.Delete> deletes)
            throws IOException

Specified by:

delete in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

exists

public boolean exists(org.apache.hadoop.hbase.client.Get get)
               throws IOException

Specified by:

exists in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

existsAll

public boolean[] existsAll(List<org.apache.hadoop.hbase.client.Get> gets)
                    throws IOException

Specified by:

existsAll in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

get

public org.apache.hadoop.hbase.client.Result get(org.apache.hadoop.hbase.client.Get get)
                                          throws IOException

Specified by:

get in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

get

public org.apache.hadoop.hbase.client.Result[] get(List<org.apache.hadoop.hbase.client.Get> gets)
                                            throws IOException

Specified by:

get in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Specified by:

getConfiguration in interface org.apache.hadoop.hbase.client.Table

getScanner

public org.apache.hadoop.hbase.client.ResultScanner getScanner(org.apache.hadoop.hbase.client.Scan scan)
                                                        throws IOException

Specified by:

getScanner in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

getScanner

public org.apache.hadoop.hbase.client.ResultScanner getScanner(byte[] family)
                                                        throws IOException

Specified by:

getScanner in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

getScanner

public org.apache.hadoop.hbase.client.ResultScanner getScanner(byte[] family,
                                                               byte[] qualifier)
                                                        throws IOException

Specified by:

getScanner in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

getTableDescriptor

public org.apache.hadoop.hbase.HTableDescriptor getTableDescriptor()
                                                            throws IOException

Specified by:

getTableDescriptor in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

getName

public org.apache.hadoop.hbase.TableName getName()

Specified by:

getName in interface org.apache.hadoop.hbase.client.Table

increment

public org.apache.hadoop.hbase.client.Result increment(org.apache.hadoop.hbase.client.Increment increment)
                                                throws IOException

Specified by:

increment in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

incrementColumnValue

public long incrementColumnValue(byte[] row,
                                 byte[] family,
                                 byte[] qualifier,
                                 long amount)
                          throws IOException

Specified by:

incrementColumnValue in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

incrementColumnValue

public long incrementColumnValue(byte[] row,
                                 byte[] family,
                                 byte[] qualifier,
                                 long amount,
                                 org.apache.hadoop.hbase.client.Durability durability)
                          throws IOException

Specified by:

incrementColumnValue in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

mutateRow

public org.apache.hadoop.hbase.client.Result mutateRow(org.apache.hadoop.hbase.client.RowMutations rm)
                                                throws IOException

Specified by:

mutateRow in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

put

public void put(org.apache.hadoop.hbase.client.Put put)
         throws IOException

Specified by:

put in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

put

public void put(List<org.apache.hadoop.hbase.client.Put> puts)
         throws IOException

Specified by:

put in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException

batchCoprocessorService

public <R extends com.google.protobuf.Message> Map<byte[],R> batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor methodDescriptor,
                                                                                     com.google.protobuf.Message request,
                                                                                     byte[] startKey,
                                                                                     byte[] endKey,
                                                                                     R responsePrototype)
                                                                              throws com.google.protobuf.ServiceException,
                                                                                     Throwable

Specified by:

batchCoprocessorService in interface org.apache.hadoop.hbase.client.Table

Throws:

com.google.protobuf.ServiceException

Throwable

batchCoprocessorService

public <R extends com.google.protobuf.Message> void batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor methodDescriptor,
                                                                            com.google.protobuf.Message request,
                                                                            byte[] startKey,
                                                                            byte[] endKey,
                                                                            R responsePrototype,
                                                                            org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
                                                                     throws com.google.protobuf.ServiceException,
                                                                            Throwable

Specified by:

batchCoprocessorService in interface org.apache.hadoop.hbase.client.Table

Throws:

com.google.protobuf.ServiceException

Throwable

checkAndMutate

public boolean checkAndMutate(byte[] row,
                              byte[] family,
                              byte[] qualifier,
                              org.apache.hadoop.hbase.filter.CompareFilter.CompareOp compareOp,
                              byte[] value,
                              org.apache.hadoop.hbase.client.RowMutations mutation)
                       throws IOException

Specified by:

checkAndMutate in interface org.apache.hadoop.hbase.client.Table

Throws:

IOException