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

Class HiveParserCalcitePlanner

java.lang.Object

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

public class HiveParserCalcitePlanner
extends Object

Ported Hive's CalcitePlanner.

Constructor Summary

Constructors

Constructor and Description
HiveParserCalcitePlanner(HiveParserQueryState queryState, PlannerContext plannerContext, FlinkCalciteCatalogReader catalogReader, org.apache.calcite.tools.FrameworkConfig frameworkConfig, CatalogManager catalogManager)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rel.RelNode	genLogicalPlan(HiveParserASTNode ast)
List<String>	getDestSchemaForClause(String clause)
HiveParserQB	getQB()
void	init(boolean clearPartsCache)
void	initCtx(HiveParserContext context)
void	setCreatViewInfo(HiveParserCreateViewInfo createViewInfo)
void	setCtasCols(List<org.apache.hadoop.hive.metastore.api.FieldSchema> ctasCols)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserCalcitePlanner

public HiveParserCalcitePlanner(HiveParserQueryState queryState,
                                PlannerContext plannerContext,
                                FlinkCalciteCatalogReader catalogReader,
                                org.apache.calcite.tools.FrameworkConfig frameworkConfig,
                                CatalogManager catalogManager)
                         throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

Method Detail

setCtasCols

public void setCtasCols(List<org.apache.hadoop.hive.metastore.api.FieldSchema> ctasCols)

setCreatViewInfo

public void setCreatViewInfo(HiveParserCreateViewInfo createViewInfo)

initCtx

public void initCtx(HiveParserContext context)

init

public void init(boolean clearPartsCache)

getQB

public HiveParserQB getQB()

genLogicalPlan

public org.apache.calcite.rel.RelNode genLogicalPlan(HiveParserASTNode ast)
                                              throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

getDestSchemaForClause

public List<String> getDestSchemaForClause(String clause)