Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.client.coprocessor |
Provides client classes for invoking Coprocessor RPC protocols
Overview
Example Usage
|
Modifier and Type | Method and Description |
---|---|
static CompletableFuture<Optional<HRegionLocation>> |
AsyncMetaTableAccessor.getRegionLocation(AsyncTable<?> metaTable,
byte[] regionName)
Returns the HRegionLocation from meta for the given region
|
static CompletableFuture<Optional<HRegionLocation>> |
AsyncMetaTableAccessor.getRegionLocationWithEncodedName(AsyncTable<?> metaTable,
byte[] encodedRegionName)
Returns the HRegionLocation from meta for the given encoded region name
|
static CompletableFuture<List<HRegionLocation>> |
AsyncMetaTableAccessor.getTableHRegionLocations(AsyncTable<AdvancedScanResultConsumer> metaTable,
Optional<TableName> tableName)
Used to get all region locations for the specific table.
|
static CompletableFuture<Optional<TableState>> |
AsyncMetaTableAccessor.getTableState(AsyncTable<?> metaTable,
TableName tableName) |
static CompletableFuture<Boolean> |
AsyncMetaTableAccessor.tableExists(AsyncTable<?> metaTable,
TableName tableName) |
Modifier and Type | Method and Description |
---|---|
AsyncTable<C> |
AsyncTableBuilder.build()
Create the
AsyncTable instance. |
default AsyncTable<AdvancedScanResultConsumer> |
AsyncConnection.getTable(TableName tableName)
Retrieve an
AsyncTable implementation for accessing a table. |
default AsyncTable<ScanResultConsumer> |
AsyncConnection.getTable(TableName tableName,
ExecutorService pool)
Retrieve an
AsyncTable implementation for accessing a table. |
Modifier and Type | Method and Description |
---|---|
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> |
AsyncAggregationClient.avg(AsyncTable<?> table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan) |
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> |
AsyncAggregationClient.max(AsyncTable<?> table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan) |
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> |
AsyncAggregationClient.median(AsyncTable<AdvancedScanResultConsumer> table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan) |
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> |
AsyncAggregationClient.min(AsyncTable<?> table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan) |
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> |
AsyncAggregationClient.rowCount(AsyncTable<?> table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan) |
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> |
AsyncAggregationClient.std(AsyncTable<?> table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan) |
static <R,S,P extends com.google.protobuf.Message,Q extends com.google.protobuf.Message,T extends com.google.protobuf.Message> |
AsyncAggregationClient.sum(AsyncTable<?> table,
ColumnInterpreter<R,S,P,Q,T> ci,
Scan scan) |
Copyright © 2007–2019 Cloudera. All rights reserved.