| Package | Description |
|---|---|
| org.apache.hadoop.hbase.thrift2 |
Provides an HBase Thrift
service.
|
| org.apache.hadoop.hbase.thrift2.generated |
| Modifier and Type | Method and Description |
|---|---|
TResult |
ThriftHBaseServiceHandler.append(ByteBuffer table,
TAppend append) |
boolean |
ThriftHBaseServiceHandler.checkAndDelete(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TDelete deleteSingle) |
boolean |
ThriftHBaseServiceHandler.checkAndMutate(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
TCompareOp compareOp,
ByteBuffer value,
TRowMutations rowMutations) |
boolean |
ThriftHBaseServiceHandler.checkAndPut(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TPut put) |
void |
ThriftHBaseServiceHandler.closeScanner(int scannerId) |
List<TDelete> |
ThriftHBaseServiceHandler.deleteMultiple(ByteBuffer table,
List<TDelete> deletes) |
void |
ThriftHBaseServiceHandler.deleteSingle(ByteBuffer table,
TDelete deleteSingle) |
boolean |
ThriftHBaseServiceHandler.exists(ByteBuffer table,
TGet get) |
List<Boolean> |
ThriftHBaseServiceHandler.existsAll(ByteBuffer table,
List<TGet> gets) |
TResult |
ThriftHBaseServiceHandler.get(ByteBuffer table,
TGet get) |
List<THRegionLocation> |
ThriftHBaseServiceHandler.getAllRegionLocations(ByteBuffer table) |
List<TResult> |
ThriftHBaseServiceHandler.getMultiple(ByteBuffer table,
List<TGet> gets) |
THRegionLocation |
ThriftHBaseServiceHandler.getRegionLocation(ByteBuffer table,
ByteBuffer row,
boolean reload) |
List<TResult> |
ThriftHBaseServiceHandler.getScannerResults(ByteBuffer table,
TScan scan,
int numRows) |
List<TResult> |
ThriftHBaseServiceHandler.getScannerRows(int scannerId,
int numRows) |
TResult |
ThriftHBaseServiceHandler.increment(ByteBuffer table,
TIncrement increment) |
void |
ThriftHBaseServiceHandler.mutateRow(ByteBuffer table,
TRowMutations rowMutations) |
int |
ThriftHBaseServiceHandler.openScanner(ByteBuffer table,
TScan scan) |
void |
ThriftHBaseServiceHandler.put(ByteBuffer table,
TPut put) |
void |
ThriftHBaseServiceHandler.putMultiple(ByteBuffer table,
List<TPut> puts) |
| Modifier and Type | Field and Description |
|---|---|
TIOError |
THBaseService.exists_result.io |
TIOError |
THBaseService.existsAll_result.io |
TIOError |
THBaseService.get_result.io |
TIOError |
THBaseService.getMultiple_result.io |
TIOError |
THBaseService.put_result.io |
TIOError |
THBaseService.checkAndPut_result.io |
TIOError |
THBaseService.putMultiple_result.io |
TIOError |
THBaseService.deleteSingle_result.io |
TIOError |
THBaseService.deleteMultiple_result.io |
TIOError |
THBaseService.checkAndDelete_result.io |
TIOError |
THBaseService.increment_result.io |
TIOError |
THBaseService.append_result.io |
TIOError |
THBaseService.openScanner_result.io |
TIOError |
THBaseService.getScannerRows_result.io |
TIOError |
THBaseService.closeScanner_result.io |
TIOError |
THBaseService.mutateRow_result.io |
TIOError |
THBaseService.getScannerResults_result.io |
TIOError |
THBaseService.getRegionLocation_result.io |
TIOError |
THBaseService.getAllRegionLocations_result.io |
TIOError |
THBaseService.checkAndMutate_result.io |
| Modifier and Type | Method and Description |
|---|---|
TIOError |
TIOError.deepCopy() |
TIOError |
THBaseService.exists_result.getIo() |
TIOError |
THBaseService.existsAll_result.getIo() |
TIOError |
THBaseService.get_result.getIo() |
TIOError |
THBaseService.getMultiple_result.getIo() |
TIOError |
THBaseService.put_result.getIo() |
TIOError |
THBaseService.checkAndPut_result.getIo() |
TIOError |
THBaseService.putMultiple_result.getIo() |
TIOError |
THBaseService.deleteSingle_result.getIo() |
TIOError |
THBaseService.deleteMultiple_result.getIo() |
TIOError |
THBaseService.checkAndDelete_result.getIo() |
TIOError |
THBaseService.increment_result.getIo() |
TIOError |
THBaseService.append_result.getIo() |
TIOError |
THBaseService.openScanner_result.getIo() |
TIOError |
THBaseService.getScannerRows_result.getIo() |
TIOError |
THBaseService.closeScanner_result.getIo() |
TIOError |
THBaseService.mutateRow_result.getIo() |
TIOError |
THBaseService.getScannerResults_result.getIo() |
TIOError |
THBaseService.getRegionLocation_result.getIo() |
TIOError |
THBaseService.getAllRegionLocations_result.getIo() |
TIOError |
THBaseService.checkAndMutate_result.getIo() |
TIOError |
TIOError.setMessage(String message) |
| Modifier and Type | Method and Description |
|---|---|
TResult |
THBaseService.Iface.append(ByteBuffer table,
TAppend tappend) |
TResult |
THBaseService.Client.append(ByteBuffer table,
TAppend tappend) |
boolean |
THBaseService.Iface.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 |
THBaseService.Client.checkAndDelete(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TDelete tdelete) |
boolean |
THBaseService.Iface.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 |
THBaseService.Client.checkAndMutate(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
TCompareOp compareOp,
ByteBuffer value,
TRowMutations rowMutations) |
boolean |
THBaseService.Iface.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.
|
boolean |
THBaseService.Client.checkAndPut(ByteBuffer table,
ByteBuffer row,
ByteBuffer family,
ByteBuffer qualifier,
ByteBuffer value,
TPut tput) |
void |
THBaseService.Iface.closeScanner(int scannerId)
Closes the scanner.
|
void |
THBaseService.Client.closeScanner(int scannerId) |
List<TDelete> |
THBaseService.Iface.deleteMultiple(ByteBuffer table,
List<TDelete> tdeletes)
Bulk commit a List of TDeletes to the table.
|
List<TDelete> |
THBaseService.Client.deleteMultiple(ByteBuffer table,
List<TDelete> tdeletes) |
void |
THBaseService.Iface.deleteSingle(ByteBuffer table,
TDelete tdelete)
Deletes as specified by the TDelete.
|
void |
THBaseService.Client.deleteSingle(ByteBuffer table,
TDelete tdelete) |
boolean |
THBaseService.Iface.exists(ByteBuffer table,
TGet tget)
Test for the existence of columns in the table, as specified in the TGet.
|
boolean |
THBaseService.Client.exists(ByteBuffer table,
TGet tget) |
List<Boolean> |
THBaseService.Iface.existsAll(ByteBuffer table,
List<TGet> tgets)
Test for the existence of columns in the table, as specified by the TGets.
|
List<Boolean> |
THBaseService.Client.existsAll(ByteBuffer table,
List<TGet> tgets) |
TResult |
THBaseService.Iface.get(ByteBuffer table,
TGet tget)
Method for getting data from a row.
|
TResult |
THBaseService.Client.get(ByteBuffer table,
TGet tget) |
List<THRegionLocation> |
THBaseService.Iface.getAllRegionLocations(ByteBuffer table)
Get all of the region locations for a given table.
|
List<THRegionLocation> |
THBaseService.Client.getAllRegionLocations(ByteBuffer table) |
List<TResult> |
THBaseService.Iface.getMultiple(ByteBuffer table,
List<TGet> tgets)
Method for getting multiple rows.
|
List<TResult> |
THBaseService.Client.getMultiple(ByteBuffer table,
List<TGet> tgets) |
THRegionLocation |
THBaseService.Iface.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.
|
THRegionLocation |
THBaseService.Client.getRegionLocation(ByteBuffer table,
ByteBuffer row,
boolean reload) |
boolean |
THBaseService.AsyncClient.exists_call.getResult() |
List<Boolean> |
THBaseService.AsyncClient.existsAll_call.getResult() |
TResult |
THBaseService.AsyncClient.get_call.getResult() |
List<TResult> |
THBaseService.AsyncClient.getMultiple_call.getResult() |
void |
THBaseService.AsyncClient.put_call.getResult() |
boolean |
THBaseService.AsyncClient.checkAndPut_call.getResult() |
void |
THBaseService.AsyncClient.putMultiple_call.getResult() |
void |
THBaseService.AsyncClient.deleteSingle_call.getResult() |
List<TDelete> |
THBaseService.AsyncClient.deleteMultiple_call.getResult() |
boolean |
THBaseService.AsyncClient.checkAndDelete_call.getResult() |
TResult |
THBaseService.AsyncClient.increment_call.getResult() |
TResult |
THBaseService.AsyncClient.append_call.getResult() |
int |
THBaseService.AsyncClient.openScanner_call.getResult() |
List<TResult> |
THBaseService.AsyncClient.getScannerRows_call.getResult() |
void |
THBaseService.AsyncClient.closeScanner_call.getResult() |
void |
THBaseService.AsyncClient.mutateRow_call.getResult() |
List<TResult> |
THBaseService.AsyncClient.getScannerResults_call.getResult() |
THRegionLocation |
THBaseService.AsyncClient.getRegionLocation_call.getResult() |
List<THRegionLocation> |
THBaseService.AsyncClient.getAllRegionLocations_call.getResult() |
boolean |
THBaseService.AsyncClient.checkAndMutate_call.getResult() |
List<TResult> |
THBaseService.Iface.getScannerResults(ByteBuffer table,
TScan tscan,
int numRows)
Get results for the provided TScan object.
|
List<TResult> |
THBaseService.Client.getScannerResults(ByteBuffer table,
TScan tscan,
int numRows) |
List<TResult> |
THBaseService.Iface.getScannerRows(int scannerId,
int numRows)
Grabs multiple rows from a Scanner.
|
List<TResult> |
THBaseService.Client.getScannerRows(int scannerId,
int numRows) |
TResult |
THBaseService.Iface.increment(ByteBuffer table,
TIncrement tincrement) |
TResult |
THBaseService.Client.increment(ByteBuffer table,
TIncrement tincrement) |
void |
THBaseService.Iface.mutateRow(ByteBuffer table,
TRowMutations trowMutations)
mutateRow performs multiple mutations atomically on a single row.
|
void |
THBaseService.Client.mutateRow(ByteBuffer table,
TRowMutations trowMutations) |
int |
THBaseService.Iface.openScanner(ByteBuffer table,
TScan tscan)
Get a Scanner for the provided TScan object.
|
int |
THBaseService.Client.openScanner(ByteBuffer table,
TScan tscan) |
void |
THBaseService.Iface.put(ByteBuffer table,
TPut tput)
Commit a TPut to a table.
|
void |
THBaseService.Client.put(ByteBuffer table,
TPut tput) |
void |
THBaseService.Iface.putMultiple(ByteBuffer table,
List<TPut> tputs)
Commit a List of Puts to the table.
|
void |
THBaseService.Client.putMultiple(ByteBuffer table,
List<TPut> tputs) |
TResult |
THBaseService.Client.recv_append() |
boolean |
THBaseService.Client.recv_checkAndDelete() |
boolean |
THBaseService.Client.recv_checkAndMutate() |
boolean |
THBaseService.Client.recv_checkAndPut() |
void |
THBaseService.Client.recv_closeScanner() |
List<TDelete> |
THBaseService.Client.recv_deleteMultiple() |
void |
THBaseService.Client.recv_deleteSingle() |
boolean |
THBaseService.Client.recv_exists() |
List<Boolean> |
THBaseService.Client.recv_existsAll() |
TResult |
THBaseService.Client.recv_get() |
List<THRegionLocation> |
THBaseService.Client.recv_getAllRegionLocations() |
List<TResult> |
THBaseService.Client.recv_getMultiple() |
THRegionLocation |
THBaseService.Client.recv_getRegionLocation() |
List<TResult> |
THBaseService.Client.recv_getScannerResults() |
List<TResult> |
THBaseService.Client.recv_getScannerRows() |
TResult |
THBaseService.Client.recv_increment() |
void |
THBaseService.Client.recv_mutateRow() |
int |
THBaseService.Client.recv_openScanner() |
void |
THBaseService.Client.recv_put() |
void |
THBaseService.Client.recv_putMultiple() |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.