Modifier and Type | Method and Description |
---|---|
default AsyncConnection |
Server.getAsyncConnection()
Returns a reference to the servers' async connection.
|
Modifier and Type | Interface and Description |
---|---|
interface |
AsyncClusterConnection
The asynchronous connection for internal usage.
|
Modifier and Type | Class and Description |
---|---|
(package private) class |
AsyncClusterConnectionImpl
The implementation of AsyncClusterConnection.
|
class |
AsyncConnectionImpl
The implementation of AsyncConnection.
|
class |
SharedAsyncConnection
Wraps a
AsyncConnection to make it can't be closed. |
Modifier and Type | Field and Description |
---|---|
private AsyncConnection |
SharedAsyncConnection.conn |
Modifier and Type | Method and Description |
---|---|
AsyncConnection |
SharedConnection.toAsyncConnection() |
AsyncConnection |
Connection.toAsyncConnection()
Convert this connection to an
AsyncConnection . |
AsyncConnection |
ConnectionOverAsyncConnection.toAsyncConnection() |
Modifier and Type | Method and Description |
---|---|
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection()
Call
ConnectionFactory.createAsyncConnection(Configuration) using default HBaseConfiguration. |
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection(org.apache.hadoop.conf.Configuration conf)
Call
ConnectionFactory.createAsyncConnection(Configuration, User) using the given conf and a
User object created by UserProvider . |
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection(org.apache.hadoop.conf.Configuration conf,
User user)
Create a new AsyncConnection instance using the passed
conf and user . |
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection(org.apache.hadoop.conf.Configuration conf,
User user,
Map<String,byte[]> connectionAttributes)
Create a new AsyncConnection instance using the passed
conf and user . |
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection(URI connectionUri)
Call
ConnectionFactory.createAsyncConnection(URI, Configuration) using default HBaseConfiguration. |
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection(URI connectionUri,
org.apache.hadoop.conf.Configuration conf)
Call
ConnectionFactory.createAsyncConnection(Configuration, User) using the given connectionUri ,
conf and a User object created by UserProvider . |
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection(URI connectionUri,
org.apache.hadoop.conf.Configuration conf,
User user)
Create a new AsyncConnection instance using the passed
connectionUri , conf and
user . |
static CompletableFuture<AsyncConnection> |
ConnectionFactory.createAsyncConnection(URI connectionUri,
org.apache.hadoop.conf.Configuration conf,
User user,
Map<String,byte[]> connectionAttributes)
Create a new AsyncConnection instance using the passed
connectionUri , conf and
user . |
Constructor and Description |
---|
SharedAsyncConnection(AsyncConnection conn) |
Modifier and Type | Field and Description |
---|---|
private AsyncConnection |
HttpProxyExample.conn |
private AsyncConnection |
HttpProxyExample.RequestHandler.conn |
Modifier and Type | Field and Description |
---|---|
private AtomicReference<CompletableFuture<AsyncConnection>> |
AsyncClientExample.future |
Modifier and Type | Method and Description |
---|---|
private CompletableFuture<AsyncConnection> |
AsyncClientExample.getConn() |
Constructor and Description |
---|
RequestHandler(AsyncConnection conn,
org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup channelGroup) |
Modifier and Type | Field and Description |
---|---|
private AsyncConnection |
MetaBrowser.connection |
Constructor and Description |
---|
MetaBrowser(AsyncConnection connection,
javax.servlet.http.HttpServletRequest request) |
Modifier and Type | Field and Description |
---|---|
private AsyncConnection |
SecureBulkLoadManager.conn |
Constructor and Description |
---|
SecureBulkLoadManager(org.apache.hadoop.conf.Configuration conf,
AsyncConnection conn) |
Modifier and Type | Method and Description |
---|---|
void |
WALEntrySinkFilter.init(AsyncConnection conn)
Called after Construction.
|
Modifier and Type | Method and Description |
---|---|
static CompletableFuture<org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier>> |
TokenUtil.obtainToken(AsyncConnection conn)
Deprecated.
External users should not use this method. Please post on the HBase dev mailing
list if you need this method. Internal HBase code should use
ClientTokenUtil instead. |
static CompletableFuture<org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier>> |
ClientTokenUtil.obtainToken(AsyncConnection conn)
Obtain and return an authentication token for the current user.
|
Modifier and Type | Method and Description |
---|---|
AsyncConnection |
ThriftConnection.toAsyncConnection() |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.