org.apache.hadoop.hbase.mapred

Class TestTableInputFormat.ExampleTIF

java.lang.Object

org.apache.hadoop.hbase.mapred.TableInputFormatBase

org.apache.hadoop.hbase.mapred.TestTableInputFormat.ExampleTIF

Direct Known Subclasses:

TestTableInputFormat.ExampleJobConfigurableTIF

Enclosing class:

TestTableInputFormat

public static class TestTableInputFormat.ExampleTIF
extends TableInputFormatBase

Constructor Summary

Constructors

Constructor and Description
ExampleTIF()

Method Summary

Modifier and Type	Method and Description
protected void	initialize(JobConf job) Handle subclass specific set up.
protected void	initialize(JobConf job, String table)

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

closeTable, getHTable, getRecordReader, getSplits, getTable, initializeTable, setHTable, setInputColumns, setRowFilter, 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(JobConf job)
                   throws IOException

Description copied from class: TableInputFormatBase

Handle subclass specific set up. Each of the entry points used by the MapReduce framework, TableInputFormatBase.getRecordReader(InputSplit, JobConf, Reporter) and TableInputFormatBase.getSplits(JobConf, int), will call TableInputFormatBase.initialize(JobConf) 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

initialize

protected void initialize(JobConf job,
                          String table)
                   throws IOException

Throws:

IOException