RemoteHTable (Apache HBase 1.4.11 API)

java.lang.Object
- org.apache.hadoop.hbase.rest.client.RemoteHTable

All Implemented Interfaces:: Closeable, AutoCloseable, Table

@InterfaceAudience.Public
@InterfaceStability.Stable
public class RemoteHTable
extends Object
implements Table

HTable interface to remote tables accessed via REST gateway

Constructor Summary

Constructors
Constructor and Description
`RemoteHTable(Client client, org.apache.hadoop.conf.Configuration conf, byte[] name)` Constructor
`RemoteHTable(Client client, org.apache.hadoop.conf.Configuration conf, String name)` Constructor
`RemoteHTable(Client client, String name)` Constructor

Method Summary

Methods
Modifier and Type	Method and Description
`Result`	`append(Append append)` Appends values to one or more columns within a single row.
`Object[]`	`batch(List<? extends Row> actions)` Same as `Table.batch(List, Object[])`, but returns an array of results instead of using a results parameter reference.
`void`	`batch(List<? extends Row> actions, Object[] results)` Method that does a batch call on Deletes, Gets, Puts, Increments, Appends, RowMutations The ordering of execution of the actions is not defined.
`<R> Object[]`	`batchCallback(List<? extends Row> actions, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)` Same as `Table.batch(List)`, but with a callback.
`<R> void`	`batchCallback(List<? extends Row> actions, Object[] results, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)` Same as `Table.batch(List, Object[])`, but with a callback.
`<R extends com.google.protobuf.Message> Map<byte[],R>`	`batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, byte[] startKey, byte[] endKey, R responsePrototype)` Creates an instance of the given `Service` subclass for each table region spanning the range from the `startKey` row to `endKey` row (inclusive), all the invocations to the same region server will be batched into one call.
`<R extends com.google.protobuf.Message> void`	`batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor method, com.google.protobuf.Message request, byte[] startKey, byte[] endKey, R responsePrototype, org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)` Creates an instance of the given `Service` subclass for each table region spanning the range from the `startKey` row to `endKey` row (inclusive), all the invocations to the same region server will be batched into one call.
`protected org.apache.hadoop.hbase.rest.model.CellSetModel`	`buildModelFromPut(Put put)`
`protected String`	`buildMultiRowSpec(byte[][] rows, int maxVersions)`
`protected Result[]`	`buildResultFromModel(org.apache.hadoop.hbase.rest.model.CellSetModel model)`
`protected String`	`buildRowSpec(byte[] row, Map familyMap, long startTime, long endTime, int maxVersions)`
`boolean`	`checkAndDelete(byte[] row, byte[] family, byte[] qualifier, byte[] value, Delete delete)` Atomically checks if a row/family/qualifier value matches the expected value.
`boolean`	`checkAndDelete(byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, byte[] value, Delete delete)` Atomically checks if a row/family/qualifier value matches the expected value.
`boolean`	`checkAndMutate(byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, byte[] value, RowMutations rm)` Atomically checks if a row/family/qualifier value matches the expected value.
`boolean`	`checkAndPut(byte[] row, byte[] family, byte[] qualifier, byte[] value, Put put)` Atomically checks if a row/family/qualifier value matches the expected value.
`boolean`	`checkAndPut(byte[] row, byte[] family, byte[] qualifier, CompareFilter.CompareOp compareOp, byte[] value, Put put)` Atomically checks if a row/family/qualifier value matches the expected value.
`void`	`close()` Releases any resources held or pending changes in internal buffers.
`CoprocessorRpcChannel`	`coprocessorService(byte[] row)` Creates and returns a `RpcChannel` instance connected to the table region containing the specified 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)` Creates an instance of the given `Service` subclass for each table region spanning the range from the `startKey` row to `endKey` row (inclusive), and invokes the passed `Batch.Call.call(T)` method with each `Service` instance.
`<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)` Creates an instance of the given `Service` subclass for each table region spanning the range from the `startKey` row to `endKey` row (inclusive), and invokes the passed `Batch.Call.call(T)` method with each `Service` instance.
`void`	`delete(Delete delete)` Deletes the specified cells/row.
`void`	`delete(List<Delete> deletes)` Deletes the specified cells/rows in bulk.
`boolean`	`exists(Get get)` Test for the existence of columns in the table, as specified by the Get.
`Boolean[]`	`exists(List<Get> gets)` Deprecated.
`boolean[]`	`existsAll(List<Get> gets)` exists(List) is really a list of get() calls.
`void`	`flushCommits()`
`Result`	`get(Get get)` Extracts certain cells from a given row.
`Result[]`	`get(List<Get> gets)` Extracts certain cells from the given rows, in batch.
`org.apache.hadoop.conf.Configuration`	`getConfiguration()` Returns the `Configuration` object used by this instance.
`TableName`	`getName()` Gets the fully qualified table name instance of this table.
`int`	`getOperationTimeout()` Get timeout (millisecond) of each operation for in Table instance.
`int`	`getReadRpcTimeout()` Get timeout (millisecond) of each rpc read request in this Table instance.
`Result`	`getRowOrBefore(byte[] row, byte[] family)`
`int`	`getRpcTimeout()` Deprecated.
`ResultScanner`	`getScanner(byte[] family)` Gets a scanner on the current table for the given family.
`ResultScanner`	`getScanner(byte[] family, byte[] qualifier)` Gets a scanner on the current table for the given family and qualifier.
`ResultScanner`	`getScanner(Scan scan)` Returns a scanner on the current table as specified by the `Scan` object.
`HTableDescriptor`	`getTableDescriptor()` Gets the `table descriptor` for this table.
`byte[]`	`getTableName()`
`long`	`getWriteBufferSize()` Returns the maximum size in bytes of the write buffer for this HTable.
`int`	`getWriteRpcTimeout()` Get timeout (millisecond) of each rpc write request in this Table instance.
`Result`	`increment(Increment increment)` Increments one or more columns within a single row.
`long`	`incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, long amount)` See `Table.incrementColumnValue(byte[], byte[], byte[], long, Durability)`
`long`	`incrementColumnValue(byte[] row, byte[] family, byte[] qualifier, long amount, Durability durability)` Atomically increments a column value.
`boolean`	`isAutoFlush()`
`void`	`mutateRow(RowMutations rm)` Performs multiple mutations atomically on a single row.
`void`	`put(List<Put> puts)` Puts some data in the table, in batch.
`void`	`put(Put put)` Puts some data in the table.
`void`	`setOperationTimeout(int operationTimeout)` Set timeout (millisecond) of each operation in this Table instance, will override the value of hbase.client.operation.timeout in configuration.
`void`	`setReadRpcTimeout(int readRpcTimeout)` Set timeout (millisecond) of each rpc read request in operations of this Table instance, will override the value of hbase.rpc.read.timeout in configuration.
`void`	`setRpcTimeout(int rpcTimeout)` Deprecated.
`void`	`setWriteBufferSize(long writeBufferSize)` Sets the size of the buffer in bytes.
`void`	`setWriteRpcTimeout(int writeRpcTimeout)` Set timeout (millisecond) of each rpc write request in operations of this Table instance, will override the value of hbase.rpc.write.timeout in configuration.

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,
            String name)
```
    Constructor
  - RemoteHTable
