public abstract class MultiInputDataSetConfigurator extends java.lang.Object implements InputDataSetConfigurator
MultiInputDataSet. An instance of this class depends on an internal InputDataSetConfiguratorHandler which is passed at creation time and is used to eventually configure the data sets conatined in the MultiInputDataSet instance.| Constructor and Description |
|---|
MultiInputDataSetConfigurator(InputDataSetConfiguratorHandler configuratorHandler)
Creates a new instance
|
| 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, org.apache.hadoop.conf.Configuration conf)
Setups the given data set using the given job's configuration
|
protected abstract org.apache.hadoop.conf.Configuration |
createTaggedConf(org.apache.hadoop.conf.Configuration conf, java.lang.String tag, boolean untaggedSearch)
Returns a tagged version of the given job's configuration.
|
InputDataSetConfiguratorHandler |
getConfiguratorHandler()
Gets a configurator handler used to configure the data sets contained in a
MultiInputDataSet |
static SpatialConfig |
getGlobalSpatialConfig(MultiInputDataSet mDataSet, boolean enforceSameSrid)
Gets the common spatial configuration between all the input data sets contained in the given
MultiInputDataSet instance |
void |
setConfiguratorHandler(InputDataSetConfiguratorHandler configuratorHandler)
Sets a configurator handler used to configure the data sets contained in a
MultiInputDataSet |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetBaseInputFormatClasspublic MultiInputDataSetConfigurator(InputDataSetConfiguratorHandler configuratorHandler)
configuratorHandler - A configurator handler used to configure the data sets contained in a MultiInputDataSetpublic void setConfiguratorHandler(InputDataSetConfiguratorHandler configuratorHandler)
MultiInputDataSetconfiguratorHandler - an instance of InputDataSetConfiguratorHandlerpublic InputDataSetConfiguratorHandler getConfiguratorHandler()
MultiInputDataSetInputDataSetConfiguratorHandlerpublic boolean acceptsDataSet(AbstractInputDataSet dataSet)
DataSetConfiguratoracceptsDataSet in interface DataSetConfigurator<AbstractInputDataSet>dataSet - a data setpublic void configure(AbstractInputDataSet dataSet, org.apache.hadoop.conf.Configuration conf) throws java.lang.Exception
DataSetConfiguratorconfigure in interface DataSetConfigurator<AbstractInputDataSet>dataSet - a data setconf - a job configurationjava.lang.Exception
protected abstract org.apache.hadoop.conf.Configuration createTaggedConf(org.apache.hadoop.conf.Configuration conf,
java.lang.String tag,
boolean untaggedSearch)
conf - a job configurationtag - the tag to be used by the tagged configurationuntaggedSearch - true if the tagged configuration should look without tag when a tagged property is not foundpublic static SpatialConfig getGlobalSpatialConfig(MultiInputDataSet mDataSet, boolean enforceSameSrid)
MultiInputDataSet instancemDataSet - a MultiInputDataSet instanceenforceSameSrid - when true, an exception will be raised if two contained data sets do not have the same SRIDSpatialConfigCopyright © 2016 Oracle and/or its affiliates. All Rights Reserved.