Bulk Operation

FLINK-26360 Flink hive parser considers literal floating point number differently than Hive SQL

FLINK-26360 Hive dialect supports add jar

FLINK-26360 Introduce operation execution plugin

FLINK-26360 HiveFunctionWrapper should use UserClassLoader to load class

FLINK-26360 Support Hive's UDAF which implement GenericUDAFResolver

FLINK-26360 Exception will be thrown when over window contains grouping in Hive Dialect

FLINK-26360 IndexOutOfBoundsException is thrown when project contains window which dosen't refer all fields of input when using Hive dialect

FLINK-26360 Hive dialect support set variable

FLINK-26360 Hive dialect support "tablesample (xx rows)"

FLINK-26360 HiveInspectors should use correct writable type to creaet ConstantObjectInspector

FLINK-26360 Hive dialect support INTERVAL type

FLINK-26360 Fix fail to count mutiple fields excpetion in Hive dialect

FLINK-26360 Hive dialect supports "select current_database()"

FLINK-26360 Support subdirectories with Hive tables

FLINK-26360 Support partition filter push down when there exists default_parition

FLINK-26360 Fail to call Hive UDAF when the UDAF is with only one parameter with array type

FLINK-26360 Supports read Hive table partitioned by decimal type

FLINK-26360 Fix divide by zero exception in Hive dialect

FLINK-26360 Improve supporting for complex data type for Hive dialect

FLINK-26360 Fix exception for casting timestamp to decimal in Hive dialect

FLINK-26360 Hive dialect supports IS_DISTINCT_FROM

FLINK-26360 Fix incomparable exception between boolean type and numeric type in Hive dialect

FLINK-26360 Fix "schema of both sides of union should match" exception when one side of union select multiple same coulmns

FLINK-26360 Support handle join involving complex types in on condition

FLINK-26360 Fix IndexOutOfBoundsException for non equality condition exists in left semi join in Hive dialect

FLINK-26360 Fail to call hive udf when secondary parameter required constant but pass value like "-1"

FLINK-26360 Hive dialect supports "MACRO"

FLINK-26360 Hive dialect support "LOAD DATA INPATH"

FLINK-26360 Hive dialect supports "CREATE FUNCTION USING xxx.jar"

FLINK-26360 Hive dialect supports CLUSTERED BY/ SORTED BY table

FLINK-26360 support hive transform using syntax

FLINK-26360 Support read hive variables using the syntax like select ${hiveconf:select_time}

FLINK-26360 Support "insert directory"

FLINK-26360 improve hive udaf

FLINK-26360 Improve hive udtf

FLINK-26360 Fail to use such expression like if(1= 1, 2, 3)

FLINK-26360 "IndexOutOfBoundsException" when subquery select all field from using hive dialect

FLINK-26360 "Unexpected correlate variable $cor0" when using hive dialect to write a subquery

FLINK-26360 Hive dialect: `insert overwrite table partition if not exists` will throw exception when tablename is like 'database.table'