```
public RemoteHTable(Client client,
            org.apache.hadoop.conf.Configuration conf,
            String name)
```
    Constructor
  - RemoteHTable
```
public RemoteHTable(Client client,
            org.apache.hadoop.conf.Configuration conf,
            byte[] name)
```
    Constructor
- Method Detail
  - buildRowSpec
```
protected String buildRowSpec(byte[] row,
                  Map familyMap,
                  long startTime,
                  long endTime,
                  int maxVersions)
```
  - buildMultiRowSpec
```
protected String buildMultiRowSpec(byte[][] rows,
                       int maxVersions)
```
  - buildResultFromModel
```
protected Result[] buildResultFromModel(org.apache.hadoop.hbase.rest.model.CellSetModel model)
```
  - buildModelFromPut
```
protected org.apache.hadoop.hbase.rest.model.CellSetModel buildModelFromPut(Put put)
```
  - getTableName
```
public byte[] getTableName()
```
  - getName
```
public TableName getName()
```
    Description copied from interface: Table
    
    Gets the fully qualified table name instance of this table.
    
    Specified by:
    
    getName in interface Table
  - getConfiguration
```
public org.apache.hadoop.conf.Configuration getConfiguration()
```
    Description copied from interface: Table
    
    Returns the Configuration object used by this instance.
    The reference returned is not a copy, so any change made to it will affect this instance.
    
    Specified by:
    
    getConfiguration in interface Table
  - getTableDescriptor
