org.apache.hadoop.hbase.rest.client

Class RemoteHTable

java.lang.Object

org.apache.hadoop.hbase.rest.client.RemoteHTable

public class RemoteHTable
extends java.lang.Object

HTable interface to remote tables accessed via REST gateway

Constructor Summary

Constructors

Constructor and Description
RemoteHTable(Client client, Configuration conf, byte[] name) Constructor
RemoteHTable(Client client, Configuration conf, java.lang.String name) Constructor
RemoteHTable(Client client, java.lang.String name) Constructor

Method Summary

Modifier and Type	Method and Description
Result	append(Append append)
void	batch(java.util.List<? extends Row> actions, java.lang.Object[] results)
<R> void	batchCallback(java.util.List<? extends Row> actions, java.lang.Object[] results, <any> callback)
<R extends Message> java.util.Map<byte[],R>	batchCoprocessorService(Descriptors.MethodDescriptor method, Message request, byte[] startKey, byte[] endKey, R responsePrototype)
<R extends Message> void	batchCoprocessorService(Descriptors.MethodDescriptor method, Message request, byte[] startKey, byte[] endKey, R responsePrototype, <any> callback)
protected CellSetModel	buildModelFromPut(Put put)
protected java.lang.String	buildMultiRowSpec(byte[][] rows, int maxVersions)
protected Result[]	buildResultFromModel(CellSetModel model)
protected java.lang.String	buildRowSpec(byte[] row, java.util.Map familyMap, long startTime, long endTime, int maxVersions)
boolean	checkAndDelete(byte[] row, byte[] family, byte[] qualifier, byte[] value, Delete delete)
boolean	checkAndDelete(byte[] row, byte[] family, byte[] qualifier, CompareOp compareOp, byte[] value, Delete delete) Deprecated.
boolean	checkAndDelete(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, Delete delete) Deprecated.
CheckAndMutateBuilder	checkAndMutate(byte[] row, byte[] family)
boolean	checkAndMutate(byte[] row, byte[] family, byte[] qualifier, CompareOp compareOp, byte[] value, RowMutations rm) Deprecated.
boolean	checkAndMutate(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, RowMutations rm) Deprecated.
boolean	checkAndPut(byte[] row, byte[] family, byte[] qualifier, byte[] value, Put put) Deprecated.
boolean	checkAndPut(byte[] row, byte[] family, byte[] qualifier, CompareOp compareOp, byte[] value, Put put) Deprecated.
boolean	checkAndPut(byte[] row, byte[] family, byte[] qualifier, CompareOperator compareOp, byte[] value, Put put) Deprecated.
void	close()
CoprocessorRpcChannel	coprocessorService(byte[] row)
<T extends Service,R> java.util.Map<byte[],R>	coprocessorService(java.lang.Class<T> service, byte[] startKey, byte[] endKey, <any> callable)
<T extends Service,R> void	coprocessorService(java.lang.Class<T> service, byte[] startKey, byte[] endKey, <any> callable, <any> callback)
void	delete(Delete delete)
void	delete(java.util.List<Delete> deletes)
boolean	exists(Get get)
boolean[]	exists(java.util.List<Get> gets)
void	flushCommits()
Result	get(Get get)
Result[]	get(java.util.List<Get> gets)
Configuration	getConfiguration()
TableDescriptor	getDescriptor()
TableName	getName()
int	getOperationTimeout() Deprecated.
long	getOperationTimeout(java.util.concurrent.TimeUnit unit)
int	getReadRpcTimeout() Deprecated.
long	getReadRpcTimeout(java.util.concurrent.TimeUnit unit)
int	getRpcTimeout() Deprecated.
long	getRpcTimeout(java.util.concurrent.TimeUnit unit)
ResultScanner	getScanner(byte[] family)
ResultScanner	getScanner(byte[] family, byte[] qualifier)
ResultScanner	getScanner(Scan scan)
HTableDescriptor	getTableDescriptor() Deprecated.
byte[]	getTableName()
int	getWriteRpcTimeout() Deprecated.
long	getWriteRpcTimeout(java.util.concurrent.TimeUnit unit)
Result	increment(Increment increment)
long	incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, long amount)
long	incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, long amount, Durability durability)
boolean	isAutoFlush()
void	mutateRow(RowMutations rm)
void	put(java.util.List<Put> puts)
void	put(Put put)
void	setOperationTimeout(int operationTimeout) Deprecated.
void	setReadRpcTimeout(int readRpcTimeout) Deprecated.
void	setRpcTimeout(int rpcTimeout) Deprecated.
void	setWriteRpcTimeout(int writeRpcTimeout) Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

