org.apache.hadoop.hbase.mapreduce

Class MultiTableInputFormat

java.lang.Object

<any>

org.apache.hadoop.hbase.mapreduce.MultiTableInputFormatBase

org.apache.hadoop.hbase.mapreduce.MultiTableInputFormat

public class MultiTableInputFormat
extends MultiTableInputFormatBase

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

Usage example

 List<Scan> scans = new ArrayList<Scan>();

 Scan scan1 = new Scan();
 scan1.setStartRow(firstRow1);
 scan1.setStopRow(lastRow1);
 scan1.setAttribute(Scan.SCAN_ATTRIBUTES_TABLE_NAME, table1);
 scans.add(scan1);

 Scan scan2 = new Scan();
 scan2.setStartRow(firstRow2);
 scan2.setStopRow(lastRow2);
 scan1.setAttribute(Scan.SCAN_ATTRIBUTES_TABLE_NAME, table2);
 scans.add(scan2);

 TableMapReduceUtil.initTableMapperJob(scans, TableMapper.class, Text.class,
     IntWritable.class, job);
 

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	SCANS Job parameter that specifies the scan list.

Constructor Summary

Constructors

Constructor and Description
MultiTableInputFormat()

Method Summary

Modifier and Type	Method and Description
Configuration	getConf() Returns the current configuration.
void	setConf(Configuration configuration) Sets the configuration.

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

createRecordReader, getScans, getSplits, includeRegionInSplit, setScans, setTableRecordReader

Methods inherited from class java.lang.Object

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

Field Detail

SCANS

public static final java.lang.String SCANS

Job parameter that specifies the scan list.

See Also:

Constant Field Values

Constructor Detail

MultiTableInputFormat

public MultiTableInputFormat()

Method Detail

getConf

public Configuration getConf()

Returns the current configuration.

Returns:

The current configuration.

See Also:

org.apache.hadoop.conf.Configurable#getConf()

setConf

public void setConf(Configuration configuration)

Sets the configuration. This is used to set the details for the tables to be scanned.

Parameters:

configuration - The configuration to set.

See Also:

org.apache.hadoop.conf.Configurable#setConf( org.apache.hadoop.conf.Configuration)