oracle.spatial.hadoop.vector.data

Class SimpleInputDataSet

java.lang.Object

oracle.spatial.hadoop.vector.data.SimpleInputDataSet

All Implemented Interfaces:

ConfigurationStorable, AbstractInputDataSet, IODataSet

Direct Known Subclasses:

FileInputDataSet, MultiInputDataSet, NoSQLInputDataSet

public class SimpleInputDataSet
extends java.lang.Object
implements AbstractInputDataSet

Contains the minimum information to represent an input data set. Additional configuration for the input data set (if needed) can be set directly to the job's configuration or using a specific InputDataSetConfigurator.

Author:

hsaucedo

Constructor Summary

Constructors

Constructor and Description
SimpleInputDataSet()

Method Summary

Modifier and Type	Method and Description
java.lang.Class<?>	getInputFormatClass() Gets the InputFormat class used to read the input data set
long	getLength() Gets the length (in bytes) of the data set
java.lang.Class<? extends RecordInfoProvider<?,?>>	getRecordInfoProviderClass() Gets the RecordInfoProvider class used to extract required information from the key-value pairs provided by the InputFormat.
SpatialConfig	getSpatialConfig() Gets the spatial configuration of the data set which defines the spatial features of the data set such as SRID, dimensions and boundaries.
void	load(Configuration conf) Loads the current state from the given job configuration
void	setInputFormatClass(java.lang.Class<?> inputFormatClass) Sets the InputFormat class used to read the input data set
void	setInputFormatClassAsString(java.lang.String inputFormatClassStr) Sets the InputFormat class used to read the input data set.
void	setLength(long length) Sets the length (in bytes) of the data set
void	setRecordInfoProviderClass(java.lang.Class<? extends RecordInfoProvider<?,?>> recordInfoProviderClass) Sets the RecordInfoProvider class used to extract required information from the key-value pairs provided by the InputFormat.
void	setSpatialConfig(SpatialConfig spatialConfig) Sets the spatial configuration of the data set which defines the spatial features of the data set such as SRID, dimensions and boundaries.
void	store(Configuration conf) Stores the current state into the given job configuration

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimpleInputDataSet

public SimpleInputDataSet()

Method Detail

getInputFormatClass

public java.lang.Class<?> getInputFormatClass()

Description copied from interface: AbstractInputDataSet

Gets the InputFormat class used to read the input data set

Specified by:

getInputFormatClass in interface AbstractInputDataSet

Returns:

a subclass of either, org.apache.hadoop.mapred.InputFormat or org.apache.hadoop.mapreduce.InputFormat.

getLength

public long getLength()

Description copied from interface: AbstractInputDataSet

Gets the length (in bytes) of the data set

Specified by:

getLength in interface AbstractInputDataSet

Returns:

the data set length

getRecordInfoProviderClass

public java.lang.Class<? extends RecordInfoProvider<?,?>> getRecordInfoProviderClass()

Description copied from interface: AbstractInputDataSet

Gets the RecordInfoProvider class used to extract required information from the key-value pairs provided by the InputFormat.

Specified by:

getRecordInfoProviderClass in interface AbstractInputDataSet

Returns:

a subclass of RecordInfoProvider

getSpatialConfig

public SpatialConfig getSpatialConfig()

Description copied from interface: AbstractInputDataSet

Gets the spatial configuration of the data set which defines the spatial features of the data set such as SRID, dimensions and boundaries.

Specified by:

getSpatialConfig in interface AbstractInputDataSet

Returns:

a SpatialConfig instance

load

public void load(Configuration conf)

Description copied from interface: ConfigurationStorable

Loads the current state from the given job configuration

Specified by:

load in interface ConfigurationStorable

setInputFormatClass

public void setInputFormatClass(java.lang.Class<?> inputFormatClass)

Description copied from interface: AbstractInputDataSet

Sets the InputFormat class used to read the input data set

Specified by:

setInputFormatClass in interface AbstractInputDataSet

Parameters:

inputFormatClass - a subclass of either, org.apache.hadoop.mapred.InputFormat or org.apache.hadoop.mapreduce.InputFormat.

setInputFormatClassAsString

public void setInputFormatClassAsString(java.lang.String inputFormatClassStr)

Description copied from interface: AbstractInputDataSet

Sets the InputFormat class used to read the input data set. The class is set specifying the fully qualified class name as a string

Specified by:

setInputFormatClassAsString in interface AbstractInputDataSet

Parameters:

inputFormatClassStr - a fully qualified name a subclass of either, org.apache.hadoop.mapred.InputFormat or org.apache.hadoop.mapreduce.InputFormat.

setLength

public void setLength(long length)

Description copied from interface: AbstractInputDataSet

Sets the length (in bytes) of the data set

Specified by:

setLength in interface AbstractInputDataSet

Parameters:

length - the data set length

setRecordInfoProviderClass

public void setRecordInfoProviderClass(java.lang.Class<? extends RecordInfoProvider<?,?>> recordInfoProviderClass)

Description copied from interface: AbstractInputDataSet

Sets the RecordInfoProvider class used to extract required information from the key-value pairs provided by the InputFormat.

Specified by:

setRecordInfoProviderClass in interface AbstractInputDataSet

Parameters:

recordInfoProviderClass - a subclass of RecordInfoProvider

setSpatialConfig

public void setSpatialConfig(SpatialConfig spatialConfig)

Description copied from interface: AbstractInputDataSet

Sets the spatial configuration of the data set which defines the spatial features of the data set such as SRID, dimensions and boundaries.

Specified by:

setSpatialConfig in interface AbstractInputDataSet

Parameters:

spatialConfig - a SpatialConfig instance.

store

public void store(Configuration conf)

Description copied from interface: ConfigurationStorable

Stores the current state into the given job configuration

Specified by:

store in interface ConfigurationStorable