Hi, I wrote a example including queries which you want [1]. The example uses only Flink Scala API, but I think It would be better to use Table API. I used broadcast set [2] to perform subqueries in your given query.
Flink has many functions to handle data and the great documentation to explain the functions. I think that It is good to read Batch API section of Flink documentation for you. If you have a question for the example, please reply mail to user mailing list. Regards, Chiwan Park [1] https://gist.github.com/chiwanpark/5e2a6ac00b7e0bf85444 [2] https://ci.apache.org/projects/flink/flink-docs-master/apis/programming_guide.html#broadcast-variables > On Jul 11, 2015, at 5:00 AM, hagersaleh <loveallah1...@yahoo.com> wrote: > > please help > > > > -- > View this message in context: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/how-can-handles-Any-All-query-on-flink-tp1997p2005.html > Sent from the Apache Flink User Mailing List archive. mailing list archive at > Nabble.com.
