oracle.spatial.hadoop.vector.mapreduce.input

Class MultipleInputsInputFormat

java.lang.Object

<any>

oracle.spatial.hadoop.vector.mapreduce.input.MultipleInputsInputFormat

public class MultipleInputsInputFormat
extends <any>

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	CONF_DATA_SET_TAGS
static java.lang.String	CONF_TAGS_REMOVED

Constructor Summary

Constructors

Constructor and Description
MultipleInputsInputFormat()

Method Summary

Modifier and Type	Method and Description
<any>	createRecordReader(InputSplit split, TaskAttemptContext context)
java.util.List<InputSplit>	getSplits(JobContext context)
static boolean	isTagged(java.lang.String key, java.lang.String tag)
static java.lang.String	removeTag(java.lang.String key, java.lang.String tag)

Methods inherited from class java.lang.Object

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

Field Detail

CONF_DATA_SET_TAGS

public static final java.lang.String CONF_DATA_SET_TAGS

See Also:

Constant Field Values

CONF_TAGS_REMOVED

public static final java.lang.String CONF_TAGS_REMOVED

See Also:

Constant Field Values

Constructor Detail

MultipleInputsInputFormat

public MultipleInputsInputFormat()

Method Detail

createRecordReader

public <any> createRecordReader(InputSplit split,
                                TaskAttemptContext context)
                         throws java.io.IOException,
                                java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

getSplits

public java.util.List<InputSplit> getSplits(JobContext context)
                                     throws java.io.IOException,
                                            java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

isTagged

public static boolean isTagged(java.lang.String key,
                               java.lang.String tag)

removeTag

public static java.lang.String removeTag(java.lang.String key,
                                         java.lang.String tag)