RemoteHTable

public RemoteHTable(Client client,
                    java.lang.String name)

Constructor

RemoteHTable

public RemoteHTable(Client client,
                    Configuration conf,
                    java.lang.String name)

Constructor

RemoteHTable

public RemoteHTable(Client client,
                    Configuration conf,
                    byte[] name)

Constructor

Method Detail

buildRowSpec

protected java.lang.String buildRowSpec(byte[] row,
                                        java.util.Map familyMap,
                                        long startTime,
                                        long endTime,
                                        int maxVersions)

buildMultiRowSpec

protected java.lang.String buildMultiRowSpec(byte[][] rows,
                                             int maxVersions)

buildResultFromModel

protected Result[] buildResultFromModel(CellSetModel model)

buildModelFromPut

protected CellSetModel buildModelFromPut(Put put)

getTableName

public byte[] getTableName()

getName

public TableName getName()

getConfiguration

public Configuration getConfiguration()

getTableDescriptor

@Deprecated
public HTableDescriptor getTableDescriptor()
                                                throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

get

public Result get(Get get)
           throws java.io.IOException

Throws:

java.io.IOException

get

public Result[] get(java.util.List<Get> gets)
             throws java.io.IOException

Throws:

java.io.IOException

exists

public boolean exists(Get get)
               throws java.io.IOException

Throws:

java.io.IOException

exists

public boolean[] exists(java.util.List<Get> gets)
                 throws java.io.IOException

Throws:

java.io.IOException

put

public void put(Put put)
         throws java.io.IOException

Throws:

java.io.IOException

put

public void put(java.util.List<Put> puts)
         throws java.io.IOException

Throws:

java.io.IOException

delete

public void delete(Delete delete)
            throws java.io.IOException

Throws:

java.io.IOException

delete

public void delete(java.util.List<Delete> deletes)
            throws java.io.IOException

Throws:

java.io.IOException

flushCommits

public void flushCommits()
                  throws java.io.IOException

Throws:

java.io.IOException

getDescriptor

public TableDescriptor getDescriptor()
                              throws java.io.IOException

Throws:

java.io.IOException

getScanner

public ResultScanner getScanner(Scan scan)
                         throws java.io.IOException

Throws:

java.io.IOException

getScanner

public ResultScanner getScanner(byte[] family)
                         throws java.io.IOException

Throws:

java.io.IOException

getScanner

public ResultScanner getScanner(byte[] family,
                                byte[] qualifier)
                         throws java.io.IOException

Throws:

java.io.IOException

isAutoFlush

public boolean isAutoFlush()

checkAndPut

@Deprecated
public boolean checkAndPut(byte[] row,
                                       byte[] family,
                                       byte[] qualifier,
                                       byte[] value,
                                       Put put)
                                throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

checkAndPut

@Deprecated
public boolean checkAndPut(byte[] row,
                                       byte[] family,
                                       byte[] qualifier,
                                       CompareOp compareOp,
                                       byte[] value,
                                       Put put)
                                throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

checkAndPut

@Deprecated
public boolean checkAndPut(byte[] row,
                                       byte[] family,
                                       byte[] qualifier,
                                       CompareOperator compareOp,
                                       byte[] value,
                                       Put put)
                                throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

checkAndDelete

public boolean checkAndDelete(byte[] row,
                              byte[] family,
                              byte[] qualifier,
                              byte[] value,
                              Delete delete)
                       throws java.io.IOException

Throws:

java.io.IOException

checkAndDelete

@Deprecated
public boolean checkAndDelete(byte[] row,
                                          byte[] family,
                                          byte[] qualifier,
                                          CompareOp compareOp,
                                          byte[] value,
                                          Delete delete)
                                   throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

checkAndDelete

@Deprecated
public boolean checkAndDelete(byte[] row,
                                          byte[] family,
                                          byte[] qualifier,
                                          CompareOperator compareOp,
                                          byte[] value,
                                          Delete delete)
                                   throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

checkAndMutate

public CheckAndMutateBuilder checkAndMutate(byte[] row,
                                            byte[] family)

