com.alicloud.tablestore.hbase

Class TablestoreConnection

java.lang.Object

com.alicloud.tablestore.hbase.TablestoreConnection

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.Abortable, org.apache.hadoop.hbase.client.Connection

public class TablestoreConnection
extends Object
implements org.apache.hadoop.hbase.client.Connection

Constructor Summary

Constructors

Constructor and Description
TablestoreConnection(org.apache.hadoop.conf.Configuration conf)
TablestoreConnection(org.apache.hadoop.conf.Configuration conf, boolean managed, ExecutorService pool, org.apache.hadoop.hbase.security.User user)
TablestoreConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, org.apache.hadoop.hbase.security.User user)
TablestoreConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService pool, org.apache.hadoop.hbase.security.User user, Map<String,byte[]> connectionAttributes)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e)
void	clearRegionLocationCache()
void	close()
org.apache.hadoop.hbase.client.Admin	getAdmin()
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutatorParams params)
org.apache.hadoop.hbase.client.BufferedMutator	getBufferedMutator(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.client.RegionLocator	getRegionLocator(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.Table	getTable(org.apache.hadoop.hbase.TableName tableName)
org.apache.hadoop.hbase.client.Table	getTable(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
org.apache.hadoop.hbase.client.TableBuilder	getTableBuilder(org.apache.hadoop.hbase.TableName tableName, ExecutorService pool)
com.alicloud.tablestore.adaptor.client.TablestoreClientConf	getTablestoreConf()
boolean	isAborted()
boolean	isClosed()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hadoop.hbase.client.Connection

getClusterId, getHbck, getHbck

Methods inherited from interface org.apache.hadoop.hbase.Abortable

abort

Constructor Detail

TablestoreConnection

public TablestoreConnection(org.apache.hadoop.conf.Configuration conf)
                     throws IOException

Throws:

IOException

TablestoreConnection

public TablestoreConnection(org.apache.hadoop.conf.Configuration conf,
                            boolean managed,
                            ExecutorService pool,
                            org.apache.hadoop.hbase.security.User user)

TablestoreConnection

public TablestoreConnection(org.apache.hadoop.conf.Configuration conf,
                            ExecutorService pool,
                            org.apache.hadoop.hbase.security.User user)

TablestoreConnection

public TablestoreConnection(org.apache.hadoop.conf.Configuration conf,
                            ExecutorService pool,
                            org.apache.hadoop.hbase.security.User user,
                            Map<String,byte[]> connectionAttributes)

Method Detail

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Specified by:

getConfiguration in interface org.apache.hadoop.hbase.client.Connection

getTablestoreConf

public com.alicloud.tablestore.adaptor.client.TablestoreClientConf getTablestoreConf()

getTable

public org.apache.hadoop.hbase.client.Table getTable(org.apache.hadoop.hbase.TableName tableName)
                                              throws IOException

Specified by:

getTable in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getAdmin

public org.apache.hadoop.hbase.client.Admin getAdmin()
                                              throws IOException

Specified by:

getAdmin in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getTable

public org.apache.hadoop.hbase.client.Table getTable(org.apache.hadoop.hbase.TableName tableName,
                                                     ExecutorService pool)
                                              throws IOException

Specified by:

getTable in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getTableBuilder

public org.apache.hadoop.hbase.client.TableBuilder getTableBuilder(org.apache.hadoop.hbase.TableName tableName,
                                                                   ExecutorService pool)

Specified by:

getTableBuilder in interface org.apache.hadoop.hbase.client.Connection

getBufferedMutator

public org.apache.hadoop.hbase.client.BufferedMutator getBufferedMutator(org.apache.hadoop.hbase.TableName tableName)
                                                                  throws IOException

Specified by:

getBufferedMutator in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getBufferedMutator

public org.apache.hadoop.hbase.client.BufferedMutator getBufferedMutator(org.apache.hadoop.hbase.client.BufferedMutatorParams params)
                                                                  throws IOException

Specified by:

getBufferedMutator in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

getRegionLocator

public org.apache.hadoop.hbase.client.RegionLocator getRegionLocator(org.apache.hadoop.hbase.TableName tableName)
                                                              throws IOException

Specified by:

getRegionLocator in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

clearRegionLocationCache

public void clearRegionLocationCache()

Specified by:

clearRegionLocationCache in interface org.apache.hadoop.hbase.client.Connection

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.hadoop.hbase.client.Connection

Throws:

IOException

isClosed

public boolean isClosed()

Specified by:

isClosed in interface org.apache.hadoop.hbase.client.Connection

abort

public void abort(String why,
                  Throwable e)

Specified by:

abort in interface org.apache.hadoop.hbase.Abortable

isAborted

public boolean isAborted()

Specified by:

isAborted in interface org.apache.hadoop.hbase.Abortable