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

Class NativeMapReduceOper

java.lang.Object

org.apache.pig.impl.plan.Operator<MROpPlanVisitor>

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

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

All Implemented Interfaces:

Serializable, Cloneable, Comparable<Operator>

public class NativeMapReduceOper
extends MapReduceOper

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper

combinePlan, mapKeyType, mapKeyTypeOfSplittees, mapPlan, phyToMRMap, reducePlan, scalars, UDFs

Fields inherited from class org.apache.pig.impl.plan.Operator

mKey

Constructor Summary

Constructors

Constructor and Description
NativeMapReduceOper(OperatorKey k, String mrJar, String[] parameters)

Method Summary

Modifier and Type	Method and Description
String	getCommandString()
String	getJobId()
static int	getJobNumber()
String	name() Uses the string representation of the component plans to identify itself.
void	runJob()
void	visit(MROpPlanVisitor v) Visit this node with the provided visitor.

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper

combineSmallSplits, getCustomPartitioner, getOperationID, getQuantFile, getRankOperationId, getRequestedParallelism, getSecondarySortOrder, getSkewedJoin, getSkewedJoinPartitionFile, getSortOrder, getUseSecondaryKey, isCogroup, isCounterOperation, isEndOfAllInputSetInMap, isEndOfAllInputSetInReduce, isGlobalSort, isGroupBy, isIndexer, isLimitAfterSort, isLimitOnly, isMapDone, isRankOperation, isReduceDone, isRegularJoin, isRowNumber, isSampler, isSkewedJoin, isSplitter, markCogroup, markGroupBy, markIndexer, markRegularJoin, markSampler, needsDistinctCombiner, noCombineSmallSplits, setEndOfAllInputInMap, setEndOfAllInputInReduce, setGlobalSort, setLimitAfterSort, setLimitOnly, setMapDone, setMapDoneMultiple, setMapDoneSingle, setNeedsDistinctCombiner, setQuantFile, setReduceDone, setSecondarySortOrder, setSkewedJoin, setSkewedJoinPartitionFile, setSortOrder, setSplitter, setUseSecondaryKey, supportsMultipleInputs, supportsMultipleOutputs, useTypedComparator, usingTypedComparator

Methods inherited from class org.apache.pig.impl.plan.Operator

clone, compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

NativeMapReduceOper

public NativeMapReduceOper(OperatorKey k,
                           String mrJar,
                           String[] parameters)

Method Detail

getJobNumber

public static int getJobNumber()

getJobId

public String getJobId()

getCommandString

public String getCommandString()

visit

public void visit(MROpPlanVisitor v)
           throws VisitorException

Description copied from class: Operator

Visit this node with the provided visitor. This should only be called by the visitor class itself, never directly.

Overrides:

visit in class MapReduceOper

Parameters:

v - Visitor to visit with.

Throws:

VisitorException - if the visitor has a problem.

runJob

public void runJob()
            throws JobCreationException

Throws:

JobCreationException

name

public String name()

Description copied from class: MapReduceOper

Uses the string representation of the component plans to identify itself.

Overrides:

name in class MapReduceOper