com.datasalt.pangool.tuplemr.mapred.lib.input
Class TaggedInputSplit

java.lang.Object
  org.apache.hadoop.mapreduce.InputSplit
      com.datasalt.pangool.tuplemr.mapred.lib.input.TaggedInputSplit

All Implemented Interfaces:

org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.Writable

public class TaggedInputSplit
extends org.apache.hadoop.mapreduce.InputSplit
implements org.apache.hadoop.conf.Configurable, org.apache.hadoop.io.Writable

An InputSplit that tags another InputSplit with extra data for use by DelegatingInputFormats and DelegatingMappers.

PATCH: Changed visibility (package to public)

Constructor Summary

TaggedInputSplit()

TaggedInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit, org.apache.hadoop.conf.Configuration conf, String inputFormatFile, String inputProcessorFile)
Creates a new TaggedInputSplit.

Method Summary

org.apache.hadoop.conf.Configuration	getConf()
String	getInputFormatFile()
String	getInputProcessorFile()
org.apache.hadoop.mapreduce.InputSplit	getInputSplit() Retrieves the original InputSplit.
long	getLength()
String[]	getLocations()
void	readFields(DataInput in)
void	setConf(org.apache.hadoop.conf.Configuration conf)
void	write(DataOutput out)

Methods inherited from class java.lang.Object

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

Constructor Detail

TaggedInputSplit

public TaggedInputSplit()

TaggedInputSplit

public TaggedInputSplit(org.apache.hadoop.mapreduce.InputSplit inputSplit,
                        org.apache.hadoop.conf.Configuration conf,
                        String inputFormatFile,
                        String inputProcessorFile)

Creates a new TaggedInputSplit.

Parameters:

inputSplit - The InputSplit to be tagged

conf - The configuration to use

Method Detail

getInputSplit

public org.apache.hadoop.mapreduce.InputSplit getInputSplit()

Retrieves the original InputSplit.

Returns:

The InputSplit that was tagged

getInputFormatFile

public String getInputFormatFile()

getInputProcessorFile

public String getInputProcessorFile()

getLength

public long getLength()
               throws IOException,
                      InterruptedException

Specified by:

getLength in class org.apache.hadoop.mapreduce.InputSplit

Throws:

IOException

InterruptedException

getLocations

public String[] getLocations()
                      throws IOException,
                             InterruptedException

Specified by:

getLocations in class org.apache.hadoop.mapreduce.InputSplit

Throws:

IOException

InterruptedException

readFields

public void readFields(DataInput in)
                throws IOException

Specified by:

readFields in interface org.apache.hadoop.io.Writable

Throws:

IOException

write

public void write(DataOutput out)
           throws IOException

Specified by:

write in interface org.apache.hadoop.io.Writable

Throws:

IOException

getConf

public org.apache.hadoop.conf.Configuration getConf()

Specified by:

getConf in interface org.apache.hadoop.conf.Configurable

setConf

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

Specified by:

setConf in interface org.apache.hadoop.conf.Configurable