org.apache.pig.backend.hadoop.executionengine.tez.plan.operator

Class NativeTezOper

java.lang.Object

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

org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator

org.apache.pig.backend.hadoop.executionengine.tez.plan.operator.NativeTezOper

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.lang.Comparable<Operator>

public class NativeTezOper
extends TezOperator

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator

TezOperator.LoaderInfo, TezOperator.OPER_FEATURE, TezOperator.VertexGroupInfo

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator

inEdges, outEdges, plan, scalars, UDFs

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

mKey

Constructor Summary

Constructors

Constructor and Description
NativeTezOper(OperatorKey k, java.lang.String tezJar, java.lang.String[] parameters)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getCommandString()
java.lang.String	getJobId()
java.lang.String	name()
void	runJob(java.lang.String jobStatsKey)
void	visit(TezOpPlanVisitor v) Visit this node with the provided visitor.

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.tez.plan.TezOperator

addCrossKey, addUnionPredecessor, addVertexGroupStore, combineSmallSplits, copyFeatures, getCrossKeys, getEffectiveParallelism, getEstimatedParallelism, getLoaderInfo, getParallelismFactor, getProcessorName, getRequestedParallelism, getSampleOperator, getSortOperator, getSortOrder, getSplitParent, getTotalInputFilesSize, getUnionMembers, getVertexGroupInfo, getVertexGroupMembers, getVertexGroupStores, getVertexParallelism, isBuildBloom, isClosed, isCogroup, isDistinct, isDontEstimateParallelism, isFilterBloom, isGlobalSort, isGroupBy, isIndexer, isIntermediateReducer, isLimit, isLimitAfterSort, isMergeCogroup, isMergeJoin, isMergeSparseJoin, isNative, isNeedEstimateParallelism, isOverrideIntermediateParallelism, isRankCounter, isRegularJoin, isSampleAggregation, isSampleBasedPartitioner, isSampler, isSkewedJoin, isSplitter, isUnion, isUseGraceParallelism, isUseMRMapSettings, isUseSecondaryKey, isVertexGroup, markBuildBloom, markCogroup, markDistinct, markFilterBloom, markGlobalSort, markGroupBy, markIndexer, markLimit, markLimitAfterSort, markMergeCogroup, markMergeJoin, markMergeSparseJoin, markNative, markRankCounter, markRegularJoin, markSampleAggregation, markSampleBasedPartitioner, markSampler, markSkewedJoin, markUnion, needSegmentBelow, noCombineSmallSplits, removeVertexGroupStore, setClosed, setDontEstimateParallelism, setEstimatedParallelism, setIntermediateReducer, setNeedEstimatedQuantile, setOverrideIntermediateParallelism, setRequestedParallelism, setRequestedParallelismByReference, setSampleOperator, setSortOperator, setSortOrder, setSplitParent, setSplitter, setTotalInputFilesSize, setUseGraceParallelism, setUseMRMapSettings, setUseSecondaryKey, setVertexGroupInfo, setVertexGroupMembers, setVertexParallelism, supportsMultipleInputs, supportsMultipleOutputs, toString

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

NativeTezOper

public NativeTezOper(OperatorKey k,
                     java.lang.String tezJar,
                     java.lang.String[] parameters)

Method Detail

getJobId

public java.lang.String getJobId()

getCommandString

public java.lang.String getCommandString()

visit

public void visit(TezOpPlanVisitor 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 TezOperator

Parameters:

v - Visitor to visit with.

Throws:

VisitorException - if the visitor has a problem.

runJob

public void runJob(java.lang.String jobStatsKey)
            throws JobCreationException

Throws:

JobCreationException

name

public java.lang.String name()

Overrides:

name in class TezOperator