org.apache.hadoop.hive.ql.optimizer.lineage

Class ExprProcFactory

java.lang.Object

org.apache.hadoop.hive.ql.optimizer.lineage.ExprProcFactory

public class ExprProcFactory
extends Object

Expression processor factory for lineage. Each processor is responsible to create the leaf level column info objects that the expression depends upon and also generates a string representation of the expression.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ExprProcFactory.ColumnExprProcessor Processor for column expressions.
static class	ExprProcFactory.DefaultExprProcessor Processor for constants and null expressions.
static class	ExprProcFactory.GenericExprProcessor Processor for any function or field expression.

Constructor Summary

Constructors

Constructor and Description
ExprProcFactory()

Method Summary

Modifier and Type	Method and Description
static NodeProcessor	getColumnProcessor()
static NodeProcessor	getDefaultExprProcessor()
static LineageInfo.Dependency	getExprDependency(LineageCtx lctx, Operator<? extends OperatorDesc> inpOp, ExprNodeDesc expr) Gets the expression dependencies for the expression.
static LineageInfo.Dependency	getExprDependency(LineageCtx lctx, Operator<? extends OperatorDesc> inpOp, ExprNodeDesc expr, HashMap<Node,Object> outputMap) Gets the expression dependencies for the expression.
static String	getExprString(RowSchema rs, ExprNodeDesc expr, LineageCtx lctx, Operator<? extends OperatorDesc> inpOp, LineageInfo.Predicate cond) Get the expression string of an expression node.
static NodeProcessor	getFieldProcessor()
static NodeProcessor	getGenericFuncProcessor()

Methods inherited from class java.lang.Object

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

Constructor Detail

ExprProcFactory

public ExprProcFactory()

Method Detail

getDefaultExprProcessor

public static NodeProcessor getDefaultExprProcessor()

getGenericFuncProcessor

public static NodeProcessor getGenericFuncProcessor()

getFieldProcessor

public static NodeProcessor getFieldProcessor()

getColumnProcessor

public static NodeProcessor getColumnProcessor()

getExprString

public static String getExprString(RowSchema rs,
                                   ExprNodeDesc expr,
                                   LineageCtx lctx,
                                   Operator<? extends OperatorDesc> inpOp,
                                   LineageInfo.Predicate cond)

Get the expression string of an expression node.

getExprDependency

public static LineageInfo.Dependency getExprDependency(LineageCtx lctx,
                                                       Operator<? extends OperatorDesc> inpOp,
                                                       ExprNodeDesc expr)
                                                throws SemanticException

Gets the expression dependencies for the expression.

Parameters:

lctx - The lineage context containing the input operators dependencies.

inpOp - The input operator to the current operator.

expr - The expression that is being processed.

Throws:

SemanticException

getExprDependency

public static LineageInfo.Dependency getExprDependency(LineageCtx lctx,
                                                       Operator<? extends OperatorDesc> inpOp,
                                                       ExprNodeDesc expr,
                                                       HashMap<Node,Object> outputMap)
                                                throws SemanticException

Gets the expression dependencies for the expression.

Parameters:

lctx - The lineage context containing the input operators dependencies.

inpOp - The input operator to the current operator.

expr - The expression that is being processed.

outputMap -

Throws:

SemanticException