public static class THBaseService.Client extends org.apache.thrift.TServiceClient implements THBaseService.Iface
| Modifier and Type | Class and Description |
|---|---|
static class |
THBaseService.Client.Factory |
| Constructor and Description |
|---|
THBaseService.Client(org.apache.thrift.protocol.TProtocol prot) |
THBaseService.Client(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot) |
| Modifier and Type | Method and Description |
|---|---|
TResult |
append(ByteBuffer table,
TAppend tappend) |
boolean |
checkAndDelete(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TDelete tdelete)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
boolean |
checkAndMutate(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
TCompareOp compareOp,
ByteBuffer value,
TRowMutations rowMutations)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
boolean |
checkAndPut(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TPut tput)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
void |
closeScanner(int scannerId)
Closes the scanner.
|
List<TDelete> |
deleteMultiple(ByteBuffer table,
List<TDelete> tdeletes)
Bulk commit a List of TDeletes to the table.
|
void |
deleteSingle(ByteBuffer table,
TDelete tdelete)
Deletes as specified by the TDelete.
|
boolean |
exists(ByteBuffer table,
TGet tget)
Test for the existence of columns in the table, as specified in the TGet.
|
List<Boolean> |
existsAll(ByteBuffer table,
List<TGet> tgets)
Test for the existence of columns in the table, as specified by the TGets.
|
TResult |
get(ByteBuffer table,
TGet tget)
Method for getting data from a row.
|
List<THRegionLocation> |
getAllRegionLocations(ByteBuffer table)
Get all of the region locations for a given table.
|
List<TResult> |
getMultiple(ByteBuffer table,
List<TGet> tgets)
Method for getting multiple rows.
|
THRegionLocation |
getRegionLocation(ByteBuffer table,
ByteBuffer row,
boolean reload)
Given a table and a row get the location of the region that
would contain the given row key.
|
List<TResult> |
getScannerResults(ByteBuffer table,
TScan tscan,
int numRows)
Get results for the provided TScan object.
|
List<TResult> |
getScannerRows(int scannerId,
int numRows)
Grabs multiple rows from a Scanner.
|
TResult |
increment(ByteBuffer table,
TIncrement tincrement) |
void |
mutateRow(ByteBuffer table,
TRowMutations trowMutations)
mutateRow performs multiple mutations atomically on a single row.
|
int |
openScanner(ByteBuffer table,
TScan tscan)
Get a Scanner for the provided TScan object.
|
void |
put(ByteBuffer table,
TPut tput)
Commit a TPut to a table.
|
void |
putMultiple(ByteBuffer table,
List<TPut> tputs)
Commit a List of Puts to the table.
|
TResult |
recv_append() |
boolean |
recv_checkAndDelete() |
boolean |
recv_checkAndMutate() |
boolean |
recv_checkAndPut() |
void |
recv_closeScanner() |
List<TDelete> |
recv_deleteMultiple() |
void |
recv_deleteSingle() |
boolean |
recv_exists() |
List<Boolean> |
recv_existsAll() |
TResult |
recv_get() |
List<THRegionLocation> |
recv_getAllRegionLocations() |
List<TResult> |
recv_getMultiple() |
THRegionLocation |
recv_getRegionLocation() |
List<TResult> |
recv_getScannerResults() |
List<TResult> |
recv_getScannerRows() |
TResult |
recv_increment() |
void |
recv_mutateRow() |
int |
recv_openScanner() |
void |
recv_put() |
void |
recv_putMultiple() |
void |
send_append(ByteBuffer table,
TAppend tappend) |
void |
send_checkAndDelete(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TDelete tdelete) |
void |
send_checkAndMutate(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
TCompareOp compareOp,
ByteBuffer value,
TRowMutations rowMutations) |
void |
send_checkAndPut(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TPut tput) |
void |
send_closeScanner(int scannerId) |
void |
send_deleteMultiple(ByteBuffer table,
List<TDelete> tdeletes) |
void |
send_deleteSingle(ByteBuffer table,
TDelete tdelete) |
void |
send_exists(ByteBuffer table,
TGet tget) |
void |
send_existsAll(ByteBuffer table,
List<TGet> tgets) |
void |
send_get(ByteBuffer table,
TGet tget) |
void |
send_getAllRegionLocations(ByteBuffer table) |
void |
send_getMultiple(ByteBuffer table,
List<TGet> tgets) |
void |
send_getRegionLocation(ByteBuffer table,
ByteBuffer row,
boolean reload) |
void |
send_getScannerResults(ByteBuffer table,
TScan tscan,
int numRows) |
void |
send_getScannerRows(int scannerId,
int numRows) |
void |
send_increment(ByteBuffer table,
TIncrement tincrement) |
void |
send_mutateRow(ByteBuffer table,
TRowMutations trowMutations) |
void |
send_openScanner(ByteBuffer table,
TScan tscan) |
void |
send_put(ByteBuffer table,
TPut tput) |
void |
send_putMultiple(ByteBuffer table,
List<TPut> tputs) |
public THBaseService.Client(org.apache.thrift.protocol.TProtocol prot)
public THBaseService.Client(org.apache.thrift.protocol.TProtocol iprot,
org.apache.thrift.protocol.TProtocol oprot)
public boolean exists(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException
THBaseService.Ifaceexists in interface THBaseService.Ifacetable - the table to check ontget - the TGet to check forTIOErrororg.apache.thrift.TExceptionpublic void send_exists(ByteBuffer table, TGet tget) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean recv_exists()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic List<Boolean> existsAll(ByteBuffer table, List<TGet> tgets) throws TIOError, org.apache.thrift.TException
THBaseService.IfaceexistsAll in interface THBaseService.Ifacetable - the table to check ontgets - a list of TGets to check forTIOErrororg.apache.thrift.TExceptionpublic void send_existsAll(ByteBuffer table, List<TGet> tgets) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic List<Boolean> recv_existsAll() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic TResult get(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException
THBaseService.Ifaceget in interface THBaseService.Ifacetable - the table to get fromtget - the TGet to fetchTIOErrororg.apache.thrift.TExceptionpublic void send_get(ByteBuffer table, TGet tget) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic TResult recv_get() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic List<TResult> getMultiple(ByteBuffer table, List<TGet> tgets) throws TIOError, org.apache.thrift.TException
THBaseService.IfacegetMultiple in interface THBaseService.Ifacetable - the table to get fromtgets - a list of TGets to fetch, the Result list
will have the Results at corresponding positions
or null if there was an errorTIOErrororg.apache.thrift.TExceptionpublic void send_getMultiple(ByteBuffer table, List<TGet> tgets) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic List<TResult> recv_getMultiple() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic void put(ByteBuffer table, TPut tput) throws TIOError, org.apache.thrift.TException
THBaseService.Ifaceput in interface THBaseService.Ifacetable - the table to put data intput - the TPut to putTIOErrororg.apache.thrift.TExceptionpublic void send_put(ByteBuffer table, TPut tput) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_put()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic boolean checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput) throws TIOError, org.apache.thrift.TException
THBaseService.IfacecheckAndPut in interface THBaseService.Ifacetable - to check in and put torow - row to checkfamily - column family to checkqualifier - column qualifier to checkvalue - the expected value, if not provided the
check is for the non-existence of the
column in questiontput - the TPut to put if the check succeedsTIOErrororg.apache.thrift.TExceptionpublic void send_checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean recv_checkAndPut()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic void putMultiple(ByteBuffer table, List<TPut> tputs) throws TIOError, org.apache.thrift.TException
THBaseService.IfaceputMultiple in interface THBaseService.Ifacetable - the table to put data intputs - a list of TPuts to commitTIOErrororg.apache.thrift.TExceptionpublic void send_putMultiple(ByteBuffer table, List<TPut> tputs) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_putMultiple()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic void deleteSingle(ByteBuffer table, TDelete tdelete) throws TIOError, org.apache.thrift.TException
THBaseService.IfacedeleteSingle in interface THBaseService.Ifacetable - the table to delete fromtdelete - the TDelete to deleteTIOErrororg.apache.thrift.TExceptionpublic void send_deleteSingle(ByteBuffer table, TDelete tdelete) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_deleteSingle()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic List<TDelete> deleteMultiple(ByteBuffer table, List<TDelete> tdeletes) throws TIOError, org.apache.thrift.TException
THBaseService.IfacedeleteMultiple in interface THBaseService.Ifacetable - the table to delete fromtdeletes - list of TDeletes to deleteTIOErrororg.apache.thrift.TExceptionpublic void send_deleteMultiple(ByteBuffer table, List<TDelete> tdeletes) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic List<TDelete> recv_deleteMultiple() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic boolean checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete) throws TIOError, org.apache.thrift.TException
THBaseService.IfacecheckAndDelete in interface THBaseService.Ifacetable - to check in and delete fromrow - row to checkfamily - column family to checkqualifier - column qualifier to checkvalue - the expected value, if not provided the
check is for the non-existence of the
column in questiontdelete - the TDelete to execute if the check succeedsTIOErrororg.apache.thrift.TExceptionpublic void send_checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic boolean recv_checkAndDelete()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic TResult increment(ByteBuffer table, TIncrement tincrement) throws TIOError, org.apache.thrift.TException
increment in interface THBaseService.IfaceTIOErrororg.apache.thrift.TExceptionpublic void send_increment(ByteBuffer table, TIncrement tincrement) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic TResult recv_increment() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic TResult append(ByteBuffer table, TAppend tappend) throws TIOError, org.apache.thrift.TException
append in interface THBaseService.IfaceTIOErrororg.apache.thrift.TExceptionpublic void send_append(ByteBuffer table, TAppend tappend) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic TResult recv_append() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic int openScanner(ByteBuffer table, TScan tscan) throws TIOError, org.apache.thrift.TException
THBaseService.IfaceopenScanner in interface THBaseService.Ifacetable - the table to get the Scanner fortscan - the scan object to get a Scanner forTIOErrororg.apache.thrift.TExceptionpublic void send_openScanner(ByteBuffer table, TScan tscan) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic int recv_openScanner()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic List<TResult> getScannerRows(int scannerId, int numRows) throws TIOError, TIllegalArgument, org.apache.thrift.TException
THBaseService.IfacegetScannerRows in interface THBaseService.IfacescannerId - the Id of the Scanner to return rows from. This is an Id returned from the openScanner function.numRows - number of rows to returnTIOErrorTIllegalArgumentorg.apache.thrift.TExceptionpublic void send_getScannerRows(int scannerId,
int numRows)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic List<TResult> recv_getScannerRows() throws TIOError, TIllegalArgument, org.apache.thrift.TException
TIOErrorTIllegalArgumentorg.apache.thrift.TExceptionpublic void closeScanner(int scannerId)
throws TIOError,
TIllegalArgument,
org.apache.thrift.TException
THBaseService.IfacecloseScanner in interface THBaseService.IfacescannerId - the Id of the Scanner to close *TIOErrorTIllegalArgumentorg.apache.thrift.TExceptionpublic void send_closeScanner(int scannerId)
throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_closeScanner()
throws TIOError,
TIllegalArgument,
org.apache.thrift.TException
TIOErrorTIllegalArgumentorg.apache.thrift.TExceptionpublic void mutateRow(ByteBuffer table, TRowMutations trowMutations) throws TIOError, org.apache.thrift.TException
THBaseService.IfacemutateRow in interface THBaseService.Ifacetable - table to apply the mutationstrowMutations - mutations to applyTIOErrororg.apache.thrift.TExceptionpublic void send_mutateRow(ByteBuffer table, TRowMutations trowMutations) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic void recv_mutateRow()
throws TIOError,
org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic List<TResult> getScannerResults(ByteBuffer table, TScan tscan, int numRows) throws TIOError, org.apache.thrift.TException
THBaseService.IfacegetScannerResults in interface THBaseService.Ifacetable - the table to get the Scanner fortscan - the scan object to get a Scanner fornumRows - number of rows to returnTIOErrororg.apache.thrift.TExceptionpublic void send_getScannerResults(ByteBuffer table, TScan tscan, int numRows) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic List<TResult> recv_getScannerResults() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic THRegionLocation getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload) throws TIOError, org.apache.thrift.TException
THBaseService.IfacegetRegionLocation in interface THBaseService.IfaceTIOErrororg.apache.thrift.TExceptionpublic void send_getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic THRegionLocation recv_getRegionLocation() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic List<THRegionLocation> getAllRegionLocations(ByteBuffer table) throws TIOError, org.apache.thrift.TException
THBaseService.IfacegetAllRegionLocations in interface THBaseService.IfaceTIOErrororg.apache.thrift.TExceptionpublic void send_getAllRegionLocations(ByteBuffer table) throws org.apache.thrift.TException
org.apache.thrift.TExceptionpublic List<THRegionLocation> recv_getAllRegionLocations() throws TIOError, org.apache.thrift.TException
TIOErrororg.apache.thrift.TExceptionpublic boolean checkAndMutate(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, TCompareOp compareOp, ByteBuffer value, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException
THBaseService.IfacecheckAndMutate in interface THBaseService.Ifacetable - to check in and delete fromrow - row to checkfamily - column family to checkqualifier - column qualifier to checkcompareOp - comparison to make on the valuevalue - the expected value to be compared against, if not provided the
check is for the non-existence of the column in questionrowMutations - row mutations to execute if the value matchesTIOErrororg.apache.thrift.TExceptionpublic void send_checkAndMutate(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, TCompareOp compareOp, ByteBuffer value, TRowMutations rowMutations) throws org.apache.thrift.TException
org.apache.thrift.TExceptionCopyright © 2007–2019 The Apache Software Foundation. All rights reserved.