org.apache.pig.backend.hadoop.executionengine.mapReduceLayer
Class PigTextInputFormat

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<K,V>
      extended by org.apache.hadoop.mapreduce.lib.input.FileInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>
          extended by org.apache.hadoop.mapreduce.lib.input.TextInputFormat
              extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigTextInputFormat
Direct Known Subclasses:
IndexedStorage.IndexedStorageInputFormat

public class PigTextInputFormat
extends org.apache.hadoop.mapreduce.lib.input.TextInputFormat


Nested Class Summary
 
Nested classes/interfaces inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
org.apache.hadoop.mapreduce.lib.input.FileInputFormat.Counter
 
Constructor Summary
PigTextInputFormat()
           
 
Method Summary
protected  List<org.apache.hadoop.fs.FileStatus> listStatus(org.apache.hadoop.mapreduce.JobContext job)
           
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.input.TextInputFormat
createRecordReader, isSplitable
 
Methods inherited from class org.apache.hadoop.mapreduce.lib.input.FileInputFormat
addInputPath, addInputPaths, computeSplitSize, getBlockIndex, getFormatMinSplitSize, getInputPathFilter, getInputPaths, getMaxSplitSize, getMinSplitSize, getSplits, setInputPathFilter, setInputPaths, setInputPaths, setMaxInputSplitSize, setMinInputSplitSize
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PigTextInputFormat

public PigTextInputFormat()
Method Detail

listStatus

protected List<org.apache.hadoop.fs.FileStatus> listStatus(org.apache.hadoop.mapreduce.JobContext job)
                                                    throws IOException
Overrides:
listStatus in class org.apache.hadoop.mapreduce.lib.input.FileInputFormat<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.Text>
Throws:
IOException


Copyright © 2007-2012 The Apache Software Foundation