org.apache.pig.backend.hadoop.executionengine.tez.util

Class TezUDFContextSeparator

java.lang.Object

org.apache.pig.impl.plan.PlanVisitor<TezOperator,TezOperPlan>

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

org.apache.pig.backend.hadoop.executionengine.tez.util.TezUDFContextSeparator

public class TezUDFContextSeparator
extends TezOpPlanVisitor

Field Summary

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

mCurrentWalker, mPlan

Constructor Summary

Constructors

Constructor and Description
TezUDFContextSeparator(TezOperPlan plan, PlanWalker<TezOperator,TezOperPlan> walker)

Method Summary

Modifier and Type	Method and Description
void	serializeUDFContext(org.apache.hadoop.conf.Configuration conf, TezOperator tezOp)
void	serializeUDFContext(org.apache.hadoop.conf.Configuration conf, TezOperator tezOp, POStore store)
void	serializeUDFContext(org.apache.hadoop.conf.Configuration conf, TezOperator tezOp, UDFContextSeparator.UDFType udfType)
void	serializeUDFContextForEdge(org.apache.hadoop.conf.Configuration conf, TezOperator from, TezOperator to, UDFContextSeparator.UDFType udfType)
void	visitTezOp(TezOperator tezOperator)

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

TezUDFContextSeparator

public TezUDFContextSeparator(TezOperPlan plan,
                              PlanWalker<TezOperator,TezOperPlan> walker)

Method Detail

visitTezOp

public void visitTezOp(TezOperator tezOperator)
                throws VisitorException

Overrides:

visitTezOp in class TezOpPlanVisitor

Throws:

VisitorException

serializeUDFContext

public void serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
                                TezOperator tezOp)
                         throws java.io.IOException

Throws:

java.io.IOException

serializeUDFContext

public void serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
                                TezOperator tezOp,
                                UDFContextSeparator.UDFType udfType)
                         throws java.io.IOException

Throws:

java.io.IOException

serializeUDFContextForEdge

public void serializeUDFContextForEdge(org.apache.hadoop.conf.Configuration conf,
                                       TezOperator from,
                                       TezOperator to,
                                       UDFContextSeparator.UDFType udfType)
                                throws java.io.IOException

Throws:

java.io.IOException

serializeUDFContext

public void serializeUDFContext(org.apache.hadoop.conf.Configuration conf,
                                TezOperator tezOp,
                                POStore store)
                         throws java.io.IOException

Throws:

java.io.IOException