public static interface THBaseService.Iface
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.
|
boolean exists(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException
table
- the table to check ontget
- the TGet to check forTIOError
org.apache.thrift.TException
List<Boolean> existsAll(ByteBuffer table, List<TGet> tgets) throws TIOError, org.apache.thrift.TException
table
- the table to check ontgets
- a list of TGets to check forTIOError
org.apache.thrift.TException
TResult get(ByteBuffer table, TGet tget) throws TIOError, org.apache.thrift.TException
table
- the table to get fromtget
- the TGet to fetchTIOError
org.apache.thrift.TException
List<TResult> getMultiple(ByteBuffer table, List<TGet> tgets) throws TIOError, org.apache.thrift.TException
table
- 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 errorTIOError
org.apache.thrift.TException
void put(ByteBuffer table, TPut tput) throws TIOError, org.apache.thrift.TException
table
- the table to put data intput
- the TPut to putTIOError
org.apache.thrift.TException
boolean checkAndPut(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TPut tput) throws TIOError, org.apache.thrift.TException
table
- 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 succeedsTIOError
org.apache.thrift.TException
void putMultiple(ByteBuffer table, List<TPut> tputs) throws TIOError, org.apache.thrift.TException
table
- the table to put data intputs
- a list of TPuts to commitTIOError
org.apache.thrift.TException
void deleteSingle(ByteBuffer table, TDelete tdelete) throws TIOError, org.apache.thrift.TException
table
- the table to delete fromtdelete
- the TDelete to deleteTIOError
org.apache.thrift.TException
List<TDelete> deleteMultiple(ByteBuffer table, List<TDelete> tdeletes) throws TIOError, org.apache.thrift.TException
table
- the table to delete fromtdeletes
- list of TDeletes to deleteTIOError
org.apache.thrift.TException
boolean checkAndDelete(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, ByteBuffer value, TDelete tdelete) throws TIOError, org.apache.thrift.TException
table
- 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 succeedsTIOError
org.apache.thrift.TException
TResult increment(ByteBuffer table, TIncrement tincrement) throws TIOError, org.apache.thrift.TException
TIOError
org.apache.thrift.TException
TResult append(ByteBuffer table, TAppend tappend) throws TIOError, org.apache.thrift.TException
TIOError
org.apache.thrift.TException
int openScanner(ByteBuffer table, TScan tscan) throws TIOError, org.apache.thrift.TException
table
- the table to get the Scanner fortscan
- the scan object to get a Scanner forTIOError
org.apache.thrift.TException
List<TResult> getScannerRows(int scannerId, int numRows) throws TIOError, TIllegalArgument, org.apache.thrift.TException
scannerId
- the Id of the Scanner to return rows from. This is an Id returned from the openScanner function.numRows
- number of rows to returnTIOError
TIllegalArgument
org.apache.thrift.TException
void closeScanner(int scannerId) throws TIOError, TIllegalArgument, org.apache.thrift.TException
scannerId
- the Id of the Scanner to close *TIOError
TIllegalArgument
org.apache.thrift.TException
void mutateRow(ByteBuffer table, TRowMutations trowMutations) throws TIOError, org.apache.thrift.TException
table
- table to apply the mutationstrowMutations
- mutations to applyTIOError
org.apache.thrift.TException
List<TResult> getScannerResults(ByteBuffer table, TScan tscan, int numRows) throws TIOError, org.apache.thrift.TException
table
- the table to get the Scanner fortscan
- the scan object to get a Scanner fornumRows
- number of rows to returnTIOError
org.apache.thrift.TException
THRegionLocation getRegionLocation(ByteBuffer table, ByteBuffer row, boolean reload) throws TIOError, org.apache.thrift.TException
table
- row
- reload
- TIOError
org.apache.thrift.TException
List<THRegionLocation> getAllRegionLocations(ByteBuffer table) throws TIOError, org.apache.thrift.TException
table
- TIOError
org.apache.thrift.TException
boolean checkAndMutate(ByteBuffer table, ByteBuffer row, ByteBuffer family, ByteBuffer qualifier, TCompareOp compareOp, ByteBuffer value, TRowMutations rowMutations) throws TIOError, org.apache.thrift.TException
table
- 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 matchesTIOError
org.apache.thrift.TException
Copyright © 2007–2019 Cloudera. All rights reserved.