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

Class HiveParserTypeCheckCtx

java.lang.Object

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

All Implemented Interfaces:

org.apache.hadoop.hive.ql.lib.NodeProcessorCtx

Direct Known Subclasses:

HiveParserJoinTypeCheckCtx

public class HiveParserTypeCheckCtx
extends Object
implements org.apache.hadoop.hive.ql.lib.NodeProcessorCtx

Counterpart of hive's org.apache.hadoop.hive.ql.parse.TypeCheckCtx.

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
HiveParserTypeCheckCtx(HiveParserRowResolver inputRR, boolean useCaching, boolean foldExpr, boolean allowStatefulFunctions, boolean allowDistinctFunctions, boolean allowGBExprElimination, boolean allowAllColRef, boolean allowFunctionStar, boolean allowWindowing, boolean allowIndexExpr, boolean allowSubQueryExpr, org.apache.calcite.tools.FrameworkConfig frameworkConfig, org.apache.calcite.plan.RelOptCluster cluster)
HiveParserTypeCheckCtx(HiveParserRowResolver inputRR, boolean useCaching, boolean foldExpr, org.apache.calcite.tools.FrameworkConfig frameworkConfig, org.apache.calcite.plan.RelOptCluster cluster)
HiveParserTypeCheckCtx(HiveParserRowResolver inputRR, org.apache.calcite.tools.FrameworkConfig frameworkConfig, org.apache.calcite.plan.RelOptCluster cluster) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	getallowAllColRef()
boolean	getAllowDistinctFunctions()
boolean	getallowFunctionStar()
boolean	getAllowGBExprElimination()
boolean	getallowIndexExpr()
boolean	getAllowStatefulFunctions()
boolean	getallowSubQueryExpr()
boolean	getallowWindowing()
org.apache.calcite.plan.RelOptCluster	getCluster()
String	getError()
HiveParserASTNode	getErrorSrcNode()
HiveParserRowResolver	getInputRR()
HiveParserRowResolver	getOuterRR()
org.apache.calcite.sql.SqlOperatorTable	getSqlOperatorTable()
Map<HiveParserASTNode,org.apache.calcite.rel.RelNode>	getSubqueryToRelNode()
org.apache.calcite.rel.type.RelDataTypeFactory	getTypeFactory()
HiveParserUnparseTranslator	getUnparseTranslator()
boolean	isFoldExpr()
boolean	isUseCaching()
void	setAllowDistinctFunctions(boolean allowDistinctFunctions)
void	setAllowStatefulFunctions(boolean allowStatefulFunctions)
void	setError(String error, HiveParserASTNode errorSrcNode)
void	setInputRR(HiveParserRowResolver inputRR)
void	setOuterRR(HiveParserRowResolver outerRR)
void	setSubqueryToRelNode(Map<HiveParserASTNode,org.apache.calcite.rel.RelNode> subqueryToRelNode)
void	setUnparseTranslator(HiveParserUnparseTranslator unparseTranslator)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final org.slf4j.Logger LOG

Constructor Detail

HiveParserTypeCheckCtx

public HiveParserTypeCheckCtx(HiveParserRowResolver inputRR,
                              org.apache.calcite.tools.FrameworkConfig frameworkConfig,
                              org.apache.calcite.plan.RelOptCluster cluster)

Constructor.

Parameters:

inputRR - The input row resolver of the previous operator.

HiveParserTypeCheckCtx

public HiveParserTypeCheckCtx(HiveParserRowResolver inputRR,
                              boolean useCaching,
                              boolean foldExpr,
                              org.apache.calcite.tools.FrameworkConfig frameworkConfig,
                              org.apache.calcite.plan.RelOptCluster cluster)

HiveParserTypeCheckCtx

public HiveParserTypeCheckCtx(HiveParserRowResolver inputRR,
                              boolean useCaching,
                              boolean foldExpr,
                              boolean allowStatefulFunctions,
                              boolean allowDistinctFunctions,
                              boolean allowGBExprElimination,
                              boolean allowAllColRef,
                              boolean allowFunctionStar,
                              boolean allowWindowing,
                              boolean allowIndexExpr,
                              boolean allowSubQueryExpr,
                              org.apache.calcite.tools.FrameworkConfig frameworkConfig,
                              org.apache.calcite.plan.RelOptCluster cluster)

Method Detail

setInputRR

public void setInputRR(HiveParserRowResolver inputRR)

Parameters:

inputRR - the inputRR to set

getInputRR

public HiveParserRowResolver getInputRR()

Returns:

the inputRR

setOuterRR

public void setOuterRR(HiveParserRowResolver outerRR)

Parameters:

outerRR - the outerRR to set

getOuterRR

public HiveParserRowResolver getOuterRR()

Returns:

the outerRR

setSubqueryToRelNode

public void setSubqueryToRelNode(Map<HiveParserASTNode,org.apache.calcite.rel.RelNode> subqueryToRelNode)

Parameters:

subqueryToRelNode - the subqueryToRelNode to set

getSubqueryToRelNode

public Map<HiveParserASTNode,org.apache.calcite.rel.RelNode> getSubqueryToRelNode()

Returns:

the outerRR

setUnparseTranslator

public void setUnparseTranslator(HiveParserUnparseTranslator unparseTranslator)

Parameters:

unparseTranslator - the unparseTranslator to set

getUnparseTranslator

public HiveParserUnparseTranslator getUnparseTranslator()

Returns:

the unparseTranslator

setAllowStatefulFunctions

public void setAllowStatefulFunctions(boolean allowStatefulFunctions)

Parameters:

allowStatefulFunctions - whether to allow stateful UDF invocations

getAllowStatefulFunctions

public boolean getAllowStatefulFunctions()

Returns:

whether to allow stateful UDF invocations

setError

public void setError(String error,
                     HiveParserASTNode errorSrcNode)

Parameters:

error - the error to set

getError

public String getError()

Returns:

the error

getErrorSrcNode

public HiveParserASTNode getErrorSrcNode()

setAllowDistinctFunctions

public void setAllowDistinctFunctions(boolean allowDistinctFunctions)

getAllowDistinctFunctions

public boolean getAllowDistinctFunctions()

getAllowGBExprElimination

public boolean getAllowGBExprElimination()

getallowAllColRef

public boolean getallowAllColRef()

getallowFunctionStar

public boolean getallowFunctionStar()

getallowWindowing

public boolean getallowWindowing()

getallowIndexExpr

public boolean getallowIndexExpr()

getallowSubQueryExpr

public boolean getallowSubQueryExpr()

isUseCaching

public boolean isUseCaching()

isFoldExpr

public boolean isFoldExpr()

getSqlOperatorTable

public org.apache.calcite.sql.SqlOperatorTable getSqlOperatorTable()

getTypeFactory

public org.apache.calcite.rel.type.RelDataTypeFactory getTypeFactory()

getCluster

public org.apache.calcite.plan.RelOptCluster getCluster()