oracle.spatial.hadoop.vector.mapred.input

Class MultipleInputsFileSplitInputFormat.SplitSelector

java.lang.Object

oracle.spatial.hadoop.vector.mapred.input.MultipleInputsFileSplitInputFormat.SplitSelector

Enclosing class:

oracle.spatial.hadoop.vector.mapred.input.MultipleInputsFileSplitInputFormat

public static class MultipleInputsFileSplitInputFormat.SplitSelector
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_SAMPLER

Constructor Summary

Constructors

Constructor and Description
SplitSelector()

Method Summary

Modifier and Type	Method and Description
java.util.Collection<org.apache.hadoop.mapreduce.InputSplit>	getSampleSplits(java.util.Collection<org.apache.hadoop.mapreduce.InputSplit> splitsList)
java.util.Collection<InputSplit>	getSampleSplits(InputSplit[] splits)
void	init(Configuration conf)
static boolean	isSamplingRequired(Configuration conf)

Methods inherited from class java.lang.Object

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

Field Detail

CONF_SAMPLER

public static final java.lang.String CONF_SAMPLER

See Also:

Constant Field Values

Constructor Detail

SplitSelector

public SplitSelector()

Method Detail

getSampleSplits

public java.util.Collection<org.apache.hadoop.mapreduce.InputSplit> getSampleSplits(java.util.Collection<org.apache.hadoop.mapreduce.InputSplit> splitsList)
                                                                             throws java.io.IOException,
                                                                                    java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getSampleSplits

public java.util.Collection<InputSplit> getSampleSplits(InputSplit[] splits)
                                                 throws java.io.IOException

Throws:

java.io.IOException

init

public void init(Configuration conf)

isSamplingRequired

public static boolean isSamplingRequired(Configuration conf)