```
public HTableDescriptor getTableDescriptor()
                                    throws IOException
```
    Description copied from interface: Table
    
    Gets the table descriptor for this table.
    
    Specified by:
    
    getTableDescriptor in interface Table
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - close
```
public void close()
           throws IOException
```
    Description copied from interface: Table
    
    Releases any resources held or pending changes in internal buffers.
    
    Specified by:
    
    close in interface Closeable
    
    Specified by:
    
    close in interface AutoCloseable
    
    Specified by:
    
    close in interface Table
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - get
```
public Result get(Get get)
           throws IOException
```
    Description copied from interface: Table
    
    Extracts certain cells from a given row.
    
    Specified by:
    
    get in interface Table
    
    Parameters:
    get - The object that specifies what data to fetch and from which row.
    
    Returns:
    The data coming from the specified row, if it exists. If the row specified doesn't exist, the Result instance returned won't contain any KeyValue, as indicated by Result.isEmpty().
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - get
```
public Result[] get(List<Get> gets)
             throws IOException
```
    Description copied from interface: Table
    
    Extracts certain cells from the given rows, in batch.
    
    Specified by:
    
    get in interface Table
    
    Parameters:
    gets - The objects that specify what data to fetch and from which rows.
    
    Returns:
    The data coming from the specified rows, if it exists. If the row specified doesn't exist, the Result instance returned won't contain any KeyValue, as indicated by Result.isEmpty(). If there are any failures even after retries, there will be a null in the results array for those Gets, AND an exception will be thrown.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - exists
```
public boolean exists(Get get)
               throws IOException
```
    Description copied from interface: Table
    
    Test for the existence of columns in the table, as specified by the Get.
    This will return true if the Get matches one or more keys, false if not.
    This is a server-side call so it prevents any data from being transfered to the client.
    
    Specified by:
    
    exists in interface Table
    
    Parameters:
    get - the Get
    
    Returns:
    true if the specified Get matches one or more keys, false if not
    
    Throws:
    
    IOException - e
  - existsAll
```
public boolean[] existsAll(List<Get> gets)
                    throws IOException
```
    exists(List) is really a list of get() calls. Just use get().
    
    Specified by:
    
    existsAll in interface Table
    
    Parameters:
    gets - list of Get to test for the existence
    
    Returns:
    Array of boolean. True if the specified Get matches one or more keys, false if not.
    
    Throws:
    
    IOException - e
  - exists
```
@Deprecated
public Boolean[] exists(List<Get> gets)
                 throws IOException
```
    Deprecated.
    
    Throws:
    
    IOException
  - put
```
public void put(Put put)
         throws IOException
```
    Description copied from interface: Table
    
    Puts some data in the table.
    
    Specified by:
    
    put in interface Table
    
    Parameters:
    put - The data to put.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - put
```
public void put(List<Put> puts)
         throws IOException
```
    Description copied from interface: Table
    
    Puts some data in the table, in batch.
    This can be used for group commit, or for submitting user defined batches. The writeBuffer will be periodically inspected while the List is processed, so depending on the List size the writeBuffer may flush not at all, or more than once.
    
    Specified by:
    
    put in interface Table
    
    Parameters:
    puts - The list of mutations to apply. The batch put is done by aggregating the iteration of the Puts over the write buffer at the client-side for a single RPC call.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - delete
```
public void delete(Delete delete)
            throws IOException
```
    Description copied from interface: Table
    
    Deletes the specified cells/row.
    
    Specified by:
    
    delete in interface Table
    
    Parameters:
    delete - The object that specifies what to delete.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - delete
