org.apache.pig.impl.util

Class UDFContextSeparator

java.lang.Object

org.apache.pig.impl.plan.PlanVisitor<PhysicalOperator,PhysicalPlan>

org.apache.pig.backend.hadoop.executionengine.physicalLayer.plans.PhyPlanVisitor

org.apache.pig.impl.util.UDFContextSeparator

public class UDFContextSeparator
extends PhyPlanVisitor

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	UDFContextSeparator.UDFType

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
UDFContextSeparator()

Method Summary

Modifier and Type	Method and Description
java.util.Set<org.apache.pig.impl.util.UDFContext.UDFContextKey>	getUnKnownKeys()
void	serializeUDFContext(org.apache.hadoop.conf.Configuration conf, java.lang.String planOpKey, POStore store)
void	serializeUDFContext(org.apache.hadoop.conf.Configuration conf, java.lang.String planOpKey, UDFContextSeparator.UDFType... udfTypes)
void	setPlan(PhysicalPlan plan, java.lang.String planOpKey)
void	visitCast(POCast op)
void	visitLoad(POLoad ld)
void	visitStore(POStore st)
void	visitUserFunc(POUserFunc userFunc)

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

visit, visitAdd, visitAnd, visitBinCond, visitBroadcastSpark, visitCollectedGroup, visitComparisonFunc, visitConstant, visitCounter, visitCross, visitDemux, visitDistinct, visitDivide, visitEqualTo, visitFilter, visitFRJoin, visitGlobalRearrange, visitGreaterThan, visitGTOrEqual, visitIsNull, visitLessThan, visitLimit, visitLocalRearrange, visitLTOrEqual, visitMapLookUp, visitMergeCoGroup, visitMergeJoin, visitMod, visitMultiply, visitNative, visitNegative, visitNot, visitNotEqualTo, visitOr, visitPackage, visitPartialAgg, visitPartitionRearrange, visitPOForEach, visitPoissonSample, visitPOOptimizedForEach, visitPreCombinerLocalRearrange, visitProject, visitRank, visitRegexp, visitReservoirSample, visitSkewedJoin, visitSort, visitSplit, visitStream, visitSubtract, visitUnion

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

getPlan, popWalker, pushWalker, visit

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UDFContextSeparator

public UDFContextSeparator()

Method Detail

getUnKnownKeys

public java.util.Set<org.apache.pig.impl.util.UDFContext.UDFContextKey> getUnKnownKeys()

setPlan

public void setPlan(PhysicalPlan plan,
                    java.lang.String planOpKey)

visitUserFunc

public void visitUserFunc(POUserFunc userFunc)
                   throws VisitorException

Overrides:

visitUserFunc in class PhyPlanVisitor

Throws:

VisitorException

visitLoad

public void visitLoad(POLoad ld)
               throws VisitorException

Overrides:

visitLoad in class PhyPlanVisitor

Throws:

VisitorException

visitStore

public void visitStore(POStore st)
                throws VisitorException

Overrides:

visitStore in class PhyPlanVisitor

Throws:

VisitorException

visitCast

public void visitCast(POCast op)

Overrides:

visitCast in class PhyPlanVisitor

serializeUDFContext

public void serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
                                java.lang.String planOpKey,
                                UDFContextSeparator.UDFType... udfTypes)
                         throws java.io.IOException

Throws:

java.io.IOException

serializeUDFContext

public void serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
                                java.lang.String planOpKey,
                                POStore store)
                         throws java.io.IOException

Throws:

java.io.IOException