Uses of Interface
org.apache.hadoop.hbase.client.AsyncConnection
Package
Description
Provides HBase Client
-
Uses of AsyncConnection in org.apache.hadoop.hbase
Modifier and TypeFieldDescriptionprotected AsyncConnection
PerformanceEvaluation.AsyncTest.connection
Modifier and TypeMethodDescriptiondefault AsyncConnection
Server.getAsyncConnection()
Returns a reference to the servers' async connection.Modifier and TypeMethodDescription(package private) static PerformanceEvaluation.RunResult
PerformanceEvaluation.runOneClient
(Class<? extends PerformanceEvaluation.TestBase> cmd, org.apache.hadoop.conf.Configuration conf, Connection con, AsyncConnection asyncCon, PerformanceEvaluation.TestOptions opts, PerformanceEvaluation.Status status) ModifierConstructorDescription(package private)
AsyncRandomReadTest
(AsyncConnection con, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) (package private)
AsyncRandomWriteTest
(AsyncConnection con, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) (package private)
AsyncScanTest
(AsyncConnection con, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) (package private)
AsyncSequentialReadTest
(AsyncConnection con, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) (package private)
AsyncSequentialWriteTest
(AsyncConnection con, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) (package private)
AsyncTableTest
(AsyncConnection con, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) (package private)
AsyncTest
(AsyncConnection con, PerformanceEvaluation.TestOptions options, PerformanceEvaluation.Status status) -
Uses of AsyncConnection in org.apache.hadoop.hbase.client
Modifier and TypeInterfaceDescriptioninterface
The asynchronous connection for internal usage.Modifier and TypeClassDescription(package private) class
The implementation of AsyncClusterConnection.class
The implementation of AsyncConnection.class
Wraps aAsyncConnection
to make it can't be closed.Modifier and TypeMethodDescriptionConnection.toAsyncConnection()
Convert this connection to anAsyncConnection
.ConnectionOverAsyncConnection.toAsyncConnection()
SharedConnection.toAsyncConnection()
Modifier and TypeMethodDescriptionstatic CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection()
CallConnectionFactory.createAsyncConnection(Configuration)
using default HBaseConfiguration.static CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(URI connectionUri) CallConnectionFactory.createAsyncConnection(URI, Configuration)
using default HBaseConfiguration.static CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(URI connectionUri, org.apache.hadoop.conf.Configuration conf) CallConnectionFactory.createAsyncConnection(Configuration, User)
using the givenconnectionUri
,conf
and a User object created byUserProvider
.static CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(URI connectionUri, org.apache.hadoop.conf.Configuration conf, User user) Create a new AsyncConnection instance using the passedconnectionUri
,conf
anduser
.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 passedconnectionUri
,conf
anduser
.static CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(org.apache.hadoop.conf.Configuration conf) CallConnectionFactory.createAsyncConnection(Configuration, User)
using the givenconf
and a User object created byUserProvider
.static CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(org.apache.hadoop.conf.Configuration conf, User user) Create a new AsyncConnection instance using the passedconf
anduser
.static CompletableFuture<AsyncConnection>
ConnectionFactory.createAsyncConnection
(org.apache.hadoop.conf.Configuration conf, User user, Map<String, byte[]> connectionAttributes) Create a new AsyncConnection instance using the passedconf
anduser
. -
Uses of AsyncConnection in org.apache.hadoop.hbase.client.example
Modifier and TypeFieldDescriptionprivate AsyncConnection
HttpProxyExample.conn
private final AsyncConnection
HttpProxyExample.RequestHandler.conn
Modifier and TypeFieldDescriptionprivate final AtomicReference<CompletableFuture<AsyncConnection>>
AsyncClientExample.future
Modifier and TypeMethodDescriptionprivate CompletableFuture<AsyncConnection>
AsyncClientExample.getConn()
ModifierConstructorDescriptionRequestHandler
(AsyncConnection conn, org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup channelGroup) -
Uses of AsyncConnection in org.apache.hadoop.hbase.master.http
ModifierConstructorDescriptionMetaBrowser
(AsyncConnection connection, javax.servlet.http.HttpServletRequest request) -
Uses of AsyncConnection in org.apache.hadoop.hbase.regionserver
ModifierConstructorDescription(package private)
SecureBulkLoadManager
(org.apache.hadoop.conf.Configuration conf, AsyncConnection conn) -
Uses of AsyncConnection in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeMethodDescriptionvoid
WALEntrySinkFilter.init
(AsyncConnection conn) Called after Construction. -
Uses of AsyncConnection in org.apache.hadoop.hbase.security.token
Modifier and TypeMethodDescriptionstatic CompletableFuture<org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier>>
ClientTokenUtil.obtainToken
(AsyncConnection conn) Obtain and return an authentication token for the current user.static CompletableFuture<org.apache.hadoop.security.token.Token<AuthenticationTokenIdentifier>>
TokenUtil.obtainToken
(AsyncConnection conn) Deprecated.External users should not use this method, will be removed in 4.0.0. -
Uses of AsyncConnection in org.apache.hadoop.hbase.thrift2.client