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.IOException
public 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.IOException
public void addInputDataSet(InputDataSet inDataSet, org.apache.hadoop.mapred.JobConf jobConf) throws java.io.IOException
inDataSet
- an instance of InputDataSet
jobConf
- the job configurationjava.io.IOException
public void addInputDataSet(InputDataSet inDataSet, org.apache.hadoop.mapreduce.Job job) throws java.io.IOException
inDataSet
- an instance of InputDataSet
job
- 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.IOException
public DistributedDataSet getDataSet(int dataSetId)
dataSetId
- a data set idDistributedDataSet
public 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.