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(CalciteContext calciteContext, SqlFunctionConverter funcConverter, CatalogRegistry catalogRegistry)

Method Summary

Modifier and Type	Method and Description
Operation	createInsertOperation(HiveParserCalcitePlanner analyzer, org.apache.calcite.rel.RelNode queryRelNode)
Tuple4<ObjectIdentifier,QueryOperation,Map<String,String>,Boolean>	createInsertOperationInfo(org.apache.calcite.rel.RelNode queryRelNode, CatalogTable destTable, ObjectIdentifier destTableIdentifier, 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(CalciteContext calciteContext,
                           SqlFunctionConverter funcConverter,
                           CatalogRegistry catalogRegistry)

Method Detail

createInsertOperationInfo

public Tuple4<ObjectIdentifier,QueryOperation,Map<String,String>,Boolean> createInsertOperationInfo(org.apache.calcite.rel.RelNode queryRelNode,
                                                                                                    CatalogTable destTable,
                                                                                                    ObjectIdentifier destTableIdentifier,
                                                                                                    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