@InterfaceAudience.Public @InterfaceStability.Evolving public class MultiTableInputFormat extends MultiTableInputFormatBase implements org.apache.hadoop.conf.Configurable
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);
Modifier and Type | Field and Description |
---|---|
private org.apache.hadoop.conf.Configuration |
conf
The configuration.
|
static String |
SCANS
Job parameter that specifies the scan list.
|
Constructor and Description |
---|
MultiTableInputFormat() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.conf.Configuration |
getConf()
Returns the current configuration.
|
void |
setConf(org.apache.hadoop.conf.Configuration configuration)
Sets the configuration.
|
createRecordReader, getScans, getSplits, includeRegionInSplit, setScans, setTableRecordReader
public static final String SCANS
private org.apache.hadoop.conf.Configuration conf
public org.apache.hadoop.conf.Configuration getConf()
getConf
in interface org.apache.hadoop.conf.Configurable
Configurable.getConf()
public void setConf(org.apache.hadoop.conf.Configuration configuration)
setConf
in interface org.apache.hadoop.conf.Configurable
configuration
- The configuration to set.Configurable.setConf(
org.apache.hadoop.conf.Configuration)
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.