public class MultipleInputsConfig
extends java.lang.Object
| Constructor and Description |
|---|
MultipleInputsConfig()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
addInputDataSet(InputDataSet inDataSet, org.apache.hadoop.mapreduce.Job job)
Deprecated.
Adds a data set to the job
|
void |
addInputDataSet(InputDataSet inDataSet, org.apache.hadoop.mapred.JobConf jobConf)
Deprecated.
Adds a data set to the job
|
void |
addInputDataSets(java.util.List<InputDataSet> inDataSets, org.apache.hadoop.mapreduce.Job job)
Deprecated.
Adds a list of input data sets to the job.
|
void |
addInputDataSets(java.util.List<InputDataSet> inputs, org.apache.hadoop.mapred.JobConf jobConf)
Deprecated.
Adds a list of input data sets to the job.
|
DistributedDataSet |
getDataSet(int dataSetId)
Deprecated.
Gets data set identified by the given id
|
int |
getDataSetId(org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration conf)
Deprecated.
Gets the id of the data set to which the given path belongs.
|
java.lang.Class<?> |
getInputFormatClass(int dataSetId)
Deprecated.
Gets the input format class used to read the data set identified by the given id
|
java.lang.Class<?> |
getRecordInfoProviderClass(int dataSetId)
Deprecated.
Gets the
RecordInfoProvider class used for the data set identified by the given id |
void |
load(org.apache.hadoop.conf.Configuration conf)
Deprecated.
Loads the multiple input data sets configuration from the job configuration
|
void |
store(org.apache.hadoop.conf.Configuration conf)
Deprecated.
Stores the multiple input data sets configuration to the job configuration
|
public void addInputDataSets(java.util.List<InputDataSet> inputs, org.apache.hadoop.mapred.JobConf jobConf) throws java.io.IOException
inputs - a list of InputDataSet instancesjobConf - the job configurationjava.io.IOExceptionpublic void addInputDataSets(java.util.List<InputDataSet> inDataSets, org.apache.hadoop.mapreduce.Job job) throws java.io.IOException
inDataSets - a list of InputDataSet instancesjob - a jobjava.io.IOExceptionpublic void addInputDataSet(InputDataSet inDataSet, org.apache.hadoop.mapred.JobConf jobConf) throws java.io.IOException
inDataSet - an instance of InputDataSetjobConf - the job configurationjava.io.IOExceptionpublic void addInputDataSet(InputDataSet inDataSet, org.apache.hadoop.mapreduce.Job job) throws java.io.IOException
inDataSet - an instance of InputDataSetjob - a jobjava.io.IOException
public int getDataSetId(org.apache.hadoop.fs.Path path,
org.apache.hadoop.conf.Configuration conf)
throws java.io.IOException
path - a pathconf - a job configurationjava.io.IOExceptionpublic DistributedDataSet getDataSet(int dataSetId)
dataSetId - a data set idDistributedDataSetpublic java.lang.Class<?> getInputFormatClass(int dataSetId)
dataSetId - a data set idpublic java.lang.Class<?> getRecordInfoProviderClass(int dataSetId)
RecordInfoProvider class used for the data set identified by the given iddataSetId - a data set idRecordInfoProvider class or null if no data set was found for the given idpublic void store(org.apache.hadoop.conf.Configuration conf)
conf -public void load(org.apache.hadoop.conf.Configuration conf)
conf -Copyright © 2016 Oracle and/or its affiliates. All Rights Reserved.