oracle.spatial.hadoop.vector.mapreduce.input

Class MultipleInputsInputFormat

java.lang.Object

org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

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

public class MultipleInputsInputFormat
extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	MultipleInputsInputFormat.MultipleInputsRecordReader

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

Methods

Modifier and Type	Method and Description
org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,RecordInfo>	createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
java.util.List<org.apache.hadoop.mapreduce.InputSplit>	getSplits(org.apache.hadoop.mapreduce.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

clone, equals, finalize, 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 org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,RecordInfo> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                         org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                                  throws java.io.IOException,
                                                                                                         java.lang.InterruptedException

Specified by:

createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

Throws:

java.io.IOException

java.lang.InterruptedException

getSplits

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

Specified by:

getSplits in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,RecordInfo>

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)