| Package | Description |
|---|---|
| org.apache.hadoop.hbase | |
| org.apache.hadoop.hbase.client |
Provides HBase Client
|
| org.apache.hadoop.hbase.io | |
| org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
| org.apache.hadoop.hbase.regionserver | |
| org.apache.hadoop.hbase.shaded.protobuf | |
| org.apache.hadoop.hbase.wal |
| Modifier and Type | Method and Description |
|---|---|
CellScanner |
CellScannable.cellScanner() |
static CellScanner |
CellUtil.createCellScanner(Cell[] cellArray) |
static CellScanner |
CellUtil.createCellScanner(Iterable<Cell> cellIterable) |
static CellScanner |
CellUtil.createCellScanner(Iterator<Cell> cells) |
static CellScanner |
CellUtil.createCellScanner(List<? extends CellScannable> cellScannerables) |
static CellScanner |
CellUtil.createCellScanner(NavigableMap<byte[],List<Cell>> map)
Flatten the map of cells out under the CellScanner
|
| Modifier and Type | Class and Description |
|---|---|
class |
Result
|
| Modifier and Type | Method and Description |
|---|---|
CellScanner |
Result.cellScanner() |
CellScanner |
Mutation.cellScanner() |
protected CellScanner |
RegionServerCallable.getRpcControllerCellScanner()
Get the RpcController CellScanner.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
RegionServerCallable.setRpcControllerCellScanner(CellScanner cellScanner) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
SizedCellScanner
A CellScanner that knows its size in memory in bytes.
|
| Modifier and Type | Method and Description |
|---|---|
CellScanner |
HBaseRpcControllerImpl.cellScanner() |
CellScanner |
DelegatingHBaseRpcController.cellScanner() |
CellScanner |
RpcCall.getCellScanner() |
| Modifier and Type | Method and Description |
|---|---|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
NettyRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
RpcServerInterface.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status)
Deprecated.
As of release 1.3, this will be removed in HBase 3.0
|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
SimpleRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
NettyRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status,
long startTime,
int timeout) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
RpcServerInterface.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status,
long startTime,
int timeout)
Deprecated.
As of release 2.0, this will be removed in HBase 3.0
|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
SimpleRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status,
long startTime,
int timeout) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
RpcServerInterface.call(RpcCall call,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
RpcServer.call(RpcCall call,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status)
This is a server side method, which is invoked over RPC.
|
| Modifier and Type | Method and Description |
|---|---|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
NettyRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
RpcServerInterface.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status)
Deprecated.
As of release 1.3, this will be removed in HBase 3.0
|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
SimpleRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
NettyRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status,
long startTime,
int timeout) |
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
RpcServerInterface.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status,
long startTime,
int timeout)
Deprecated.
As of release 2.0, this will be removed in HBase 3.0
|
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> |
SimpleRpcServer.call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
org.apache.hadoop.hbase.monitoring.MonitoredRPCHandler status,
long startTime,
int timeout) |
HBaseRpcController |
RpcControllerFactory.newController(CellScanner cellScanner) |
void |
HBaseRpcControllerImpl.setCellScanner(CellScanner cellScanner) |
void |
DelegatingHBaseRpcController.setCellScanner(CellScanner cellScanner) |
void |
HBaseRpcController.setCellScanner(CellScanner cellScanner)
Only used to send cells to rpc server, the returned cells should be set by
HBaseRpcController.setDone(CellScanner). |
void |
HBaseRpcControllerImpl.setDone(CellScanner cellScanner) |
void |
DelegatingHBaseRpcController.setDone(CellScanner cellScanner) |
void |
HBaseRpcController.setDone(CellScanner cellScanner)
IMPORTANT: always call this method if the call finished without any exception to tell
the
HBaseRpcController that we are done. |
void |
RpcCall.setResponse(org.apache.hbase.thirdparty.com.google.protobuf.Message param,
CellScanner cells,
Throwable errorThrowable,
String error)
Set the response resulting from this RPC call.
|
| Constructor and Description |
|---|
HBaseRpcControllerImpl(CellScanner cellScanner) |
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationSinkService.replicateLogEntries(List<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry> entries,
CellScanner cells,
String replicationClusterId,
String sourceBaseNamespaceDirPath,
String sourceHFileArchiveDirPath)
Carry on the list of log entries down to the sink
|
| Modifier and Type | Method and Description |
|---|---|
static SingleResponse |
ResponseConverter.getResult(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest request,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse response,
CellScanner cells) |
static Result[] |
ResponseConverter.getResults(CellScanner cellScanner,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse response)
Create Results from the cells using the cells meta data.
|
static MultiResponse |
ResponseConverter.getResults(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse response,
CellScanner cells)
Get the results from a protocol buffer MultiResponse
|
static MultiResponse |
ResponseConverter.getResults(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request,
Map<Integer,Integer> rowMutationsIndexMap,
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse response,
CellScanner cells)
Get the results from a protocol buffer MultiResponse
|
static Append |
ProtobufUtil.toAppend(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to an Append
|
static Delete |
ProtobufUtil.toDelete(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to a Delete
|
static Get |
ProtobufUtil.toGet(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to a Get.
|
static Increment |
ProtobufUtil.toIncrement(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to an Increment
|
static Put |
ProtobufUtil.toPut(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to a Put.
|
static Result |
ProtobufUtil.toResult(org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.Result proto,
CellScanner scanner)
Convert a protocol buffer Result to a client Result
|
| Modifier and Type | Method and Description |
|---|---|
static List<WALSplitter.MutationReplay> |
WALSplitter.getMutationsFromWALEntry(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.WALEntry entry,
CellScanner cells,
Pair<WALKey,WALEdit> logEntry,
Durability durability)
This function is used to construct mutations from a WALEntry.
|
Copyright © 2007–2022 The Apache Software Foundation. All rights reserved.