checkAndMutate

@Deprecated
public boolean checkAndMutate(byte[] row,
                                          byte[] family,
                                          byte[] qualifier,
                                          CompareOp compareOp,
                                          byte[] value,
                                          RowMutations rm)
                                   throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

checkAndMutate

@Deprecated
public boolean checkAndMutate(byte[] row,
                                          byte[] family,
                                          byte[] qualifier,
                                          CompareOperator compareOp,
                                          byte[] value,
                                          RowMutations rm)
                                   throws java.io.IOException

Deprecated.

Throws:

java.io.IOException

increment

public Result increment(Increment increment)
                 throws java.io.IOException

Throws:

java.io.IOException

append

public Result append(Append append)
              throws java.io.IOException

Throws:

java.io.IOException

incrementColumnValue

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

Throws:

java.io.IOException

incrementColumnValue

public long incrementColumnValue(byte[] row,
                                 byte[] family,
                                 byte[] qualifier,
                                 long amount,
                                 Durability durability)
                          throws java.io.IOException

Throws:

java.io.IOException

batch

public void batch(java.util.List<? extends Row> actions,
                  java.lang.Object[] results)
           throws java.io.IOException

Throws:

java.io.IOException

batchCallback

public <R> void batchCallback(java.util.List<? extends Row> actions,
                              java.lang.Object[] results,
                              <any> callback)
                       throws java.io.IOException,
                              java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

coprocessorService

public CoprocessorRpcChannel coprocessorService(byte[] row)

coprocessorService

public <T extends Service,R> java.util.Map<byte[],R> coprocessorService(java.lang.Class<T> service,
                                                                        byte[] startKey,
                                                                        byte[] endKey,
                                                                        <any> callable)
                                                                 throws ServiceException,
                                                                        java.lang.Throwable

Throws:

ServiceException

java.lang.Throwable

coprocessorService

public <T extends Service,R> void coprocessorService(java.lang.Class<T> service,
                                                     byte[] startKey,
                                                     byte[] endKey,
                                                     <any> callable,
                                                     <any> callback)
                                              throws ServiceException,
                                                     java.lang.Throwable

Throws:

ServiceException

java.lang.Throwable

mutateRow

public void mutateRow(RowMutations rm)
               throws java.io.IOException

Throws:

java.io.IOException

batchCoprocessorService

public <R extends Message> java.util.Map<byte[],R> batchCoprocessorService(Descriptors.MethodDescriptor method,
                                                                           Message request,
                                                                           byte[] startKey,
                                                                           byte[] endKey,
                                                                           R responsePrototype)
                                                                    throws ServiceException,
                                                                           java.lang.Throwable

Throws:

ServiceException

java.lang.Throwable

batchCoprocessorService

public <R extends Message> void batchCoprocessorService(Descriptors.MethodDescriptor method,
                                                        Message request,
                                                        byte[] startKey,
                                                        byte[] endKey,
                                                        R responsePrototype,
                                                        <any> callback)
                                                 throws ServiceException,
                                                        java.lang.Throwable

Throws:

ServiceException

java.lang.Throwable

setOperationTimeout

@Deprecated
public void setOperationTimeout(int operationTimeout)

Deprecated.

getOperationTimeout

@Deprecated
public int getOperationTimeout()

Deprecated.

setRpcTimeout

@Deprecated
public void setRpcTimeout(int rpcTimeout)

Deprecated.

getReadRpcTimeout

public long getReadRpcTimeout(java.util.concurrent.TimeUnit unit)

getRpcTimeout

@Deprecated
public int getRpcTimeout()

Deprecated.

getRpcTimeout

public long getRpcTimeout(java.util.concurrent.TimeUnit unit)

getReadRpcTimeout

@Deprecated
public int getReadRpcTimeout()

Deprecated.

setReadRpcTimeout

@Deprecated
public void setReadRpcTimeout(int readRpcTimeout)

Deprecated.

getWriteRpcTimeout

public long getWriteRpcTimeout(java.util.concurrent.TimeUnit unit)

getWriteRpcTimeout

@Deprecated
public int getWriteRpcTimeout()

Deprecated.

setWriteRpcTimeout

@Deprecated
public void setWriteRpcTimeout(int writeRpcTimeout)

Deprecated.

getOperationTimeout

public long getOperationTimeout(java.util.concurrent.TimeUnit unit)