How to do when Scala Object as input in Flink

Hi, Can Scala object be input in Flink? eg, class AA; select AA.id,AA.name from table where AA.id >'10' Could you please give some example about scala object as input in Flink? Specially in Select and Where case. Thank you so much~ BR Xiaohua -- Sent from: http://apac

How to to in Flink to support below HIVE SQL

~ BR Xiaohua -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

1. 如下HIVE SQL如何用用Flink SQL或者Table API替换

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~ BR Xiaohua