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

java.lang.Object
  extended by org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,Tuple>
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.PigInputFormat

public class PigInputFormat
extends org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,Tuple>


Field Summary
static org.apache.commons.logging.Log log
           
static String PIG_INPUTS
           
static org.apache.hadoop.conf.Configuration sJob
          Deprecated. Use UDFContext instead in the following way to get the job's Configuration:
UdfContext.getUdfContext().getJobConf()
 
Constructor Summary
PigInputFormat()
           
 
Method Summary
 org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split, org.apache.hadoop.mapreduce.TaskAttemptContext context)
           
static PigSplit getActiveSplit()
           
protected  List<org.apache.hadoop.mapreduce.InputSplit> getPigSplits(List<org.apache.hadoop.mapreduce.InputSplit> oneInputSplits, int inputIndex, ArrayList<OperatorKey> targetOps, long blockSize, boolean combinable, org.apache.hadoop.conf.Configuration conf)
           
 List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext jobcontext)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

public static final org.apache.commons.logging.Log log

PIG_INPUTS

public static final String PIG_INPUTS
See Also:
Constant Field Values

sJob

@Deprecated
public static org.apache.hadoop.conf.Configuration sJob
Deprecated. Use UDFContext instead in the following way to get the job's Configuration:
UdfContext.getUdfContext().getJobConf()
Constructor Detail

PigInputFormat

public PigInputFormat()
Method Detail

createRecordReader

public org.apache.hadoop.mapreduce.RecordReader<org.apache.hadoop.io.Text,Tuple> createRecordReader(org.apache.hadoop.mapreduce.InputSplit split,
                                                                                                    org.apache.hadoop.mapreduce.TaskAttemptContext context)
                                                                                             throws IOException,
                                                                                                    InterruptedException
Specified by:
createRecordReader in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,Tuple>
Throws:
IOException
InterruptedException

getSplits

public List<org.apache.hadoop.mapreduce.InputSplit> getSplits(org.apache.hadoop.mapreduce.JobContext jobcontext)
                                                       throws IOException,
                                                              InterruptedException
Specified by:
getSplits in class org.apache.hadoop.mapreduce.InputFormat<org.apache.hadoop.io.Text,Tuple>
Throws:
IOException
InterruptedException

getPigSplits

protected List<org.apache.hadoop.mapreduce.InputSplit> getPigSplits(List<org.apache.hadoop.mapreduce.InputSplit> oneInputSplits,
                                                                    int inputIndex,
                                                                    ArrayList<OperatorKey> targetOps,
                                                                    long blockSize,
                                                                    boolean combinable,
                                                                    org.apache.hadoop.conf.Configuration conf)
                                                             throws IOException,
                                                                    InterruptedException
Throws:
IOException
InterruptedException

getActiveSplit

public static PigSplit getActiveSplit()


Copyright © ${year} The Apache Software Foundation