Package | Description |
---|---|
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.rest.client | |
org.apache.hadoop.hbase.util |
Modifier and Type | Class and Description |
---|---|
class |
Append
Performs Append operations on a single row.
|
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 |
---|---|
static Comparator<Row> |
Row.COMPARATOR |
Modifier and Type | Method and Description |
---|---|
Row |
Action.getAction() |
Row |
RetriesExhaustedWithDetailsException.getRow(int i) |
Modifier and Type | Method and Description |
---|---|
List<? extends Row> |
AsyncRequestFuture.getFailedOperations() |
RowAccess<? extends Row> |
AsyncProcessTask.getRowAccess() |
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) |
int |
RowMutations.compareTo(Row i)
Deprecated.
As of release 2.0.0, this will be removed in HBase 3.0.0.
Use
COMPARATOR instead |
int |
Mutation.compareTo(Row d)
Deprecated.
As of release 2.0.0, this will be removed in HBase 3.0.0.
Use
COMPARATOR instead |
int |
Row.compareTo(Row var1)
Deprecated.
As of release 2.0.0, this will be removed in HBase 3.0.0.
Use
COMPARATOR instead |
int |
Get.compareTo(Row other) |
Modifier and Type | Method and Description |
---|---|
<T> List<CompletableFuture<T>> |
AsyncTable.batch(List<? extends Row> actions)
Method that does a batch call on Deletes, Gets, Puts, Increments, Appends and RowMutations.
|
void |
HTable.batch(List<? extends Row> actions,
Object[] results) |
default void |
Table.batch(List<? extends Row> actions,
Object[] results)
Method that does a batch call on Deletes, Gets, Puts, Increments, Appends, RowMutations.
|
void |
HTable.batch(List<? extends Row> actions,
Object[] results,
int rpcTimeout) |
default <T> CompletableFuture<List<T>> |
AsyncTable.batchAll(List<? extends Row> actions)
A simple version of batch.
|
<R> void |
HTable.batchCallback(List<? extends Row> actions,
Object[] results,
Batch.Callback<R> callback) |
default <R> void |
Table.batchCallback(List<? extends Row> actions,
Object[] results,
Batch.Callback<R> callback)
Same as
Table.batch(List, Object[]) , but with a callback. |
static <R> void |
HTable.doBatchWithCallback(List<? extends Row> actions,
Object[] results,
Batch.Callback<R> callback,
ClusterConnection connection,
ExecutorService pool,
TableName tableName) |
static String |
RetriesExhaustedWithDetailsException.getDesc(List<Throwable> exceptions,
List<? extends Row> actions,
List<String> hostnamePort) |
<R> void |
HTable.processBatchCallback(List<? extends Row> list,
Object[] results,
Batch.Callback<R> callback)
Process a mixed batch of Get, Put and Delete actions.
|
AsyncProcessTask.Builder<T> |
AsyncProcessTask.Builder.setRowAccess(List<? extends Row> rows) |
AsyncProcessTask.Builder<T> |
AsyncProcessTask.Builder.setRowAccess(RowAccess<? extends Row> rows) |
Constructor and Description |
---|
Action(Row action,
int originalIndex) |
Action(Row action,
int originalIndex,
int priority) |
Constructor and Description |
---|
RetriesExhaustedWithDetailsException(List<Throwable> exceptions,
List<Row> actions,
List<String> hostnameAndPort) |
Modifier and Type | Method and Description |
---|---|
protected void |
ReplicationSink.batch(TableName tableName,
Collection<List<Row>> allRows)
Do the changes and handle the pool
|
Modifier and Type | Method and Description |
---|---|
void |
RemoteHTable.batch(List<? extends Row> actions,
Object[] results) |
<R> void |
RemoteHTable.batchCallback(List<? extends Row> actions,
Object[] results,
Batch.Callback<R> callback) |
Modifier and Type | Method and Description |
---|---|
<R> void |
MultiHConnection.processBatchCallback(List<? extends Row> actions,
TableName tableName,
Object[] results,
Batch.Callback<R> callback)
Randomly pick a connection and process the batch of actions for a given table
|
Copyright © 2007–2019 Cloudera. All rights reserved.