```
public void delete(List<Delete> deletes)
            throws IOException
```
    Description copied from interface: Table
    
    Deletes the specified cells/rows in bulk.
    
    Specified by:
    
    delete in interface Table
    
    Parameters:
    deletes - List of things to delete. List gets modified by this method (in particular it gets re-ordered, so the order in which the elements are inserted in the list gives no guarantee as to the order in which the Deletes are executed).
    
    Throws:
    
    IOException - if a remote or network exception occurs. In that case the deletes argument will contain the Delete instances that have not be successfully applied.
  - flushCommits
```
public void flushCommits()
                  throws IOException
```
    Throws:
    
    IOException
  - getScanner
```
public ResultScanner getScanner(Scan scan)
                         throws IOException
```
    Description copied from interface: Table
    
    Returns a scanner on the current table as specified by the Scan object. Note that the passed Scan's start row and caching properties maybe changed.
    
    Specified by:
    
    getScanner in interface Table
    
    Parameters:
    scan - A configured Scan object.
    
    Returns:
    A scanner.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - getScanner
```
public ResultScanner getScanner(byte[] family)
                         throws IOException
```
    Description copied from interface: Table
    
    Gets a scanner on the current table for the given family.
    
    Specified by:
    
    getScanner in interface Table
    
    Parameters:
    family - The column family to scan.
    
    Returns:
    A scanner.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - getScanner
```
public ResultScanner getScanner(byte[] family,
                       byte[] qualifier)
                         throws IOException
```
    Description copied from interface: Table
    
    Gets a scanner on the current table for the given family and qualifier.
    
    Specified by:
    
    getScanner in interface Table
    
    Parameters:
    family - The column family to scan.
    qualifier - The column qualifier to scan.
    
    Returns:
    A scanner.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - isAutoFlush
```
public boolean isAutoFlush()
```
  - getRowOrBefore
```
public Result getRowOrBefore(byte[] row,
                    byte[] family)
                      throws IOException
```
    Throws:
    
    IOException
  - checkAndPut
```
public boolean checkAndPut(byte[] row,
                  byte[] family,
                  byte[] qualifier,
                  byte[] value,
                  Put put)
                    throws IOException
```
    Description copied from interface: Table
    
    Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the put. If the passed value is null, the check is for the lack of column (ie: non-existance)
    
    Specified by:
    
    checkAndPut in interface Table
    
    Parameters:
    row - to check
    family - column family to check
    qualifier - column qualifier to check
    value - the expected value
    put - data to put if check succeeds
    
    Returns:
    true if the new put was executed, false otherwise
    
    Throws:
    
    IOException - e
  - checkAndPut
```
public boolean checkAndPut(byte[] row,
                  byte[] family,
                  byte[] qualifier,
                  CompareFilter.CompareOp compareOp,
                  byte[] value,
                  Put put)
                    throws IOException
```
    Description copied from interface: Table
    
    Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the put. If the passed value is null, the check is for the lack of column (ie: non-existance)
    
    Specified by:
    
    checkAndPut in interface Table
    
    Parameters:
    row - to check
    family - column family to check
    qualifier - column qualifier to check
    compareOp - comparison operator to use
    value - the expected value
    put - data to put if check succeeds
    
    Returns:
    true if the new put was executed, false otherwise
    
    Throws:
    
    IOException - e
  - checkAndDelete
```
public boolean checkAndDelete(byte[] row,
                     byte[] family,
                     byte[] qualifier,
                     byte[] value,
                     Delete delete)
                       throws IOException
```
    Description copied from interface: Table
    
    Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the delete. If the passed value is null, the check is for the lack of column (ie: non-existance)
    
    Specified by:
    
    checkAndDelete in interface Table
    
    Parameters:
    row - to check
    family - column family to check
    qualifier - column qualifier to check
    value - the expected value
    delete - data to delete if check succeeds
    
    Returns:
    true if the new delete was executed, false otherwise
    
    Throws:
    
    IOException - e
  - checkAndDelete
