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

java.lang.Object
  extended by org.apache.pig.impl.plan.Operator<MROpPlanVisitor>
      extended by org.apache.pig.backend.hadoop.executionengine.mapReduceLayer.MapReduceOper
          extended by 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, mapPlan, reducePlan, scalars, UDFs
 
Fields inherited from class org.apache.pig.impl.plan.Operator
mKey
 
Constructor Summary
NativeMapReduceOper(OperatorKey k, String mrJar, String[] parameters)
           
 
Method Summary
 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, getQuantFile, getRequestedParallelism, getSecondarySortOrder, getSkewedJoin, getSkewedJoinPartitionFile, getSortOrder, getUseSecondaryKey, isCogroup, isEndOfAllInputSetInMap, isEndOfAllInputSetInReduce, isGlobalSort, isGroupBy, isIndexer, isLimitAfterSort, isLimitOnly, isMapDone, isReduceDone, isRegularJoin, 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


Copyright © ${year} The Apache Software Foundation