public class NativeTezOper extends TezOperator
TezOperator.LoaderInfo, TezOperator.OPER_FEATURE, TezOperator.VertexGroupInfo
Constructor and Description |
---|
NativeTezOper(OperatorKey k,
String tezJar,
String[] parameters) |
Modifier and Type | Method and Description |
---|---|
String |
getCommandString() |
String |
getJobId() |
String |
name() |
void |
runJob(String jobStatsKey) |
void |
visit(TezOpPlanVisitor v)
Visit this node with the provided visitor.
|
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, isNative, isNeedEstimateParallelism, isOverrideIntermediateParallelism, isRankCounter, isRegularJoin, isSampleAggregation, isSampleBasedPartitioner, isSampler, isSkewedJoin, isSplitter, isUnion, isUseGraceParallelism, isUseMRMapSettings, isUseSecondaryKey, isVertexGroup, markBuildBloom, markCogroup, markDistinct, markFilterBloom, markGlobalSort, markGroupBy, markIndexer, markLimit, markLimitAfterSort, 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
clone, compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, unsetProjectionMap
public NativeTezOper(OperatorKey k, String tezJar, String[] parameters)
public String getJobId()
public String getCommandString()
public void visit(TezOpPlanVisitor v) throws VisitorException
Operator
visit
in class TezOperator
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public void runJob(String jobStatsKey) throws JobCreationException
JobCreationException
public String name()
name
in class TezOperator
Copyright © 2007-2017 The Apache Software Foundation