Package | Description |
---|---|
org.apache.hadoop.hbase | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
Modifier and Type | Method and Description |
---|---|
private static Scan |
AsyncMetaTableAccessor.getMetaScan(AsyncTable<?> metaTable,
int rowUpperLimit) |
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,
TableName tableName)
Used to get all region locations for the specific table
|
private static CompletableFuture<List<Pair<RegionInfo,ServerName>>> |
AsyncMetaTableAccessor.getTableRegionsAndLocations(AsyncTable<AdvancedScanResultConsumer> metaTable,
TableName tableName,
boolean excludeOfflinedSplitParents)
Used to get table regions' info and server.
|
static CompletableFuture<Optional<TableState>> |
AsyncMetaTableAccessor.getTableState(AsyncTable<?> metaTable,
TableName tableName) |
private static CompletableFuture<Void> |
AsyncMetaTableAccessor.scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable,
byte[] startRow,
byte[] stopRow,
MetaTableAccessor.QueryType type,
int maxRows,
MetaTableAccessor.Visitor visitor)
Performs a scan of META table for given table.
|
private static CompletableFuture<Void> |
AsyncMetaTableAccessor.scanMeta(AsyncTable<AdvancedScanResultConsumer> metaTable,
TableName tableName,
MetaTableAccessor.QueryType type,
MetaTableAccessor.Visitor visitor)
Performs a scan of META table for given table.
|
static CompletableFuture<Boolean> |
AsyncMetaTableAccessor.tableExists(AsyncTable<?> metaTable,
TableName tableName) |
Modifier and Type | Class and Description |
---|---|
(package private) class |
AsyncTableImpl
Just a wrapper of
RawAsyncTableImpl . |
(package private) class |
RawAsyncTableImpl
The implementation of RawAsyncTable.
|
Modifier and Type | Field and Description |
---|---|
private AsyncTable<AdvancedScanResultConsumer> |
RawAsyncHBaseAdmin.metaTable |
private AsyncTable<?> |
AsyncBufferedMutatorImpl.table |
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. |
Constructor and Description |
---|
AsyncBufferedMutatorImpl(org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer periodicalFlushTimer,
AsyncTable<?> table,
long writeBufferSize,
long periodicFlushTimeoutNs,
int maxKeyValueSize) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.