public class UDFContextSeparator extends PhyPlanVisitor
Modifier and Type | Class and Description |
---|---|
static class |
UDFContextSeparator.UDFType |
mCurrentWalker, mPlan
Constructor and Description |
---|
UDFContextSeparator() |
Modifier and Type | Method and Description |
---|---|
Set<org.apache.pig.impl.util.UDFContext.UDFContextKey> |
getUnKnownKeys() |
void |
serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
String planOpKey,
POStore store) |
void |
serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
String planOpKey,
UDFContextSeparator.UDFType... udfTypes) |
void |
setPlan(PhysicalPlan plan,
String planOpKey) |
void |
visitCast(POCast op) |
void |
visitLoad(POLoad ld) |
void |
visitStore(POStore st) |
void |
visitUserFunc(POUserFunc userFunc) |
visit, visitAdd, visitAnd, visitBinCond, 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
getPlan, popWalker, pushWalker, visit
public Set<org.apache.pig.impl.util.UDFContext.UDFContextKey> getUnKnownKeys()
public void setPlan(PhysicalPlan plan, String planOpKey)
public void visitUserFunc(POUserFunc userFunc) throws VisitorException
visitUserFunc
in class PhyPlanVisitor
VisitorException
public void visitLoad(POLoad ld) throws VisitorException
visitLoad
in class PhyPlanVisitor
VisitorException
public void visitStore(POStore st) throws VisitorException
visitStore
in class PhyPlanVisitor
VisitorException
public void visitCast(POCast op)
visitCast
in class PhyPlanVisitor
public void serializeUDFContext(org.apache.hadoop.conf.Configuration conf, String planOpKey, UDFContextSeparator.UDFType... udfTypes) throws IOException
IOException
public void serializeUDFContext(org.apache.hadoop.conf.Configuration conf, String planOpKey, POStore store) throws IOException
IOException
Copyright © 2007-2012 The Apache Software Foundation