```
public boolean checkAndDelete(byte[] row,
                     byte[] family,
                     byte[] qualifier,
                     CompareFilter.CompareOp compareOp,
                     byte[] value,
                     Delete delete)
                       throws IOException
```
    Description copied from interface: Table
    
    Atomically checks if a row/family/qualifier value matches the expected value. If it does, it adds the delete. If the passed value is null, the check is for the lack of column (ie: non-existance)
    
    Specified by:
    
    checkAndDelete in interface Table
    
    Parameters:
    row - to check
    family - column family to check
    qualifier - column qualifier to check
    compareOp - comparison operator to use
    value - the expected value
    delete - data to delete if check succeeds
    
    Returns:
    true if the new delete was executed, false otherwise
    
    Throws:
    
    IOException - e
  - increment
```
public Result increment(Increment increment)
                 throws IOException
```
    Description copied from interface: Table
    
    Increments one or more columns within a single row.
    This operation ensures atomicity to readers. Increments are done under a single row lock, so write operations to a row are synchronized, and readers are guaranteed to see this operation fully completed.
    
    Specified by:
    
    increment in interface Table
    
    Parameters:
    increment - object that specifies the columns and amounts to be used for the increment operations
    
    Returns:
    values of columns after the increment
    
    Throws:
    
    IOException - e
  - append
```
public Result append(Append append)
              throws IOException
```
    Description copied from interface: Table
    
    Appends values to one or more columns within a single row.
    This operation guaranteed atomicity to readers. Appends are done under a single row lock, so write operations to a row are synchronized, and readers are guaranteed to see this operation fully completed.
    
    Specified by:
    
    append in interface Table
    
    Parameters:
    append - object that specifies the columns and values to be appended
    
    Returns:
    values of columns after the append operation (maybe null)
    
    Throws:
    
    IOException - e
  - incrementColumnValue
```
public long incrementColumnValue(byte[] row,
                        byte[] family,
                        byte[] qualifier,
                        long amount)
                          throws IOException
```
    Description copied from interface: Table
    
    See Table.incrementColumnValue(byte[], byte[], byte[], long, Durability)
    The Durability is defaulted to Durability.SYNC_WAL.
    
    Specified by:
    
    incrementColumnValue in interface Table
    
    Parameters:
    row - The row that contains the cell to increment.
    family - The column family of the cell to increment.
    qualifier - The column qualifier of the cell to increment.
    amount - The amount to increment the cell with (or decrement, if the amount is negative).
    
    Returns:
    The new value, post increment.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - incrementColumnValue
```
public long incrementColumnValue(byte[] row,
                        byte[] family,
                        byte[] qualifier,
                        long amount,
                        Durability durability)
                          throws IOException
```
    Description copied from interface: Table
    
    Atomically increments a column value. If the column value already exists and is not a big-endian long, this could throw an exception. If the column value does not yet exist it is initialized to amount and written to the specified column.
    Setting durability to Durability.SKIP_WAL means that in a fail scenario you will lose any increments that have not been flushed.
    
    Specified by:
    
    incrementColumnValue in interface Table
    
    Parameters:
    row - The row that contains the cell to increment.
    family - The column family of the cell to increment.
    qualifier - The column qualifier of the cell to increment.
    amount - The amount to increment the cell with (or decrement, if the amount is negative).
    durability - The persistence guarantee for this increment.
    
    Returns:
    The new value, post increment.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - batch
```
public void batch(List<? extends Row> actions,
         Object[] results)
           throws IOException
```
    Description copied from interface: Table
    
    Method that does a batch call on Deletes, Gets, Puts, Increments, Appends, RowMutations The ordering of execution of the actions is not defined. Meaning if you do a Put and a Get in the same Table.batch(java.util.List<? extends org.apache.hadoop.hbase.client.Row>, java.lang.Object[]) call, you will not necessarily be guaranteed that the Get returns what the Put had put.
    
    Specified by:
    
    batch in interface Table
    
    Parameters:
    actions - list of Get, Put, Delete, Increment, Append, RowMutations
    results - Empty Object[], same size as actions. Provides access to partial results, in case an exception is thrown. A null in the result array means that the call for that action failed, even after retries
    
    Throws:
    
    IOException
  - batch
