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

Class PigInputFormat

java.lang.Object

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

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

Fields

Modifier and Type	Field and Description
static org.apache.commons.logging.Log	log
static java.lang.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

Constructors

Constructor and Description
PigInputFormat()

Method Summary

Methods

Modifier and Type	Method and Description
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 java.util.List<org.apache.hadoop.mapreduce.InputSplit>	getPigSplits(java.util.List<org.apache.hadoop.mapreduce.InputSplit> oneInputSplits, int inputIndex, java.util.ArrayList<OperatorKey> targetOps, long blockSize, boolean combinable, org.apache.hadoop.conf.Configuration conf)
java.util.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 java.lang.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 java.io.IOException,
                                                                                                    java.lang.InterruptedException

Specified by:

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

Throws:

java.io.IOException

java.lang.InterruptedException

getSplits

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

Specified by:

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

Throws:

java.io.IOException

java.lang.InterruptedException

getPigSplits

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

Throws:

java.io.IOException

java.lang.InterruptedException

getActiveSplit

public static PigSplit getActiveSplit()