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

Class POMergeCogroupTez

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

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

All Implemented Interfaces:

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

public class POMergeCogroupTez
extends POMergeCogroup
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
POMergeCogroupTez(OperatorKey k, java.util.List<PhysicalOperator> inpPOs, POLocalRearrange[] lrs, int parallel)
POMergeCogroupTez(POMergeCogroup 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.
POMergeCogroupTez	clone() Make a copy of this operator.
java.lang.String[]	getTezInputs()
java.lang.String	name()
protected java.util.List<Pair<java.lang.Integer,Tuple>>	readIndex()
void	replaceInput(java.lang.String oldInputKey, java.lang.String newInputKey)
void	setInputKey(java.lang.String inputKey)

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

addTupleToIndex, getIdxFuncSpec, getIndexFileName, getLRInnerPlansOf, getNextTuple, illustratorMarkup, isEndOfInput, setEndOfInput, setEndOfRecordMark, setIdxFuncSpec, setIndexFileName, setLoaderSignatures, setSideFileSpecs, setSideLoadFuncs, supportsMultipleInputs, supportsMultipleOutputs, visit

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

POMergeCogroupTez

public POMergeCogroupTez(OperatorKey k,
                         java.util.List<PhysicalOperator> inpPOs,
                         POLocalRearrange[] lrs,
                         int parallel)

POMergeCogroupTez

public POMergeCogroupTez(POMergeCogroup copy)

Method Detail

setInputKey

public void setInputKey(java.lang.String inputKey)

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

name

public java.lang.String name()

Overrides:

name in class POMergeCogroup

readIndex

protected java.util.List<Pair<java.lang.Integer,Tuple>> readIndex()

Overrides:

readIndex in class POMergeCogroup

clone

public POMergeCogroupTez clone()
                        throws java.lang.CloneNotSupportedException

Description copied from class: PhysicalOperator

Make a copy of this operator. This function is blank, however, we should leave a place holder so that the subclasses can clone to make deep copy as this one creates a shallow copy of non-primitive types (objects, arrays and lists)

Overrides:

clone in class POMergeCogroup

Throws:

java.lang.CloneNotSupportedException

See Also:

Do not use the clone method directly. Operators are cloned when logical plans are cloned using {@link LogicalPlanCloner}