```
public Object[] batch(List<? extends Row> actions)
               throws IOException
```
    Description copied from interface: Table
    
    Same as Table.batch(List, Object[]), but returns an array of results instead of using a results parameter reference.
    
    Specified by:
    
    batch in interface Table
    
    Parameters:
    actions - list of Get, Put, Delete, Increment, Append, RowMutations
    
    Returns:
    the results from the actions. A null in the return array means that the call for that action failed, even after retries
    
    Throws:
    
    IOException
  - batchCallback
```
public <R> void batchCallback(List<? extends Row> actions,
                     Object[] results,
                     org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
                   throws IOException,
                          InterruptedException
```
    Description copied from interface: Table
    
    Same as Table.batch(List, Object[]), but with a callback.
    
    Specified by:
    
    batchCallback in interface Table
    
    Throws:
    
    IOException
    
    InterruptedException
  - batchCallback
```
public <R> Object[] batchCallback(List<? extends Row> actions,
                         org.apache.hadoop.hbase.client.coprocessor.Batch.Callback<R> callback)
                       throws IOException,
                              InterruptedException
```
    Description copied from interface: Table
    
    Same as Table.batch(List), but with a callback.
    
    Specified by:
    
    batchCallback in interface Table
    
    Throws:
    
    IOException
    
    InterruptedException
  - coprocessorService
```
public CoprocessorRpcChannel coprocessorService(byte[] row)
```
    Description copied from interface: Table
    Creates and returns a RpcChannel instance connected to the table region containing the specified row. The row given does not actually have to exist. Whichever region would contain the row based on start and end keys will be used. Note that the row parameter is also not passed to the coprocessor handler registered for this protocol, unless the row is separately passed as an argument in the service request. The parameter here is only used to locate the region used to handle the call.
    The obtained RpcChannel instance can be used to access a published coprocessor Service using standard protobuf service invocations:
    CoprocessorRpcChannel channel = myTable.coprocessorService(rowkey); MyService.BlockingInterface service = MyService.newBlockingStub(channel); MyCallRequest request = MyCallRequest.newBuilder() ... .build(); MyCallResponse response = service.myCall(null, request);
    Specified by:
    
    coprocessorService in interface Table
    
    Parameters:
    row - The row key used to identify the remote region location
    
    Returns:
    A CoprocessorRpcChannel instance
  - 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
```
    Description copied from interface: Table
    
    Creates an instance of the given Service subclass for each table region spanning the range from the startKey row to endKey row (inclusive), and invokes the passed Batch.Call.call(T) method with each Service instance.
    
    Specified by:
    
    coprocessorService in interface Table
    
    Type Parameters:
    T - the Service subclass to connect to
    R - Return type for the callable parameter's Batch.Call.call(T) method
    Parameters:
    service - the protocol buffer Service implementation to call
    startKey - start region selection with region containing this row. If null, the selection will start with the first table region.
    endKey - select regions up to and including the region containing this row. If null, selection will continue through the last table region.
    callable - this instance's .Call#call method will be invoked once per table region, using the Service instance connected to that region.
    
    Returns:
    a map of result values keyed by region name
    
    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
```
    Description copied from interface: Table
    
    Creates an instance of the given Service subclass for each table region spanning the range from the startKey row to endKey row (inclusive), and invokes the passed Batch.Call.call(T) method with each Service instance.
    The given Batch.Callback.update(byte[], byte[], Object) method will be called with the return value from each region's Batch.Call.call(T) invocation.
    
    Specified by:
    
    coprocessorService in interface Table
    
    Type Parameters:
    T - the Service subclass to connect to
    R - Return type for the callable parameter's Batch.Call.call(T) method
    Parameters:
    service - the protocol buffer Service implementation to call
    startKey - start region selection with region containing this row. If null, the selection will start with the first table region.
    endKey - select regions up to and including the region containing this row. If null, selection will continue through the last table region.
    callable - this instance's .Call#call method will be invoked once per table region, using the Service instance connected to that region.
    
    Throws:
    
    com.google.protobuf.ServiceException
    
    Throwable
  - mutateRow
```
public void mutateRow(RowMutations rm)
               throws IOException
```
    Description copied from interface: Table
    
    Performs multiple mutations atomically on a single row. Currently Put and Delete are supported.
    
    Specified by:
    
    mutateRow in interface Table
    
    Parameters:
    rm - object that specifies the set of mutations to perform atomically
    
    Throws:
    
    IOException
  - getWriteBufferSize
