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