public static class TestMultiTableInputFormatBase.MRSplitsConnection
extends java.lang.Object
| Modifier and Type | Method and Description |
|---|---|
void |
abort(java.lang.String why,
java.lang.Throwable e) |
void |
close() |
Admin |
getAdmin() |
BufferedMutator |
getBufferedMutator(BufferedMutatorParams params) |
BufferedMutator |
getBufferedMutator(TableName tableName) |
Configuration |
getConfiguration() |
RegionLocator |
getRegionLocator(TableName tableName) |
Table |
getTable(TableName tableName) |
TableBuilder |
getTableBuilder(TableName tableName,
java.util.concurrent.ExecutorService pool) |
boolean |
isAborted() |
boolean |
isClosed() |
public void abort(java.lang.String why,
java.lang.Throwable e)
public boolean isAborted()
public Configuration getConfiguration()
public BufferedMutator getBufferedMutator(TableName tableName)
throws java.io.IOException
java.io.IOExceptionpublic BufferedMutator getBufferedMutator(BufferedMutatorParams params)
throws java.io.IOException
java.io.IOExceptionpublic RegionLocator getRegionLocator(TableName tableName)
throws java.io.IOException
java.io.IOExceptionpublic Admin getAdmin()
throws java.io.IOException
java.io.IOExceptionpublic Table getTable(TableName tableName)
throws java.io.IOException
java.io.IOExceptionpublic void close()
throws java.io.IOException
java.io.IOExceptionpublic boolean isClosed()
public TableBuilder getTableBuilder(TableName tableName,
java.util.concurrent.ExecutorService pool)