com.twitter.maple.hbase.mapred

Class TableInputFormat

java.lang.Object

org.apache.hadoop.hbase.mapred.TableInputFormatBase

com.twitter.maple.hbase.mapred.TableInputFormat

All Implemented Interfaces:

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

public class TableInputFormat
extends org.apache.hadoop.hbase.mapred.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 and Description
static java.lang.String	COLUMN_LIST space delimited list of columns
static java.lang.String	INPUT_TABLE Use this jobconf param to specify the input table

Constructor Summary

Constructors

Constructor and Description
TableInputFormat()

Method Summary

Modifier and Type	Method and Description
void	configure(org.apache.hadoop.mapred.JobConf job)
static java.lang.String	getTableName(org.apache.hadoop.mapred.JobConf job)
static void	setTableName(org.apache.hadoop.mapred.JobConf job, java.lang.String tableName)
void	validateInput(org.apache.hadoop.mapred.JobConf job)

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

getHTable, getRecordReader, getSplits, setHTable, setInputColumns, setRowFilter, setTableRecordReader

Methods inherited from class java.lang.Object

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

Field Detail

COLUMN_LIST

public static final java.lang.String COLUMN_LIST

space delimited list of columns

See Also:

Constant Field Values

INPUT_TABLE

public static final java.lang.String INPUT_TABLE

Use this jobconf param to specify the input table

See Also:

Constant Field Values

Constructor Detail

TableInputFormat

public TableInputFormat()

Method Detail

configure

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

Specified by:

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

validateInput

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

Throws:

java.io.IOException

setTableName

public static void setTableName(org.apache.hadoop.mapred.JobConf job,
                                java.lang.String tableName)

getTableName

public static java.lang.String getTableName(org.apache.hadoop.mapred.JobConf job)