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

Class POCounterTez

java.lang.Object

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

org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCounter

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

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.lang.Comparable<Operator>, TezOutput, TezTaskConfigurable, Illustrable

public class POCounterTez
extends POCounter
implements TezOutput, TezTaskConfigurable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

PhysicalOperator.OriginalLocation

Field Summary

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCounter

mTupleFactory, ONE

Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

alias, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType

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

mKey

Constructor Summary

Constructors

Constructor and Description
POCounterTez(POCounter copy)

Method Summary

Methods

Modifier and Type	Method and Description
void	attachOutputs(java.util.Map<java.lang.String,LogicalOutput> outputs, org.apache.hadoop.conf.Configuration conf)
Result	getNextTuple()
java.lang.String[]	getTezOutputs()
protected void	incrementReduceCounter(java.lang.Long increment)
void	initialize(ProcessorContext processorContext)
java.lang.String	name()
void	replaceOutput(java.lang.String oldOutputKey, java.lang.String newOutputKey)
void	setStatsOutputKey(java.lang.String statsOutputKey)
void	setTuplesOutputKey(java.lang.String tuplesOutputKey)
void	visit(PhyPlanVisitor v) Visit this node with the provided visitor.

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POCounter

addCounterValue, addToLocalCounter, getAscendingColumns, getCounterPlans, getLocalCounter, getOperationID, getTaskId, illustratorMarkup, incrementLocalCounter, isDenseRank, isRowNumber, resetLocalCounter, setAscendingColumns, setCounterPlans, setIsDenseRank, setIsRowNumber, setLocalCounter, setOperationID, setTaskId, supportsMultipleInputs, supportsMultipleOutputs

Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator

addOriginalLocation, addOriginalLocation, attachInput, clone, cloneHelper, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup

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

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

POCounterTez

public POCounterTez(POCounter copy)

Method Detail

initialize

public void initialize(ProcessorContext processorContext)
                throws ExecException

Specified by:

initialize in interface TezTaskConfigurable

Throws:

ExecException

setTuplesOutputKey

public void setTuplesOutputKey(java.lang.String tuplesOutputKey)

setStatsOutputKey

public void setStatsOutputKey(java.lang.String statsOutputKey)

getTezOutputs

public java.lang.String[] getTezOutputs()

Specified by:

getTezOutputs in interface TezOutput

replaceOutput

public void replaceOutput(java.lang.String oldOutputKey,
                 java.lang.String newOutputKey)

Specified by:

replaceOutput in interface TezOutput

attachOutputs

public void attachOutputs(java.util.Map<java.lang.String,LogicalOutput> outputs,
                 org.apache.hadoop.conf.Configuration conf)
                   throws ExecException

Specified by:

attachOutputs in interface TezOutput

Throws:

ExecException

getNextTuple

public Result getNextTuple()
                    throws ExecException

Overrides:

getNextTuple in class POCounter

Throws:

ExecException

incrementReduceCounter

protected void incrementReduceCounter(java.lang.Long increment)

Overrides:

incrementReduceCounter in class POCounter

visit

public void visit(PhyPlanVisitor 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 POCounter

Parameters:

v - Visitor to visit with.

Throws:

VisitorException - if the visitor has a problem.

name

public java.lang.String name()

Overrides:

name in class POCounter