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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputSplit
      extended by 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


Copyright © –2014 Datasalt Systems S.L.. All rights reserved.