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

Class HiveParserDMLHelper

java.lang.Object

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

public class HiveParserDMLHelper
extends Object

A helper class to handle DMLs in hive dialect.

Constructor Summary

Constructors

Constructor and Description
HiveParserDMLHelper(PlannerContext plannerContext, SqlFunctionConverter funcConverter, CatalogManager catalogManager)

Method Summary

Modifier and Type	Method and Description
Operation	createInsertOperation(HiveParserCalcitePlanner analyzer, org.apache.calcite.rel.RelNode queryRelNode)
CatalogSinkModifyOperation	createInsertOperation(org.apache.calcite.rel.RelNode queryRelNode, org.apache.hadoop.hive.ql.metadata.Table destTable, Map<String,String> staticPartSpec, List<String> destSchema, boolean overwrite)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserDMLHelper

public HiveParserDMLHelper(PlannerContext plannerContext,
                           SqlFunctionConverter funcConverter,
                           CatalogManager catalogManager)

Method Detail

createInsertOperation

public CatalogSinkModifyOperation createInsertOperation(org.apache.calcite.rel.RelNode queryRelNode,
                                                        org.apache.hadoop.hive.ql.metadata.Table destTable,
                                                        Map<String,String> staticPartSpec,
                                                        List<String> destSchema,
                                                        boolean overwrite)
                                                 throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

createInsertOperation

public Operation createInsertOperation(HiveParserCalcitePlanner analyzer,
                                       org.apache.calcite.rel.RelNode queryRelNode)
                                throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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