Package org.apache.hadoop.hbase.mapreduce

Class TestHFileOutputFormat2.ConfigurationCaptorConnection

java.lang.Object

org.apache.hadoop.hbase.mapreduce.TestHFileOutputFormat2.ConfigurationCaptorConnection

All Implemented Interfaces:

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

Enclosing class:

TestHFileOutputFormat2

private static class TestHFileOutputFormat2.ConfigurationCaptorConnection
extends Object
implements org.apache.hadoop.hbase.client.Connection

Field Summary

Fields

Modifier and Type	Field	Description
private static final Map<UUID,List<org.apache.hadoop.conf.Configuration>>	confs
private final org.apache.hadoop.hbase.client.Connection	delegate
private static final String	UUID_KEY

Constructor Summary

Constructors

Constructor	Description
ConfigurationCaptorConnection(org.apache.hadoop.conf.Configuration conf, ExecutorService es, org.apache.hadoop.hbase.security.User user, org.apache.hadoop.hbase.client.ConnectionRegistry registry, Map<String,byte[]> connectionAttributes)

Method Summary

Modifier and Type	Method	Description
void	abort(String why, Throwable e)
void	clearRegionLocationCache()
void	close()
(package private) static UUID	configureConnectionImpl(org.apache.hadoop.conf.Configuration conf)
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)
(package private) static List<org.apache.hadoop.conf.Configuration>	getCapturedConfigarutions(UUID key)
String	getClusterId()
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.client.Hbck	getHbck()
org.apache.hadoop.hbase.client.Hbck	getHbck(org.apache.hadoop.hbase.ServerName masterServer)
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)
boolean	isAborted()
boolean	isClosed()
org.apache.hadoop.hbase.client.AsyncConnection	toAsyncConnection()

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.Abortable

abort

Field Details

UUID_KEY

private static final String UUID_KEY

See Also:

• Constant Field Values

confs

private static final Map<UUID,List<org.apache.hadoop.conf.Configuration>> confs

delegate

private final org.apache.hadoop.hbase.client.Connection delegate

Constructor Details

ConfigurationCaptorConnection

public ConfigurationCaptorConnection(org.apache.hadoop.conf.Configuration conf,
 ExecutorService es,
 org.apache.hadoop.hbase.security.User user,
 org.apache.hadoop.hbase.client.ConnectionRegistry registry,
 Map<String,byte[]> connectionAttributes)
                              throws IOException

Throws:

IOException

Method Details

configureConnectionImpl

static UUID configureConnectionImpl(org.apache.hadoop.conf.Configuration conf)

getCapturedConfigarutions

static List<org.apache.hadoop.conf.Configuration> getCapturedConfigarutions(UUID key)

getConfiguration

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

Specified by:

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

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

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

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

getAdmin

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

Specified by:

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

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

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

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

toAsyncConnection

public org.apache.hadoop.hbase.client.AsyncConnection toAsyncConnection()

Specified by:

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

getClusterId

public String getClusterId()

Specified by:

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

getHbck

public org.apache.hadoop.hbase.client.Hbck getHbck()
                                            throws IOException

Specified by:

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

Throws:

IOException

getHbck

public org.apache.hadoop.hbase.client.Hbck getHbck(org.apache.hadoop.hbase.ServerName masterServer)
                                            throws IOException

Specified by:

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

Throws:

IOException

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