```
public long getWriteBufferSize()
```
    Description copied from interface: Table
    
    Returns the maximum size in bytes of the write buffer for this HTable.
    The default value comes from the configuration parameter hbase.client.write.buffer.
    
    Specified by:
    
    getWriteBufferSize in interface Table
    
    Returns:
    The size of the write buffer in bytes.
  - setWriteBufferSize
```
public void setWriteBufferSize(long writeBufferSize)
                        throws IOException
```
    Description copied from interface: Table
    
    Sets the size of the buffer in bytes.
    If the new size is less than the current amount of data in the write buffer, the buffer gets flushed.
    
    Specified by:
    
    setWriteBufferSize in interface Table
    
    Parameters:
    writeBufferSize - The new write buffer size, in bytes.
    
    Throws:
    
    IOException - if a remote or network exception occurs.
  - batchCoprocessorService
```
public <R extends com.google.protobuf.Message> Map<byte[],R> batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                                            com.google.protobuf.Message request,
                                                                            byte[] startKey,
                                                                            byte[] endKey,
                                                                            R responsePrototype)
                                                                          throws com.google.protobuf.ServiceException,
                                                                                 Throwable
```
    Description copied from interface: Table
    
    Creates an instance of the given Service subclass for each table region spanning the range from the startKey row to endKey row (inclusive), all the invocations to the same region server will be batched into one call. The coprocessor service is invoked according to the service instance, method name and parameters.
    
    Specified by:
    
    batchCoprocessorService in interface Table
    
    Type Parameters:
    R - the response type for the coprocessor Service method
    Parameters:
    method - the descriptor for the protobuf service method to call.
    request - the method call parameters
    startKey - start region selection with region containing this row. If null, the selection will start with the first table region.
    endKey - select regions up to and including the region containing this row. If null, selection will continue through the last table region.
    responsePrototype - the proto type of the response of the method in Service.
    
    Returns:
    a map of result values keyed by region name
    
    Throws:
    
    com.google.protobuf.ServiceException
    
    Throwable
  - batchCoprocessorService
```
public <R extends com.google.protobuf.Message> void batchCoprocessorService(com.google.protobuf.Descriptors.MethodDescriptor method,
                                                                   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
```
    Description copied from interface: Table
    
    Creates an instance of the given Service subclass for each table region spanning the range from the startKey row to endKey row (inclusive), all the invocations to the same region server will be batched into one call. The coprocessor service is invoked according to the service instance, method name and parameters.
    The given Batch.Callback.update(byte[],byte[],Object) method will be called with the return value from each region's invocation.
    
    Specified by:
    
    batchCoprocessorService in interface Table
    
    Type Parameters:
    R - the response type for the coprocessor Service method
    Parameters:
    method - the descriptor for the protobuf service method to call.
    request - the method call parameters
    startKey - start region selection with region containing this row. If null, the selection will start with the first table region.
    endKey - select regions up to and including the region containing this row. If null, selection will continue through the last table region.
    responsePrototype - the proto type of the response of the method in Service.
    callback - callback to invoke with the response for each region
    
    Throws:
    
    com.google.protobuf.ServiceException
    
    Throwable
  - checkAndMutate
```
public boolean checkAndMutate(byte[] row,
                     byte[] family,
                     byte[] qualifier,
                     CompareFilter.CompareOp compareOp,
                     byte[] value,
                     RowMutations rm)
                       throws IOException
```
    Description copied from interface: Table
    
    Atomically checks if a row/family/qualifier value matches the expected value. If it does, it performs the row mutations. If the passed value is null, the check is for the lack of column (ie: non-existence)
    
    Specified by:
    
    checkAndMutate in interface Table
    
    Parameters:
    row - to check
    family - column family to check
    qualifier - column qualifier to check
    compareOp - the comparison operator
    value - the expected value
    rm - mutations to perform if check succeeds
    
    Returns:
    true if the new put was executed, false otherwise
    
    Throws:
    
    IOException - e
  - setOperationTimeout
