Package | Description |
---|---|
org.apache.hadoop.hbase.backup.example | |
org.apache.hadoop.hbase.catalog | |
org.apache.hadoop.hbase.client |
Provides HBase Client
|
org.apache.hadoop.hbase.ipc |
Tools to help define network clients and servers.
|
org.apache.hadoop.hbase.mapreduce |
Provides HBase MapReduce
Input/OutputFormats, a table indexing MapReduce job, and utility
|
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.replication.regionserver |
Constructor and Description |
---|
ZKTableArchiveClient(org.apache.hadoop.conf.Configuration conf,
HConnection connection) |
Modifier and Type | Method and Description |
---|---|
HConnection |
CatalogTracker.getConnection() |
Constructor and Description |
---|
CatalogTracker(ZooKeeperWatcher zk,
org.apache.hadoop.conf.Configuration conf,
HConnection connection,
Abortable abortable) |
Modifier and Type | Class and Description |
---|---|
class |
CoprocessorHConnection
Connection to an HTable from within a Coprocessor.
|
static class |
HConnectionManager.HConnectionImplementation
Encapsulates connection to zookeeper and regionservers.
|
Modifier and Type | Field and Description |
---|---|
protected HConnection |
RegionServerCallable.connection |
protected HConnection |
HTable.connection |
Modifier and Type | Method and Description |
---|---|
static HConnection |
HConnectionManager.createConnection(org.apache.hadoop.conf.Configuration conf)
Create a new HConnection instance using the passed
conf instance. |
static HConnection |
HConnectionManager.createConnection(org.apache.hadoop.conf.Configuration conf,
ExecutorService pool)
Create a new HConnection instance using the passed
conf instance. |
static HConnection |
HConnectionManager.createConnection(org.apache.hadoop.conf.Configuration conf,
ExecutorService pool,
User user)
Create a new HConnection instance using the passed
conf instance. |
static HConnection |
HConnectionManager.createConnection(org.apache.hadoop.conf.Configuration conf,
User user)
Create a new HConnection instance using the passed
conf instance. |
HConnection |
HBaseAdmin.getConnection() |
HConnection |
HTable.getConnection()
Deprecated.
This method will be changed from public to package protected.
|
protected HConnection |
ClientScanner.getConnection() |
static HConnection |
HConnectionManager.getConnection(org.apache.hadoop.conf.Configuration conf)
Deprecated.
|
static HConnection |
CoprocessorHConnection.getConnectionForEnvironment(CoprocessorEnvironment env)
Create an unmanaged
HConnection based on the environment in which we are running the
coprocessor. |
Modifier and Type | Method and Description |
---|---|
static NavigableMap<HRegionInfo,ServerName> |
MetaScanner.allTableRegions(org.apache.hadoop.conf.Configuration conf,
HConnection connection,
TableName tableName,
boolean offlined)
Lists all of the table regions currently in META.
|
abstract T |
HConnectable.connect(HConnection connection) |
static void |
HConnectionManager.deleteStaleConnection(HConnection connection)
Deprecated.
|
static NonceGenerator |
HConnectionManager.injectNonceGeneratorForTesting(HConnection conn,
NonceGenerator cnm) |
static void |
MetaScanner.metaScan(org.apache.hadoop.conf.Configuration configuration,
HConnection connection,
MetaScanner.MetaScannerVisitor visitor,
TableName userTableName)
Scans the meta table and calls a visitor on each RowResult.
|
static void |
MetaScanner.metaScan(org.apache.hadoop.conf.Configuration configuration,
HConnection connection,
MetaScanner.MetaScannerVisitor visitor,
TableName tableName,
byte[] row,
int rowLimit,
TableName metaTableName)
Scans the meta table and calls a visitor on each RowResult.
|
Constructor and Description |
---|
ClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
byte[] tableName,
HConnection connection)
|
ClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
HConnection connection)
Create a new ClientScanner for the specified table
Note that the passed
Scan 's start row maybe changed changed. |
ClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
HConnection connection,
RpcRetryingCallerFactory rpcFactory)
|
ClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
HConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory)
Create a new ClientScanner for the specified table Note that the passed
Scan 's start
row maybe changed changed. |
ClientSmallReversedScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
HConnection connection)
Create a new ReversibleClientScanner for the specified table Note that the
passed
Scan 's start row maybe changed. |
ClientSmallScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
HConnection connection)
Create a new ClientSmallScanner for the specified table.
|
ClientSmallScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
HConnection connection,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory controllerFactory)
Create a new ShortClientScanner for the specified table Note that the
passed
Scan 's start row maybe changed changed. |
CoprocessorHConnection(HConnection delegate,
HRegionServer server)
Deprecated.
delegate is not used
|
HBaseAdmin(HConnection connection)
Constructor for externally managed HConnections.
|
HTable(byte[] tableName,
HConnection connection,
ExecutorService pool)
Creates an object to access a HBase table.
|
HTable(TableName tableName,
HConnection connection)
Creates an object to access a HBase table.
|
HTable(TableName tableName,
HConnection connection,
ExecutorService pool)
Creates an object to access a HBase table.
|
RegionServerCallable(HConnection connection,
TableName tableName,
byte[] row) |
ReversedClientScanner(org.apache.hadoop.conf.Configuration conf,
Scan scan,
TableName tableName,
HConnection connection)
Create a new ReversibleClientScanner for the specified table Note that the
passed
Scan 's start row maybe changed. |
ReversedScannerCallable(HConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow)
Deprecated.
|
ReversedScannerCallable(HConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
byte[] locateStartRow,
PayloadCarryingRpcController rpcFactory) |
ScannerCallable(HConnection connection,
byte[] tableName,
Scan scan,
ScanMetrics scanMetrics)
|
ScannerCallable(HConnection connection,
TableName tableName,
Scan scan,
ScanMetrics scanMetrics,
PayloadCarryingRpcController controller) |
Constructor and Description |
---|
MasterCoprocessorRpcChannel(HConnection conn) |
RegionCoprocessorRpcChannel(HConnection conn,
TableName table,
byte[] row,
RpcRetryingCallerFactory rpcFactory,
RpcControllerFactory rpcControllerFactory) |
Modifier and Type | Method and Description |
---|---|
protected void |
LoadIncrementalHFiles.bulkLoadPhase(HTable table,
HConnection conn,
ExecutorService pool,
Deque<org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> queue,
com.google.common.collect.Multimap<ByteBuffer,org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> regionGroups)
This takes the LQI's grouped by likely regions and attempts to bulk load
them.
|
protected List<org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> |
LoadIncrementalHFiles.tryAtomicRegionLoad(HConnection conn,
byte[] tableName,
byte[] first,
Collection<org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> lqis)
|
protected List<org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> |
LoadIncrementalHFiles.tryAtomicRegionLoad(HConnection conn,
TableName tableName,
byte[] first,
Collection<org.apache.hadoop.hbase.mapreduce.LoadIncrementalHFiles.LoadQueueItem> lqis)
Attempts to do an atomic load of many hfiles into a region.
|
Constructor and Description |
---|
WALEditsReplaySink(org.apache.hadoop.conf.Configuration conf,
TableName tableName,
HConnection conn)
Create a sink for WAL log entries replay
|
Constructor and Description |
---|
ReplicationSinkManager(HConnection conn,
String peerClusterId,
ReplicationPeers replicationPeers,
org.apache.hadoop.conf.Configuration conf)
Instantiate for a single replication peer cluster.
|
Copyright © 2014 The Apache Software Foundation. All rights reserved.