Package org.apache.hadoop.hbase.mapred

Class TableInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapred.TableInputFormatBase

org.apache.hadoop.hbase.mapred.TableInputFormat

All Implemented Interfaces:

org.apache.hadoop.mapred.InputFormat<ImmutableBytesWritable,Result>, org.apache.hadoop.mapred.JobConfigurable

@Public
public class TableInputFormat
extends TableInputFormatBase
implements org.apache.hadoop.mapred.JobConfigurable

Convert HBase tabular data into a format that is consumable by Map/Reduce.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	COLUMN_LIST	space delimited list of columns
private static final org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor	Description
TableInputFormat()

Method Summary

Modifier and Type	Method	Description
void	configure(org.apache.hadoop.mapred.JobConf job)
protected void	initialize(org.apache.hadoop.mapred.JobConf job)	Handle subclass specific set up.
void	validateInput(org.apache.hadoop.mapred.JobConf job)

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

closeTable, getRecordReader, getSplits, getTable, initializeTable, setInputColumns, setRowFilter, setTableRecordReader

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

COLUMN_LIST

public static final String COLUMN_LIST

space delimited list of columns

See Also:

• Constant Field Values

Constructor Details

TableInputFormat

public TableInputFormat()

Method Details

configure

public void configure(org.apache.hadoop.mapred.JobConf job)

Specified by:

configure in interface org.apache.hadoop.mapred.JobConfigurable

initialize

protected void initialize(org.apache.hadoop.mapred.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

validateInput

public void validateInput(org.apache.hadoop.mapred.JobConf job)
                   throws IOException

Throws:

IOException