public abstract class FileInputDataSetConfigurator extends java.lang.Object implements InputDataSetConfigurator
FileInputDataSet
instances. Additionally to the minimum setup (as performed by SimpleInputDataSetConfigurator
), it will check and configure the path of the data set files.Constructor and Description |
---|
FileInputDataSetConfigurator() |
Modifier and Type | Method and Description |
---|---|
boolean |
acceptsDataSet(AbstractInputDataSet dataSet)
Returns true if the current configurator can configure the given data set
|
void |
configure(AbstractInputDataSet dataSet, Configuration conf)
Setups the given data set using the given job's configuration
|
static void |
validateInputFormatClass(FileInputDataSet dataSet, java.lang.Class<?> baseInputFormatClass)
Checks that the InputFormat class set to the data set is valid and a subclass of the specified baseInputFormat parameter
|
static void |
validateInputPaths(FileInputDataSet dataSet)
Check that the given data set contains the location of the data set files, as paths or as input string.
|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getBaseInputFormatClass
public boolean acceptsDataSet(AbstractInputDataSet dataSet)
DataSetConfigurator
acceptsDataSet
in interface DataSetConfigurator<AbstractInputDataSet>
dataSet
- a data setpublic void configure(AbstractInputDataSet dataSet, Configuration conf) throws java.lang.Exception
DataSetConfigurator
configure
in interface DataSetConfigurator<AbstractInputDataSet>
dataSet
- a data setconf
- a job configurationjava.lang.Exception
public static void validateInputFormatClass(FileInputDataSet dataSet, java.lang.Class<?> baseInputFormatClass)
dataSet
- an input data setbaseInputFormatClass
- the super class used to validate the data set input format classpublic static void validateInputPaths(FileInputDataSet dataSet)
dataSet
- an input data setCopyright © 2017 Oracle and/or its affiliates. All Rights Reserved.