public static class TestTableInputFormat.ExampleTIF extends TableInputFormatBase
MAPREDUCE_INPUT_AUTOBALANCE, MAX_AVERAGE_REGION_SIZE, NUM_MAPPERS_PER_REGION
Constructor and Description |
---|
ExampleTIF() |
Modifier and Type | Method and Description |
---|---|
protected void |
initialize(JobContext job)
Handle subclass specific set up.
|
calculateAutoBalancedSplits, closeTable, createNInputSplitsUniform, createRecordReader, getAdmin, getRegionLocator, getScan, getSplits, getStartEndKeys, getTable, includeRegionInSplit, initializeTable, setScan, setTableRecordReader
protected void initialize(JobContext job) throws java.io.IOException
TableInputFormatBase
TableInputFormatBase.createRecordReader(InputSplit, TaskAttemptContext)
and TableInputFormatBase.getSplits(JobContext)
,
will call TableInputFormatBase.initialize(JobContext)
as a convenient centralized location to handle
retrieving the necessary configuration information and calling
TableInputFormatBase.initializeTable(Connection, TableName)
.
Subclasses should implement their initialize call such that it is safe to call multiple times.
The current TableInputFormatBase implementation relies on a non-null table reference to decide
if an initialize call is needed, but this behavior may change in the future. In particular,
it is critical that initializeTable not be called multiple times since this will leak
Connection instances.initialize
in class TableInputFormatBase
java.io.IOException