Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.trace | |
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.thrift2.client |
Modifier and Type | Class and Description |
---|---|
class |
Append
Performs Append operations on a single row.
|
class |
CheckAndMutate
Used to perform CheckAndMutate operations.
|
class |
Delete
Used to perform Delete operations on a single row.
|
class |
Get
Used to perform Get operations on a single row.
|
class |
Increment
Used to perform Increment operations on a single row.
|
class |
Mutation |
class |
Put
Used to perform Put operations for a single row.
|
class |
RegionCoprocessorServiceExec
Represents a coprocessor service method execution against a single region.
|
class |
RowMutations
Performs multiple mutations atomically on a single row.
|
Modifier and Type | Field and Description |
---|---|
private Row |
Action.action |
private Row |
CheckAndMutate.action |
Modifier and Type | Field and Description |
---|---|
(package private) List<Row> |
RetriesExhaustedWithDetailsException.actions |
private List<? extends Row> |
AsyncRpcRetryingCallerFactory.BatchCallerBuilder.actions |
static Comparator<Row> |
Row.COMPARATOR |
Modifier and Type | Method and Description |
---|---|
private <T,R extends OperationWithAttributes & Row> |
RawAsyncTableImpl.newCaller(R row,
long rpcTimeoutNs) |
Modifier and Type | Method and Description |
---|---|
Row |
Action.getAction() |
Row |
CheckAndMutate.getAction()
Returns the action done if check succeeds
|
Row |
RetriesExhaustedWithDetailsException.getRow(int i) |
Modifier and Type | Method and Description |
---|---|
RequestController.ReturnCode |
RequestController.Checker.canTakeRow(HRegionLocation loc,
Row row)
Checks the data whether it is valid to submit.
|
int |
RegionCoprocessorServiceExec.compareTo(Row o) |
private static boolean |
AsyncBatchRpcRetryingCaller.hasIncrementOrAppend(Row action) |
private void |
CheckAndMutate.Builder.preCheck(Row action) |
Modifier and Type | Method and Description |
---|---|
AsyncRpcRetryingCallerFactory.BatchCallerBuilder |
AsyncRpcRetryingCallerFactory.BatchCallerBuilder.actions(List<? extends Row> actions) |
<T> List<CompletableFuture<T>> |
AsyncTableImpl.batch(List<? extends Row> actions) |
<T> List<CompletableFuture<T>> |
AsyncTable.batch(List<? extends Row> actions)
Method that does a batch call on Deletes, Gets, Puts, Increments, Appends and RowMutations.
|
<T> List<CompletableFuture<T>> |
RawAsyncTableImpl.batch(List<? extends Row> actions) |
private <T> List<CompletableFuture<T>> |
RawAsyncTableImpl.batch(List<? extends Row> actions,
long rpcTimeoutNs) |
default void |
Table.batch(List<? extends Row> actions,
Object[] results)
Method that does a batch call on Deletes, Gets, Puts, Increments, Appends, RowMutations.
|
void |
TableOverAsyncTable.batch(List<? extends Row> actions,
Object[] results) |
default <T> CompletableFuture<List<T>> |
AsyncTable.batchAll(List<? extends Row> actions)
A simple version of batch.
|
default <R> void |
Table.batchCallback(List<? extends Row> actions,
Object[] results,
Batch.Callback<R> callback)
Deprecated.
since 3.0.0, will removed in 4.0.0. Please use the batch related methods in
AsyncTable directly if you want to use callback. We reuse the callback for
coprocessor here, and the problem is that for batch operation, the
AsyncTable does not tell us the region, so in this method we need an extra
locating after we get the result, which is not good. |
<R> void |
TableOverAsyncTable.batchCallback(List<? extends Row> actions,
Object[] results,
Batch.Callback<R> callback) |
static String |
RetriesExhaustedWithDetailsException.getDesc(List<Throwable> exceptions,
List<? extends Row> actions,
List<String> hostnamePort) |
private List<CompletableFuture<Void>> |
RawAsyncTableImpl.voidMutate(List<? extends Row> actions) |
Constructor and Description |
---|
Action(Row action,
int originalIndex) |
Action(Row action,
int originalIndex,
int priority) |
CheckAndMutate(byte[] row,
byte[] family,
byte[] qualifier,
CompareOperator op,
byte[] value,
TimeRange timeRange,
Row action) |
CheckAndMutate(byte[] row,
Filter filter,
TimeRange timeRange,
Row action) |
Constructor and Description |
---|
AsyncBatchRpcRetryingCaller(org.apache.hbase.thirdparty.io.netty.util.Timer retryTimer,
AsyncConnectionImpl conn,
TableName tableName,
List<? extends Row> actions,
long pauseNs,
long pauseNsForServerOverloaded,
int maxAttempts,
long operationTimeoutNs,
long rpcTimeoutNs,
int startLogErrorsCnt,
Map<String,byte[]> requestAttributes) |
RetriesExhaustedWithDetailsException(List<Throwable> exceptions,
List<Row> actions,
List<String> hostnameAndPort) |
Modifier and Type | Method and Description |
---|---|
TableOperationSpanBuilder |
TableOperationSpanBuilder.setContainerOperations(Row row) |
TableOperationSpanBuilder |
TableOperationSpanBuilder.setOperation(Row row) |
private static Set<HBaseSemanticAttributes.Operation> |
TableOperationSpanBuilder.unpackRowOperations(Row row) |
private static HBaseSemanticAttributes.Operation |
TableOperationSpanBuilder.valueFrom(Row row) |
Modifier and Type | Method and Description |
---|---|
TableOperationSpanBuilder |
TableOperationSpanBuilder.setContainerOperations(Collection<? extends Row> operations) |
TableOperationSpanBuilder |
TableOperationSpanBuilder.setOperation(Collection<? extends Row> operations) |
Modifier and Type | Field and Description |
---|---|
private org.apache.hbase.thirdparty.com.google.common.collect.ImmutableMap<Class<? extends Row>,MetaTableMetrics.MetaTableOps> |
MetaTableMetrics.opsNameMap |
Modifier and Type | Method and Description |
---|---|
private String |
MetaTableMetrics.ExampleRegionObserverMeta.getRegionIdFromOp(Row op)
Get regionId from Ops such as: get, put, delete.
|
private String |
MetaTableMetrics.ExampleRegionObserverMeta.getTableNameFromOp(Row op)
Get table name from Ops such as: get, put, delete.
|
private void |
MetaTableMetrics.ExampleRegionObserverMeta.opMetricRegisterAndMark(Row op) |
private void |
MetaTableMetrics.ExampleRegionObserverMeta.regionMetricRegisterAndMark(Row op) |
private void |
MetaTableMetrics.ExampleRegionObserverMeta.registerAndMarkMetrics(ObserverContext<RegionCoprocessorEnvironment> e,
Row row) |
private void |
MetaTableMetrics.ExampleRegionObserverMeta.tableMetricRegisterAndMark(Row op) |
Modifier and Type | Method and Description |
---|---|
private void |
HRegion.checkRow(Row action,
byte[] row) |
Modifier and Type | Method and Description |
---|---|
private void |
ReplicationSink.batch(TableName tableName,
Collection<List<Row>> allRows,
int batchRowSizeThreshold)
Do the changes and handle the pool
|
Modifier and Type | Method and Description |
---|---|
void |
ThriftTable.batch(List<? extends Row> actions,
Object[] results) |
<R> void |
ThriftTable.batchCallback(List<? extends Row> actions,
Object[] results,
Batch.Callback<R> callback) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.