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

Class HiveParserScriptTransformHelper

java.lang.Object

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

public class HiveParserScriptTransformHelper
extends Object

A helper class to handle script transform in hive dialect.

Constructor Summary

Constructors

Constructor and Description
HiveParserScriptTransformHelper(org.apache.calcite.plan.RelOptCluster cluster, LinkedHashMap<org.apache.calcite.rel.RelNode,HiveParserRowResolver> relToRowResolver, LinkedHashMap<org.apache.calcite.rel.RelNode,Map<String,Integer>> relToHiveColNameCalcitePosMap, HiveConf hiveConf)

Method Summary

Modifier and Type	Method and Description
org.apache.calcite.rel.RelNode	genScriptPlan(HiveParserASTNode trfm, HiveParserQB qb, List<org.apache.calcite.rex.RexNode> operands, org.apache.calcite.rel.RelNode input)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserScriptTransformHelper

public HiveParserScriptTransformHelper(org.apache.calcite.plan.RelOptCluster cluster,
                                       LinkedHashMap<org.apache.calcite.rel.RelNode,HiveParserRowResolver> relToRowResolver,
                                       LinkedHashMap<org.apache.calcite.rel.RelNode,Map<String,Integer>> relToHiveColNameCalcitePosMap,
                                       HiveConf hiveConf)

Method Detail

genScriptPlan

public org.apache.calcite.rel.RelNode genScriptPlan(HiveParserASTNode trfm,
                                                    HiveParserQB qb,
                                                    List<org.apache.calcite.rex.RexNode> operands,
                                                    org.apache.calcite.rel.RelNode input)
                                             throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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