org.apache.hadoop.hbase.client
Class BigtableAsyncRegistry
- java.lang.Object
-
- org.apache.hadoop.hbase.client.BigtableAsyncRegistry
-
public class BigtableAsyncRegistry extends Object
Bigtable implementation ofAsyncRegistry
. The default Habse 2 implementation provided byZKAsyncRegistry
assumes a ZooKeeper environment, which is not the case for Bigtable.This class is injected via the system property: "hbase.client.registry.impl" For further details See
AsyncRegistryFactory.REGISTRY_IMPL_CONF_KEY
, andConnectionFactory.createAsyncConnection()
- Author:
- spollapally
-
-
Constructor Summary
Constructors Constructor and Description BigtableAsyncRegistry(org.apache.hadoop.conf.Configuration conf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method and Description void
close()
CompletableFuture<String>
getClusterId()
A non null return value is required for successful creation of asyncConnection.CompletableFuture<Integer>
getCurrentNrHRS()
CompletableFuture<ServerName>
getMasterAddress()
CompletableFuture<Integer>
getMasterInfoPort()
CompletableFuture<RegionLocations>
getMetaRegionLocation()
-
-
-
Constructor Detail
-
BigtableAsyncRegistry
public BigtableAsyncRegistry(org.apache.hadoop.conf.Configuration conf)
-
-
Method Detail
-
close
public void close()
-
getClusterId
public CompletableFuture<String> getClusterId()
A non null return value is required for successful creation of asyncConnection. seeConnectionFactory.createAsyncConnection()
-
getCurrentNrHRS
public CompletableFuture<Integer> getCurrentNrHRS()
-
getMasterAddress
public CompletableFuture<ServerName> getMasterAddress()
-
getMasterInfoPort
public CompletableFuture<Integer> getMasterInfoPort()
-
getMetaRegionLocation
public CompletableFuture<RegionLocations> getMetaRegionLocation()
-
-