```
public void setOperationTimeout(int operationTimeout)
```
    Description copied from interface: Table
    
    Set timeout (millisecond) of each operation in this Table instance, will override the value of hbase.client.operation.timeout in configuration. Operation timeout is a top-level restriction that makes sure a blocking method will not be blocked more than this. In each operation, if rpc request fails because of timeout or other reason, it will retry until success or throw a RetriesExhaustedException. But if the total time being blocking reach the operation timeout before retries exhausted, it will break early and throw SocketTimeoutException.
    
    Specified by:
    
    setOperationTimeout in interface Table
    
    Parameters:
    operationTimeout - the total timeout of each operation in millisecond.
  - getOperationTimeout
```
public int getOperationTimeout()
```
    Description copied from interface: Table
    
    Get timeout (millisecond) of each operation for in Table instance.
    
    Specified by:
    
    getOperationTimeout in interface Table
  - setRpcTimeout
```
@Deprecated
public void setRpcTimeout(int rpcTimeout)
```
    Deprecated.
    
    Description copied from interface: Table
    
    Set timeout (millisecond) of each rpc request in operations of this Table instance, will override the value of hbase.rpc.timeout in configuration. If a rpc request waiting too long, it will stop waiting and send a new request to retry until retries exhausted or operation timeout reached.
    NOTE: This will set both the read and write timeout settings to the provided value.
    
    Specified by:
    
    setRpcTimeout in interface Table
    
    Parameters:
    rpcTimeout - the timeout of each rpc request in millisecond.
  - getRpcTimeout
```
@Deprecated
public int getRpcTimeout()
```
    Deprecated.
    
    Description copied from interface: Table
    
    Get timeout (millisecond) of each rpc request in this Table instance.
    
    Specified by:
    
    getRpcTimeout in interface Table
  - getReadRpcTimeout
```
public int getReadRpcTimeout()
```
    Description copied from interface: Table
    
    Get timeout (millisecond) of each rpc read request in this Table instance.
    
    Specified by:
    
    getReadRpcTimeout in interface Table
  - setReadRpcTimeout
```
public void setReadRpcTimeout(int readRpcTimeout)
```
    Description copied from interface: Table
    
    Set timeout (millisecond) of each rpc read request in operations of this Table instance, will override the value of hbase.rpc.read.timeout in configuration. If a rpc read request waiting too long, it will stop waiting and send a new request to retry until retries exhausted or operation timeout reached.
    
    Specified by:
    
    setReadRpcTimeout in interface Table
  - getWriteRpcTimeout
```
public int getWriteRpcTimeout()
```
    Description copied from interface: Table
    
    Get timeout (millisecond) of each rpc write request in this Table instance.
    
    Specified by:
    
    getWriteRpcTimeout in interface Table
  - setWriteRpcTimeout
```
public void setWriteRpcTimeout(int writeRpcTimeout)
```
    Description copied from interface: Table
    
    Set timeout (millisecond) of each rpc write request in operations of this Table instance, will override the value of hbase.rpc.write.timeout in configuration. If a rpc write request waiting too long, it will stop waiting and send a new request to retry until retries exhausted or operation timeout reached.
    
    Specified by:
    
    setWriteRpcTimeout in interface Table

Class RemoteHTable

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Detail

RemoteHTable

RemoteHTable

RemoteHTable

Method Detail

buildRowSpec

buildMultiRowSpec

buildResultFromModel

buildModelFromPut

getTableName

getName

getConfiguration

getTableDescriptor

close

get

get

exists

existsAll

exists

put

put

delete

delete

flushCommits

getScanner

getScanner

getScanner

isAutoFlush

getRowOrBefore

checkAndPut

checkAndPut

checkAndDelete

checkAndDelete

increment

append

incrementColumnValue

incrementColumnValue

batch

batch

batchCallback

batchCallback

coprocessorService

coprocessorService

coprocessorService

mutateRow

getWriteBufferSize

setWriteBufferSize

batchCoprocessorService

batchCoprocessorService

checkAndMutate

setOperationTimeout

getOperationTimeout

setRpcTimeout

getRpcTimeout

getReadRpcTimeout

setReadRpcTimeout

getWriteRpcTimeout

setWriteRpcTimeout