| Package | Description |
|---|---|
| org.apache.hadoop.hbase.thrift |
Provides an HBase Thrift
service.
|
| org.apache.hadoop.hbase.thrift.generated |
| Modifier and Type | Method and Description |
|---|---|
protected long |
ThriftServerRunner.HBaseHandler.atomicIncrement(ByteBuffer tableName,
ByteBuffer row,
byte[] family,
byte[] qualifier,
long amount) |
long |
ThriftServerRunner.HBaseHandler.atomicIncrement(ByteBuffer tableName,
ByteBuffer row,
ByteBuffer column,
long amount) |
boolean |
ThriftServerRunner.HBaseHandler.checkAndPut(ByteBuffer tableName,
ByteBuffer row,
ByteBuffer column,
ByteBuffer value,
Mutation mput,
Map<ByteBuffer,ByteBuffer> attributes) |
static HColumnDescriptor |
ThriftUtilities.colDescFromThrift(ColumnDescriptor in)
This utility method creates a new Hbase HColumnDescriptor object based on a
Thrift ColumnDescriptor "struct".
|
void |
ThriftServerRunner.HBaseHandler.createTable(ByteBuffer in_tableName,
List<ColumnDescriptor> columnFamilies) |
void |
ThriftServerRunner.HBaseHandler.mutateRow(ByteBuffer tableName,
ByteBuffer row,
List<Mutation> mutations,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
ThriftServerRunner.HBaseHandler.mutateRows(ByteBuffer tableName,
List<BatchMutation> rowBatches,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
ThriftServerRunner.HBaseHandler.mutateRowsTs(ByteBuffer tableName,
List<BatchMutation> rowBatches,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
ThriftServerRunner.HBaseHandler.mutateRowTs(ByteBuffer tableName,
ByteBuffer row,
List<Mutation> mutations,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
ThriftServerRunner.HBaseHandler.scannerClose(int id) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.scannerGet(int id) |
List<TRowResult> |
ThriftServerRunner.HBaseHandler.scannerGetList(int id,
int nbRows) |
| Modifier and Type | Field and Description |
|---|---|
IllegalArgument |
Hbase.createTable_result.ia |
IllegalArgument |
Hbase.mutateRow_result.ia |
IllegalArgument |
Hbase.mutateRowTs_result.ia |
IllegalArgument |
Hbase.mutateRows_result.ia |
IllegalArgument |
Hbase.mutateRowsTs_result.ia |
IllegalArgument |
Hbase.atomicIncrement_result.ia |
IllegalArgument |
Hbase.scannerGet_result.ia |
IllegalArgument |
Hbase.scannerGetList_result.ia |
IllegalArgument |
Hbase.scannerClose_result.ia |
IllegalArgument |
Hbase.checkAndPut_result.ia |
| Modifier and Type | Method and Description |
|---|---|
IllegalArgument |
IllegalArgument.deepCopy() |
IllegalArgument |
Hbase.createTable_result.getIa() |
IllegalArgument |
Hbase.mutateRow_result.getIa() |
IllegalArgument |
Hbase.mutateRowTs_result.getIa() |
IllegalArgument |
Hbase.mutateRows_result.getIa() |
IllegalArgument |
Hbase.mutateRowsTs_result.getIa() |
IllegalArgument |
Hbase.atomicIncrement_result.getIa() |
IllegalArgument |
Hbase.scannerGet_result.getIa() |
IllegalArgument |
Hbase.scannerGetList_result.getIa() |
IllegalArgument |
Hbase.scannerClose_result.getIa() |
IllegalArgument |
Hbase.checkAndPut_result.getIa() |
IllegalArgument |
IllegalArgument.setMessage(String message) |
| Modifier and Type | Method and Description |
|---|---|
long |
Hbase.Iface.atomicIncrement(ByteBuffer tableName,
ByteBuffer row,
ByteBuffer column,
long value)
Atomically increment the column value specified.
|
long |
Hbase.Client.atomicIncrement(ByteBuffer tableName,
ByteBuffer row,
ByteBuffer column,
long value) |
boolean |
Hbase.Iface.checkAndPut(ByteBuffer tableName,
ByteBuffer row,
ByteBuffer column,
ByteBuffer value,
Mutation mput,
Map<ByteBuffer,ByteBuffer> attributes)
Atomically checks if a row/family/qualifier value matches the expected
value.
|
boolean |
Hbase.Client.checkAndPut(ByteBuffer tableName,
ByteBuffer row,
ByteBuffer column,
ByteBuffer value,
Mutation mput,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
Hbase.Iface.createTable(ByteBuffer tableName,
List<ColumnDescriptor> columnFamilies)
Create a table with the specified column families.
|
void |
Hbase.Client.createTable(ByteBuffer tableName,
List<ColumnDescriptor> columnFamilies) |
void |
Hbase.AsyncClient.createTable_call.getResult() |
void |
Hbase.AsyncClient.mutateRow_call.getResult() |
void |
Hbase.AsyncClient.mutateRowTs_call.getResult() |
void |
Hbase.AsyncClient.mutateRows_call.getResult() |
void |
Hbase.AsyncClient.mutateRowsTs_call.getResult() |
long |
Hbase.AsyncClient.atomicIncrement_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.scannerGet_call.getResult() |
List<TRowResult> |
Hbase.AsyncClient.scannerGetList_call.getResult() |
void |
Hbase.AsyncClient.scannerClose_call.getResult() |
boolean |
Hbase.AsyncClient.checkAndPut_call.getResult() |
void |
Hbase.Iface.mutateRow(ByteBuffer tableName,
ByteBuffer row,
List<Mutation> mutations,
Map<ByteBuffer,ByteBuffer> attributes)
Apply a series of mutations (updates/deletes) to a row in a
single transaction.
|
void |
Hbase.Client.mutateRow(ByteBuffer tableName,
ByteBuffer row,
List<Mutation> mutations,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
Hbase.Iface.mutateRows(ByteBuffer tableName,
List<BatchMutation> rowBatches,
Map<ByteBuffer,ByteBuffer> attributes)
Apply a series of batches (each a series of mutations on a single row)
in a single transaction.
|
void |
Hbase.Client.mutateRows(ByteBuffer tableName,
List<BatchMutation> rowBatches,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
Hbase.Iface.mutateRowsTs(ByteBuffer tableName,
List<BatchMutation> rowBatches,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes)
Apply a series of batches (each a series of mutations on a single row)
in a single transaction.
|
void |
Hbase.Client.mutateRowsTs(ByteBuffer tableName,
List<BatchMutation> rowBatches,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
void |
Hbase.Iface.mutateRowTs(ByteBuffer tableName,
ByteBuffer row,
List<Mutation> mutations,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes)
Apply a series of mutations (updates/deletes) to a row in a
single transaction.
|
void |
Hbase.Client.mutateRowTs(ByteBuffer tableName,
ByteBuffer row,
List<Mutation> mutations,
long timestamp,
Map<ByteBuffer,ByteBuffer> attributes) |
long |
Hbase.Client.recv_atomicIncrement() |
boolean |
Hbase.Client.recv_checkAndPut() |
void |
Hbase.Client.recv_createTable() |
void |
Hbase.Client.recv_mutateRow() |
void |
Hbase.Client.recv_mutateRows() |
void |
Hbase.Client.recv_mutateRowsTs() |
void |
Hbase.Client.recv_mutateRowTs() |
void |
Hbase.Client.recv_scannerClose() |
List<TRowResult> |
Hbase.Client.recv_scannerGet() |
List<TRowResult> |
Hbase.Client.recv_scannerGetList() |
void |
Hbase.Iface.scannerClose(int id)
Closes the server-state associated with an open scanner.
|
void |
Hbase.Client.scannerClose(int id) |
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) |
| Constructor and Description |
|---|
Hbase.atomicIncrement_result(long success,
IOError io,
IllegalArgument ia) |
Hbase.checkAndPut_result(boolean success,
IOError io,
IllegalArgument ia) |
Hbase.createTable_result(IOError io,
IllegalArgument ia,
AlreadyExists exist) |
Hbase.mutateRow_result(IOError io,
IllegalArgument ia) |
Hbase.mutateRows_result(IOError io,
IllegalArgument ia) |
Hbase.mutateRowsTs_result(IOError io,
IllegalArgument ia) |
Hbase.mutateRowTs_result(IOError io,
IllegalArgument ia) |
Hbase.scannerClose_result(IOError io,
IllegalArgument ia) |
Hbase.scannerGet_result(List<TRowResult> success,
IOError io,
IllegalArgument ia) |
Hbase.scannerGetList_result(List<TRowResult> success,
IOError io,
IllegalArgument ia) |
IllegalArgument(IllegalArgument other)
Performs a deep copy on other.
|
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.