| Package | Description |
|---|---|
| org.apache.hadoop.hbase.thrift |
Provides an HBase Thrift
service.
|
| org.apache.hadoop.hbase.thrift.generated |
| Modifier and Type | Method and Description |
|---|---|
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRow(ByteBuffer tableName,
ByteBuffer row,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRows(ByteBuffer tableName,
List<ByteBuffer> rows,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRowsTs(ByteBuffer tableName,
List<ByteBuffer> rows,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRowsWithColumns(ByteBuffer tableName,
List<ByteBuffer> rows,
List<ByteBuffer> columns,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRowsWithColumnsTs(ByteBuffer tableName,
List<ByteBuffer> rows,
List<ByteBuffer> columns,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRowTs(ByteBuffer tableName,
ByteBuffer row,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRowWithColumns(ByteBuffer tableName,
ByteBuffer row,
List<ByteBuffer> columns,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.getRowWithColumnsTs(ByteBuffer tableName,
ByteBuffer row,
List<ByteBuffer> columns,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
static List<TRowResult> |
ThriftUtilities.rowResultFromHBase(Result in) |
static List<TRowResult> |
ThriftUtilities.rowResultFromHBase(Result[] in)
This utility method creates a list of Thrift TRowResult "struct" based on
an array of Hbase RowResult objects.
|
static List<TRowResult> |
ThriftUtilities.rowResultFromHBase(Result[] in,
boolean sortColumns)
This utility method creates a list of Thrift TRowResult "struct" based on
an Hbase RowResult object.
|
List<TRowResult> |
ThriftServerRunner.HBaseHandler.scannerGet(int id) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.scannerGetList(int id,
int nbRows) |
| Modifier and Type | Field and Description |
|---|---|
List<TRowResult> |
Hbase.getRow_result.success |
List<TRowResult> |
Hbase.getRowWithColumns_result.success |
List<TRowResult> |
Hbase.getRowTs_result.success |
List<TRowResult> |
Hbase.getRowWithColumnsTs_result.success |
List<TRowResult> |
Hbase.getRows_result.success |
List<TRowResult> |
Hbase.getRowsWithColumns_result.success |
List<TRowResult> |
Hbase.getRowsTs_result.success |
List<TRowResult> |
Hbase.getRowsWithColumnsTs_result.success |
List<TRowResult> |
Hbase.scannerGet_result.success |
List<TRowResult> |
Hbase.scannerGetList_result.success |
| Modifier and Type | Method and Description |
|---|---|
TRowResult |
TRowResult.deepCopy() |
TRowResult |
TRowResult.setColumns(Map<ByteBuffer,TCell> columns) |
TRowResult |
TRowResult.setRow(byte[] row) |
TRowResult |
TRowResult.setRow(ByteBuffer row) |
TRowResult |
TRowResult.setSortedColumns(List<TColumn> sortedColumns) |
| Modifier and Type | Method and Description |
|---|---|
List<TRowResult> |
Hbase.AsyncClient.getRow_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.getRowWithColumns_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.getRowTs_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.getRowWithColumnsTs_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.getRows_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.getRowsWithColumns_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.getRowsTs_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.getRowsWithColumnsTs_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.scannerGet_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.scannerGetList_call.getResult() |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRow.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRowWithColumns.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRowTs.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRowWithColumnsTs.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRows.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRowsWithColumns.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRowsTs.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.getRowsWithColumnsTs.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.scannerGet.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> |
Hbase.AsyncProcessor.scannerGetList.getResultHandler(org.apache.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb,
int seqid) |
List<TRowResult> |
Hbase.Iface.getRow(ByteBuffer tableName,
ByteBuffer row,
Map<ByteBuffer,ByteBuffer> attributes)
Get all the data for the specified table and row at the latest
timestamp.
|
List<TRowResult> |
Hbase.Client.getRow(ByteBuffer tableName,
ByteBuffer row,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.Iface.getRows(ByteBuffer tableName,
List<ByteBuffer> rows,
Map<ByteBuffer,ByteBuffer> attributes)
Get all the data for the specified table and rows at the latest
timestamp.
|
List<TRowResult> |
Hbase.Client.getRows(ByteBuffer tableName,
List<ByteBuffer> rows,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.Iface.getRowsTs(ByteBuffer tableName,
List<ByteBuffer> rows,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes)
Get all the data for the specified table and rows at the specified
timestamp.
|
List<TRowResult> |
Hbase.Client.getRowsTs(ByteBuffer tableName,
List<ByteBuffer> rows,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.Iface.getRowsWithColumns(ByteBuffer tableName,
List<ByteBuffer> rows,
List<ByteBuffer> columns,
Map<ByteBuffer,ByteBuffer> attributes)
Get the specified columns for the specified table and rows at the latest
timestamp.
|
List<TRowResult> |
Hbase.Client.getRowsWithColumns(ByteBuffer tableName,
List<ByteBuffer> rows,
List<ByteBuffer> columns,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.Iface.getRowsWithColumnsTs(ByteBuffer tableName,
List<ByteBuffer> rows,
List<ByteBuffer> columns,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes)
Get the specified columns for the specified table and rows at the specified
timestamp.
|
List<TRowResult> |
Hbase.Client.getRowsWithColumnsTs(ByteBuffer tableName,
List<ByteBuffer> rows,
List<ByteBuffer> columns,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.Iface.getRowTs(ByteBuffer tableName,
ByteBuffer row,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes)
Get all the data for the specified table and row at the specified
timestamp.
|
List<TRowResult> |
Hbase.Client.getRowTs(ByteBuffer tableName,
ByteBuffer row,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.Iface.getRowWithColumns(ByteBuffer tableName,
ByteBuffer row,
List<ByteBuffer> columns,
Map<ByteBuffer,ByteBuffer> attributes)
Get the specified columns for the specified table and row at the latest
timestamp.
|
List<TRowResult> |
Hbase.Client.getRowWithColumns(ByteBuffer tableName,
ByteBuffer row,
List<ByteBuffer> columns,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.Iface.getRowWithColumnsTs(ByteBuffer tableName,
ByteBuffer row,
List<ByteBuffer> columns,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes)
Get the specified columns for the specified table and row at the specified
timestamp.
|
List<TRowResult> |
Hbase.Client.getRowWithColumnsTs(ByteBuffer tableName,
ByteBuffer row,
List<ByteBuffer> columns,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
List<TRowResult> |
Hbase.getRow_result.getSuccess() |
List<TRowResult> |
Hbase.getRowWithColumns_result.getSuccess() |
List<TRowResult> |
Hbase.getRowTs_result.getSuccess() |
List<TRowResult> |
Hbase.getRowWithColumnsTs_result.getSuccess() |
List<TRowResult> |
Hbase.getRows_result.getSuccess() |
List<TRowResult> |
Hbase.getRowsWithColumns_result.getSuccess() |
List<TRowResult> |
Hbase.getRowsTs_result.getSuccess() |
List<TRowResult> |
Hbase.getRowsWithColumnsTs_result.getSuccess() |
List<TRowResult> |
Hbase.scannerGet_result.getSuccess() |
List<TRowResult> |
Hbase.scannerGetList_result.getSuccess() |
Iterator<TRowResult> |
Hbase.getRow_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.getRowWithColumns_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.getRowTs_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.getRowWithColumnsTs_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.getRows_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.getRowsWithColumns_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.getRowsTs_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.getRowsWithColumnsTs_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.scannerGet_result.getSuccessIterator() |
Iterator<TRowResult> |
Hbase.scannerGetList_result.getSuccessIterator() |
List<TRowResult> |
Hbase.Client.recv_getRow() |
List<TRowResult> |
Hbase.Client.recv_getRows() |
List<TRowResult> |
Hbase.Client.recv_getRowsTs() |
List<TRowResult> |
Hbase.Client.recv_getRowsWithColumns() |
List<TRowResult> |
Hbase.Client.recv_getRowsWithColumnsTs() |
List<TRowResult> |
Hbase.Client.recv_getRowTs() |
List<TRowResult> |
Hbase.Client.recv_getRowWithColumns() |
List<TRowResult> |
Hbase.Client.recv_getRowWithColumnsTs() |
List<TRowResult> |
Hbase.Client.recv_scannerGet() |
List<TRowResult> |
Hbase.Client.recv_scannerGetList() |
List<TRowResult> |
Hbase.Iface.scannerGet(int id)
Returns the scanner's current row value and advances to the next
row in the table.
|
List<TRowResult> |
Hbase.Client.scannerGet(int id) |
List<TRowResult> |
Hbase.Iface.scannerGetList(int id,
int nbRows)
Returns, starting at the scanner's current row value nbRows worth of
rows and advances to the next row in the table.
|
List<TRowResult> |
Hbase.Client.scannerGetList(int id,
int nbRows) |
| Modifier and Type | Method and Description |
|---|---|
void |
Hbase.getRow_result.addToSuccess(TRowResult elem) |
void |
Hbase.getRowWithColumns_result.addToSuccess(TRowResult elem) |
void |
Hbase.getRowTs_result.addToSuccess(TRowResult elem) |
void |
Hbase.getRowWithColumnsTs_result.addToSuccess(TRowResult elem) |
void |
Hbase.getRows_result.addToSuccess(TRowResult elem) |
void |
Hbase.getRowsWithColumns_result.addToSuccess(TRowResult elem) |
void |
Hbase.getRowsTs_result.addToSuccess(TRowResult elem) |
void |
Hbase.getRowsWithColumnsTs_result.addToSuccess(TRowResult elem) |
void |
Hbase.scannerGet_result.addToSuccess(TRowResult elem) |
void |
Hbase.scannerGetList_result.addToSuccess(TRowResult elem) |
int |
TRowResult.compareTo(TRowResult other) |
boolean |
TRowResult.equals(TRowResult that) |
| Modifier and Type | Method and Description |
|---|---|
Hbase.getRow_result |
Hbase.getRow_result.setSuccess(List<TRowResult> success) |
Hbase.getRowWithColumns_result |
Hbase.getRowWithColumns_result.setSuccess(List<TRowResult> success) |
Hbase.getRowTs_result |
Hbase.getRowTs_result.setSuccess(List<TRowResult> success) |
Hbase.getRowWithColumnsTs_result |
Hbase.getRowWithColumnsTs_result.setSuccess(List<TRowResult> success) |
Hbase.getRows_result |
Hbase.getRows_result.setSuccess(List<TRowResult> success) |
Hbase.getRowsWithColumns_result |
Hbase.getRowsWithColumns_result.setSuccess(List<TRowResult> success) |
Hbase.getRowsTs_result |
Hbase.getRowsTs_result.setSuccess(List<TRowResult> success) |
Hbase.getRowsWithColumnsTs_result |
Hbase.getRowsWithColumnsTs_result.setSuccess(List<TRowResult> success) |
Hbase.scannerGet_result |
Hbase.scannerGet_result.setSuccess(List<TRowResult> success) |
Hbase.scannerGetList_result |
Hbase.scannerGetList_result.setSuccess(List<TRowResult> success) |
void |
Hbase.AsyncProcessor.getRow.start(I iface,
Hbase.getRow_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.getRows.start(I iface,
Hbase.getRows_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.getRowsTs.start(I iface,
Hbase.getRowsTs_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.getRowsWithColumns.start(I iface,
Hbase.getRowsWithColumns_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.getRowsWithColumnsTs.start(I iface,
Hbase.getRowsWithColumnsTs_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.getRowTs.start(I iface,
Hbase.getRowTs_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.getRowWithColumns.start(I iface,
Hbase.getRowWithColumns_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.getRowWithColumnsTs.start(I iface,
Hbase.getRowWithColumnsTs_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.scannerGet.start(I iface,
Hbase.scannerGet_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
void |
Hbase.AsyncProcessor.scannerGetList.start(I iface,
Hbase.scannerGetList_args args,
org.apache.thrift.async.AsyncMethodCallback<List<TRowResult>> resultHandler) |
| Constructor and Description |
|---|
TRowResult(TRowResult other)
Performs a deep copy on other.
|
| Constructor and Description |
|---|
Hbase.getRow_result(List<TRowResult> success,
IOError io) |
Hbase.getRows_result(List<TRowResult> success,
IOError io) |
Hbase.getRowsTs_result(List<TRowResult> success,
IOError io) |
Hbase.getRowsWithColumns_result(List<TRowResult> success,
IOError io) |
Hbase.getRowsWithColumnsTs_result(List<TRowResult> success,
IOError io) |
Hbase.getRowTs_result(List<TRowResult> success,
IOError io) |
Hbase.getRowWithColumns_result(List<TRowResult> success,
IOError io) |
Hbase.getRowWithColumnsTs_result(List<TRowResult> success,
IOError io) |
Hbase.scannerGet_result(List<TRowResult> success,
IOError io,
IllegalArgument ia) |
Hbase.scannerGetList_result(List<TRowResult> success,
IOError io,
IllegalArgument ia) |
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.