org.apache.flink.table.planner.delegation.hive

Class HiveParserTypeCheckProcFactory.DefaultExprProcessor

java.lang.Object

org.apache.flink.table.planner.delegation.hive.HiveParserTypeCheckProcFactory.DefaultExprProcessor

All Implemented Interfaces:

org.apache.hadoop.hive.ql.lib.NodeProcessor

Direct Known Subclasses:

HiveParserJoinCondTypeCheckProcFactory.JoinCondDefaultExprProcessor

Enclosing class:

HiveParserTypeCheckProcFactory

public static class HiveParserTypeCheckProcFactory.DefaultExprProcessor
extends Object
implements org.apache.hadoop.hive.ql.lib.NodeProcessor

The default processor for typechecking.

Constructor Summary

Constructors

Constructor and Description
DefaultExprProcessor()

Method Summary

Modifier and Type	Method and Description
static org.apache.hadoop.hive.ql.plan.ExprNodeDesc	getFuncExprNodeDescWithUdfData(String udfName, org.apache.hadoop.hive.serde2.typeinfo.TypeInfo typeInfo, org.apache.hadoop.hive.ql.plan.ExprNodeDesc... children) This function create an ExprNodeDesc for a UDF function given the children (arguments).
static String	getFunctionText(HiveParserASTNode expr, boolean isFunction)
protected List<String>	getReferenceableColumnAliases(HiveParserTypeCheckCtx ctx)
protected org.apache.hadoop.hive.ql.plan.ExprNodeDesc	getXpathOrFuncExprNodeDesc(HiveParserASTNode expr, boolean isFunction, ArrayList<org.apache.hadoop.hive.ql.plan.ExprNodeDesc> children, HiveParserTypeCheckCtx ctx)
protected static boolean	isRedundantConversionFunction(HiveParserASTNode expr, boolean isFunction, ArrayList<org.apache.hadoop.hive.ql.plan.ExprNodeDesc> children)
Object	process(org.apache.hadoop.hive.ql.lib.Node nd, Stack<org.apache.hadoop.hive.ql.lib.Node> stack, org.apache.hadoop.hive.ql.lib.NodeProcessorCtx procCtx, Object... nodeOutputs)
protected org.apache.hadoop.hive.ql.plan.ExprNodeDesc	processQualifiedColRef(HiveParserTypeCheckCtx ctx, HiveParserASTNode expr, Object... nodeOutputs)
protected void	validateUDF(HiveParserASTNode expr, boolean isFunction, HiveParserTypeCheckCtx ctx, org.apache.hadoop.hive.ql.exec.FunctionInfo fi, org.apache.hadoop.hive.ql.udf.generic.GenericUDF genericUDF)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultExprProcessor

public DefaultExprProcessor()

Method Detail

isRedundantConversionFunction

protected static boolean isRedundantConversionFunction(HiveParserASTNode expr,
                                                       boolean isFunction,
                                                       ArrayList<org.apache.hadoop.hive.ql.plan.ExprNodeDesc> children)

getFunctionText

public static String getFunctionText(HiveParserASTNode expr,
                                     boolean isFunction)

getFuncExprNodeDescWithUdfData

public static org.apache.hadoop.hive.ql.plan.ExprNodeDesc getFuncExprNodeDescWithUdfData(String udfName,
                                                                                         org.apache.hadoop.hive.serde2.typeinfo.TypeInfo typeInfo,
                                                                                         org.apache.hadoop.hive.ql.plan.ExprNodeDesc... children)
                                                                                  throws org.apache.hadoop.hive.ql.exec.UDFArgumentException

This function create an ExprNodeDesc for a UDF function given the children (arguments). It will insert implicit type conversion functions if necessary. Currently this is only used to handle CAST with hive UDFs. So no need to check flink functions.

Throws:

org.apache.hadoop.hive.ql.exec.UDFArgumentException

validateUDF

protected void validateUDF(HiveParserASTNode expr,
                           boolean isFunction,
                           HiveParserTypeCheckCtx ctx,
                           org.apache.hadoop.hive.ql.exec.FunctionInfo fi,
                           org.apache.hadoop.hive.ql.udf.generic.GenericUDF genericUDF)
                    throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

getXpathOrFuncExprNodeDesc

protected org.apache.hadoop.hive.ql.plan.ExprNodeDesc getXpathOrFuncExprNodeDesc(HiveParserASTNode expr,
                                                                                 boolean isFunction,
                                                                                 ArrayList<org.apache.hadoop.hive.ql.plan.ExprNodeDesc> children,
                                                                                 HiveParserTypeCheckCtx ctx)
                                                                          throws org.apache.hadoop.hive.ql.parse.SemanticException,
                                                                                 org.apache.hadoop.hive.ql.exec.UDFArgumentException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

org.apache.hadoop.hive.ql.exec.UDFArgumentException

processQualifiedColRef

protected org.apache.hadoop.hive.ql.plan.ExprNodeDesc processQualifiedColRef(HiveParserTypeCheckCtx ctx,
                                                                             HiveParserASTNode expr,
                                                                             Object... nodeOutputs)
                                                                      throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

process

public Object process(org.apache.hadoop.hive.ql.lib.Node nd,
                      Stack<org.apache.hadoop.hive.ql.lib.Node> stack,
                      org.apache.hadoop.hive.ql.lib.NodeProcessorCtx procCtx,
                      Object... nodeOutputs)
               throws org.apache.hadoop.hive.ql.parse.SemanticException

Specified by:

process in interface org.apache.hadoop.hive.ql.lib.NodeProcessor

Throws:

org.apache.hadoop.hive.ql.parse.SemanticException

getReferenceableColumnAliases

protected List<String> getReferenceableColumnAliases(HiveParserTypeCheckCtx ctx)