org.apache.hadoop.hbase.mapreduce

Class TestTableInputFormat.ExampleTIF

java.lang.Object

<any>

org.apache.hadoop.hbase.mapreduce.TableInputFormatBase

org.apache.hadoop.hbase.mapreduce.TestTableInputFormat.ExampleTIF

Enclosing class:

TestTableInputFormat

public static class TestTableInputFormat.ExampleTIF
extends TableInputFormatBase

Field Summary

Fields inherited from class org.apache.hadoop.hbase.mapreduce.TableInputFormatBase

INPUT_AUTOBALANCE_MAXSKEWRATIO, MAPREDUCE_INPUT_AUTOBALANCE, TABLE_ROW_TEXTKEY

Constructor Summary

Constructors

Constructor and Description
ExampleTIF()

Method Summary

Modifier and Type	Method and Description
protected void	initialize(JobContext job) Handle subclass specific set up.

Methods inherited from class org.apache.hadoop.hbase.mapreduce.TableInputFormatBase

calculateRebalancedSplits, closeTable, createRecordReader, getAdmin, getHTable, getRegionLocator, getScan, getSplitKey, getSplits, getStartEndKeys, getTable, includeRegionInSplit, initializeTable, reverseDNS, setHTable, setScan, setTableRecordReader

Methods inherited from class java.lang.Object

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

Constructor Detail

ExampleTIF

public ExampleTIF()

Method Detail

initialize

protected void initialize(JobContext job)
                   throws IOException

Description copied from class: TableInputFormatBase

Handle subclass specific set up. Each of the entry points used by the MapReduce framework, 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.

Overrides:

initialize in class TableInputFormatBase

Throws:

IOException