Re: How to to in Flink to support below HIVE SQL

2020-04-19 Thread Rui Li
Hey Xiaohua & Jark, I'm sorry for overlooking the email. Adding to Jark's answers: DISTRIBUTE BY => the functionality and syntax are not supported. We can consider this as a candidate feature for 1.12. named_struct => you should be able to call this function with Hive module LATERAL VIEW => the s

Re: How to to in Flink to support below HIVE SQL

2020-04-08 Thread Jark Wu
Hi Xiaohua, I'm not very familiar with Hive SQL, I will try to answer some of them: COALESCE => there is also a COALESCE built-in function in Flink [1]. From the documentation, I think they are identical. STR_TO_MAP => there is also a STR_TO_MAP built-in function in Flink blink planner[1]. But t

How to to in Flink to support below HIVE SQL

2020-04-08 Thread Xiaohua
Hi, We meet some issue when migrate from Hive/Spark to Flink, Could you please help me? Below is HIVE SQL we used: DISTRIBUTE BY named_struct COALECE LATERAL VIEW row format delimited fields STR_TO_MAP OVERWRITE FULL OUTER JOIN Rlike Array How to do use Flink SQL? Thank you~ B