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

Class POShuffleTezLoad

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

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

All Implemented Interfaces:

Serializable, Cloneable, Comparable<Operator>, TezInput, Illustrable

public class POShuffleTezLoad
extends POPackage
implements TezInput

See Also:

Serialized Form

Nested Class Summary

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

POPackage.POPackageTupleBuffer

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

PhysicalOperator.OriginalLocation

Field Summary

Fields

Modifier and Type	Field and Description
protected List<String>	inputKeys

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

key, keyWritable, mBagFactory, mTupleFactory, numInputs, pkgr

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

alias, illustrator, input, inputAttached, 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
POShuffleTezLoad(POPackage pack)

Method Summary

Methods

Modifier and Type	Method and Description
void	addInputKey(String inputKey)
void	addInputsToSkip(Set<String> inputsToSkip) Add to the list of inputs to skip download if already available in vertex cache
void	attachInputs(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs, org.apache.hadoop.conf.Configuration conf)
Result	getNextTuple() From the inputs, constructs the output tuple for this co-group in the required format which is (key, {bag of tuples from input 1}, {bag of tuples from input 2}, ...)
String[]	getTezInputs()
boolean	isSkewedJoin()
void	replaceInput(String oldInputKey, String newInputKey)
void	setInputKeys(List<String> inputKeys)
void	setSkewedJoins(boolean isSkewedJoin)
boolean	supportsMultipleInputs() Indicates whether this operator supports multiple inputs.

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

attachInput, clone, detachInput, getNumInps, getPkgr, illustratorMarkup, name, numberOfEquivalenceClasses, setIllustrator, setNumInps, setPkgr, supportsMultipleOutputs, visit

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

addOriginalLocation, addOriginalLocation, attachInput, cloneHelper, copyAliasFrom, 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, 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

Field Detail

inputKeys

protected List<String> inputKeys

Constructor Detail

POShuffleTezLoad

public POShuffleTezLoad(POPackage pack)

Method Detail

getTezInputs

public String[] getTezInputs()

Specified by:

getTezInputs in interface TezInput

replaceInput

public void replaceInput(String oldInputKey,
                String newInputKey)

Specified by:

replaceInput in interface TezInput

addInputsToSkip

public void addInputsToSkip(Set<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(Map<String,org.apache.tez.runtime.api.LogicalInput> inputs,
                org.apache.hadoop.conf.Configuration conf)
                  throws ExecException

Specified by:

attachInputs in interface TezInput

Throws:

ExecException

getNextTuple

public Result getNextTuple()
                    throws ExecException

Description copied from class: POPackage

From the inputs, constructs the output tuple for this co-group in the required format which is (key, {bag of tuples from input 1}, {bag of tuples from input 2}, ...)

Overrides:

getNextTuple in class POPackage

Throws:

ExecException

setInputKeys

public void setInputKeys(List<String> inputKeys)

addInputKey

public void addInputKey(String inputKey)

setSkewedJoins

public void setSkewedJoins(boolean isSkewedJoin)

isSkewedJoin

public boolean isSkewedJoin()

supportsMultipleInputs

public boolean supportsMultipleInputs()

Description copied from class: Operator

Indicates whether this operator supports multiple inputs.

Overrides:

supportsMultipleInputs in class POPackage

Returns:

true if it does, otherwise false.