oracle.spatial.hadoop.vector.mapred.input

Class MultipleInputsFileSplitInputFormat.SplitSelector

java.lang.Object

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

Enclosing class:

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
MultipleInputsFileSplitInputFormat.SplitSelector()

Method Summary

Methods

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<org.apache.hadoop.mapred.InputSplit>	getSampleSplits(org.apache.hadoop.mapred.InputSplit[] splits)
void	init(org.apache.hadoop.conf.Configuration conf)
static boolean	isSamplingRequired(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

clone, equals, finalize, 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

MultipleInputsFileSplitInputFormat.SplitSelector

public MultipleInputsFileSplitInputFormat.SplitSelector()

Method Detail

isSamplingRequired

public static boolean isSamplingRequired(org.apache.hadoop.conf.Configuration conf)

init

public void init(org.apache.hadoop.conf.Configuration conf)

getSampleSplits

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

Throws:

java.io.IOException

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