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

Class POFRJoinSpark

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

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

All Implemented Interfaces:

Serializable, Cloneable, Comparable<Operator>, Illustrable

public class POFRJoinSpark
extends POFRJoin

See Also:

Serialized Form

Nested Class Summary

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

POFRJoin.TupleToMapKey

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

constExps, dumTup, fe, fragment, inputSchemas, isLeftOuterJoin, keySchemas, keyTypes, LRs, nullBag, phyPlanLists, processingPlan, replFiles, replicates, setUp

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
POFRJoinSpark(POFRJoin copy)

Method Summary

Modifier and Type	Method and Description
void	attachInputs(Map<String,List<Tuple>> broadcasts)
String	name()
protected void	setUpHashMap() Builds the HashMaps by reading each replicated input from the DFS using a Load operator

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

clone, getFragment, getJoinPlans, getLRs, getNextTuple, getReplFiles, getValueTuple, illustratorMarkup, isKeyNull, isLeftOuterJoin, setFragment, setReplFiles, 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

POFRJoinSpark

public POFRJoinSpark(POFRJoin copy)
              throws ExecException

Throws:

ExecException

Method Detail

setUpHashMap

protected void setUpHashMap()
                     throws ExecException

Description copied from class: POFRJoin

Builds the HashMaps by reading each replicated input from the DFS using a Load operator

Overrides:

setUpHashMap in class POFRJoin

Throws:

ExecException

name

public String name()

Overrides:

name in class POFRJoin

attachInputs

public void attachInputs(Map<String,List<Tuple>> broadcasts)