| Package | Description |
|---|---|
| org.apache.hadoop.hbase | |
| org.apache.hadoop.hbase.client |
Provides HBase Client
|
| org.apache.hadoop.hbase.codec | |
| org.apache.hadoop.hbase.codec.prefixtree.decode | |
| org.apache.hadoop.hbase.codec.prefixtree.scanner | |
| org.apache.hadoop.hbase.io | |
| org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
| org.apache.hadoop.hbase.protobuf |
Holds classes generated from protobuf
src/main/protobuf definition files. |
| org.apache.hadoop.hbase.regionserver | |
| org.apache.hadoop.hbase.regionserver.wal | |
| org.apache.hadoop.hbase.replication.regionserver |
| 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() |
| Modifier and Type | Interface and Description |
|---|---|
static interface |
Codec.Decoder
Implementations should implicitly clean up any resources allocated when the
Decoder/CellScanner runs off the end of the cell block.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BaseDecoder
TODO javadoc
|
static class |
KeyValueCodec.KeyValueDecoder |
static class |
KeyValueCodecWithTags.KeyValueDecoder |
| Modifier and Type | Class and Description |
|---|---|
class |
PrefixTreeArrayReversibleScanner
Methods for going backwards through a PrefixTree block.
|
class |
PrefixTreeArrayScanner
Extends PtCell and manipulates its protected fields.
|
class |
PrefixTreeArraySearcher
Searcher extends the capabilities of the Scanner + ReversibleScanner to add the ability to
position itself on a requested Cell without scanning through cells before it.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CellSearcher
Methods for seeking to a random
Cell inside a sorted collection of cells. |
interface |
ReversibleCellScanner
An extension of CellScanner indicating the scanner supports iterating backwards through cells.
|
| 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 |
DelegatingPayloadCarryingRpcController.cellScanner() |
CellScanner |
PayloadCarryingRpcController.cellScanner() |
| Modifier and Type | Method and Description |
|---|---|
Pair<com.google.protobuf.Message,CellScanner> |
RpcServer.call(com.google.protobuf.BlockingService service,
com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status)
This is a server side method, which is invoked over RPC.
|
Pair<com.google.protobuf.Message,CellScanner> |
RpcServerInterface.call(com.google.protobuf.BlockingService service,
com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status) |
| Modifier and Type | Method and Description |
|---|---|
Pair<com.google.protobuf.Message,CellScanner> |
RpcServer.call(com.google.protobuf.BlockingService service,
com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status)
This is a server side method, which is invoked over RPC.
|
Pair<com.google.protobuf.Message,CellScanner> |
RpcServerInterface.call(com.google.protobuf.BlockingService service,
com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status) |
PayloadCarryingRpcController |
RpcControllerFactory.newController(CellScanner cellScanner) |
void |
DelegatingPayloadCarryingRpcController.setCellScanner(CellScanner cellScanner) |
void |
PayloadCarryingRpcController.setCellScanner(CellScanner cellScanner) |
void |
RpcClient.Call.setResponse(com.google.protobuf.Message response,
CellScanner cells)
Set the return value when there is no error.
|
| Constructor and Description |
|---|
PayloadCarryingRpcController(CellScanner cellScanner) |
RpcClient.Call(com.google.protobuf.Descriptors.MethodDescriptor md,
com.google.protobuf.Message param,
CellScanner cells,
com.google.protobuf.Message responseDefaultType) |
| Modifier and Type | Method and Description |
|---|---|
static Pair<AdminProtos.ReplicateWALEntryRequest,CellScanner> |
ReplicationProtbufUtil.buildReplicateWALEntryRequest(HLog.Entry[] entries)
Create a new ReplicateWALEntryRequest from a list of HLog entries
|
| Modifier and Type | Method and Description |
|---|---|
static Result[] |
ResponseConverter.getResults(CellScanner cellScanner,
ClientProtos.ScanResponse response)
Create Results from the cells using the cells meta data.
|
static MultiResponse |
ResponseConverter.getResults(ClientProtos.MultiRequest request,
ClientProtos.MultiResponse response,
CellScanner cells)
Get the results from a protocol buffer MultiResponse
|
static Append |
ProtobufUtil.toAppend(ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to an Append
|
static Delete |
ProtobufUtil.toDelete(ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to a Delete
|
static Increment |
ProtobufUtil.toIncrement(ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to an Increment
|
static Put |
ProtobufUtil.toPut(ClientProtos.MutationProto proto,
CellScanner cellScanner)
Convert a protocol buffer Mutate to a Put.
|
static Result |
ProtobufUtil.toResult(ClientProtos.Result proto,
CellScanner scanner)
Convert a protocol buffer Result to a client Result
|
| Modifier and Type | Method and Description |
|---|---|
protected Result |
HRegionServer.append(HRegion region,
ClientProtos.MutationProto m,
CellScanner cellScanner,
long nonceGroup)
Execute an append mutation.
|
protected void |
HRegionServer.doBatchOp(ClientProtos.RegionActionResult.Builder builder,
HRegion region,
List<ClientProtos.Action> mutations,
CellScanner cells)
Execute a list of Put/Delete mutations.
|
protected Result |
HRegionServer.increment(HRegion region,
ClientProtos.MutationProto mutation,
CellScanner cells,
long nonceGroup)
Execute an increment mutation.
|
protected void |
HRegionServer.mutateRows(HRegion region,
List<ClientProtos.Action> actions,
CellScanner cellScanner)
Mutate a list of rows atomically.
|
void |
ReplicationSinkService.replicateLogEntries(List<AdminProtos.WALEntry> entries,
CellScanner cells)
Carry on the list of log entries down to the sink
|
| Modifier and Type | Method and Description |
|---|---|
static List<HLogSplitter.MutationReplay> |
HLogSplitter.getMutationsFromWALEntry(AdminProtos.WALEntry entry,
CellScanner cells,
Pair<HLogKey,WALEdit> logEntry,
boolean addLogReplayTag)
This function is used to construct mutations from a WALEntry.
|
| Modifier and Type | Method and Description |
|---|---|
void |
ReplicationSink.replicateEntries(List<AdminProtos.WALEntry> entries,
CellScanner cells)
Replicate this array of entries directly into the local cluster using the native client.
|
void |
Replication.replicateLogEntries(List<AdminProtos.WALEntry> entries,
CellScanner cells)
Carry on the list of log entries down to the sink
|
Copyright © 2014 The Apache Software Foundation. All rights reserved.