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

Class HiveParserSqlFunctionConverter

java.lang.Object

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

public class HiveParserSqlFunctionConverter
extends Object

Counterpart of hive's org.apache.hadoop.hive.ql.optimizer.calcite.translator.SqlFunctionConverter.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HiveParserSqlFunctionConverter.CalciteSqlFn CalciteSqlFn.
static interface	HiveParserSqlFunctionConverter.CanAggregateDistinct CanAggregateDistinct.

Constructor Summary

Constructors

Constructor and Description
HiveParserSqlFunctionConverter()

Method Summary

Modifier and Type	Method and Description
static org.apache.calcite.sql.SqlAggFunction	getCalciteAggFn(String hiveUdfName, boolean isDistinct, List<org.apache.calcite.rel.type.RelDataType> calciteArgTypes, org.apache.calcite.rel.type.RelDataType calciteRetType)
static org.apache.calcite.sql.SqlOperator	getCalciteFn(String hiveUdfName, List<org.apache.calcite.rel.type.RelDataType> calciteArgTypes, org.apache.calcite.rel.type.RelDataType calciteRetType, boolean deterministic, SqlFunctionConverter functionConverter)
static org.apache.calcite.sql.SqlOperator	getCalciteOperator(String funcTextName, org.apache.hadoop.hive.ql.udf.generic.GenericUDF hiveUDF, List<org.apache.calcite.rel.type.RelDataType> calciteArgTypes, org.apache.calcite.rel.type.RelDataType retType, SqlFunctionConverter functionConverter)

Methods inherited from class java.lang.Object

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

Constructor Detail

HiveParserSqlFunctionConverter

public HiveParserSqlFunctionConverter()

Method Detail

getCalciteOperator

public static org.apache.calcite.sql.SqlOperator getCalciteOperator(String funcTextName,
                                                                    org.apache.hadoop.hive.ql.udf.generic.GenericUDF hiveUDF,
                                                                    List<org.apache.calcite.rel.type.RelDataType> calciteArgTypes,
                                                                    org.apache.calcite.rel.type.RelDataType retType,
                                                                    SqlFunctionConverter functionConverter)
                                                             throws org.apache.hadoop.hive.ql.parse.SemanticException

Throws:

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

getCalciteFn

public static org.apache.calcite.sql.SqlOperator getCalciteFn(String hiveUdfName,
                                                              List<org.apache.calcite.rel.type.RelDataType> calciteArgTypes,
                                                              org.apache.calcite.rel.type.RelDataType calciteRetType,
                                                              boolean deterministic,
                                                              SqlFunctionConverter functionConverter)

getCalciteAggFn

public static org.apache.calcite.sql.SqlAggFunction getCalciteAggFn(String hiveUdfName,
                                                                    boolean isDistinct,
                                                                    List<org.apache.calcite.rel.type.RelDataType> calciteArgTypes,
                                                                    org.apache.calcite.rel.type.RelDataType calciteRetType)