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

Class PORankTez

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.PORank

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

All Implemented Interfaces:

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

public class PORankTez
extends PORank
implements TezInput

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.PhysicalOperator

alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, 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
PORankTez(PORank copy)

Method Summary

Modifier and Type	Method and Description
void	addInputsToSkip(java.util.Set<java.lang.String> inputsToSkip) Add to the list of inputs to skip download if already available in vertex cache
void	attachInputs(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf) Attach the inputs to the operator.
Result	getNextTuple()
protected java.lang.Long	getRankCounterOffset(java.lang.Integer taskId)
java.lang.String[]	getTezInputs()
java.lang.String	name()
void	replaceInput(java.lang.String oldInputKey, java.lang.String newInputKey)
void	setStatsInputKey(java.lang.String statsInputKey)
void	setTuplesInputKey(java.lang.String tuplesInputKey)
void	visit(PhyPlanVisitor v) Visit this node with the provided visitor.

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

addRank, clone, getAscendingCols, getOperationID, getRankPlans, illustratorMarkup, setAscendingCols, setOperationID, setRankPlans, supportsMultipleInputs, supportsMultipleOutputs

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

addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, 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

PORankTez

public PORankTez(PORank copy)

Method Detail

setTuplesInputKey

public void setTuplesInputKey(java.lang.String tuplesInputKey)

setStatsInputKey

public void setStatsInputKey(java.lang.String statsInputKey)

getTezInputs

public java.lang.String[] getTezInputs()

Specified by:

getTezInputs in interface TezInput

replaceInput

public void replaceInput(java.lang.String oldInputKey,
                         java.lang.String newInputKey)

Specified by:

replaceInput in interface TezInput

addInputsToSkip

public void addInputsToSkip(java.util.Set<java.lang.String> inputsToSkip)

Description copied from interface: TezInput

Add to the list of inputs to skip download if already available in vertex cache

Specified by:

addInputsToSkip in interface TezInput

attachInputs

public void attachInputs(java.util.Map<java.lang.String,org.apache.tez.runtime.api.LogicalInput> inputs,
                         org.apache.hadoop.conf.Configuration conf)
                  throws ExecException

Description copied from interface: TezInput

Attach the inputs to the operator. Also ensure reader.next() is called to force fetch the input so that all inputs are fetched and memory released before memory is allocated for outputs

Specified by:

attachInputs in interface TezInput

Parameters:

inputs - available inputs

conf - configuration

Throws:

ExecException

getNextTuple

public Result getNextTuple()
                    throws ExecException

Overrides:

getNextTuple in class PORank

Throws:

ExecException

getRankCounterOffset

protected java.lang.Long getRankCounterOffset(java.lang.Integer taskId)

Overrides:

getRankCounterOffset in class PORank

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 PORank

Parameters:

v - Visitor to visit with.

Throws:

VisitorException - if the visitor has a problem.

name

public java.lang.String name()

Overrides:

name in class PORank