SQL query support in Flink

[Sourav Mazumder]

Hi,

Just wanted to check whether one can directly run SQL queries on Flink.

For example whether one can define a table on a dataset and then run queries like dataset.sql ("select column1, column2 from mytable").

I used to think that this is possible right now in 0.10.1. But when I checked the blog a year in review http://flink.apache.org/news/2015/12/18/a-year-in-review.html, I found there is a feature mentioned in 2016's roadmap as - "SQL queries for static data sets and streams". Hence my doubt.

Regards,

Sourav

[Fabian Hueske-2]

Hi Sourav,

Flink does not support to execute SQL queries on DataSets, yet.

We just started an effort to change that. See the discussion on the dev mailing list [1] and the corresponding design document [2].

For simple relational queries, you can use the Table API [3].

Best,

Fabian

[1] https://mail-archives.apache.org/mod_mbox/flink-dev/201601.mbox/%3CCAAdrtT04o6tU%2BDHM4632v_8p7QxT7ErFWicpuzFUtfaDMOK9FQ%40mail.gmail.com%3E
[2] https://docs.google.com/document/d/1TLayJNOTBle_-m1rQfgA6Ouj1oYsfqRjPcp1h2TVqdI
[3] https://ci.apache.org/projects/flink/flink-docs-release-0.10/libs/table.html

2016-01-12 1:18 GMT+01:00 Sourav Mazumder <[hidden email]>:

Hi,

Just wanted to check whether one can directly run SQL queries on Flink.

For example whether one can define a table on a dataset and then run queries like dataset.sql ("select column1, column2 from mytable").

I used to think that this is possible right now in 0.10.1. But when I checked the blog a year in review http://flink.apache.org/news/2015/12/18/a-year-in-review.html, I found there is a feature mentioned in 2016's roadmap as - "SQL queries for static data sets and streams". Hence my doubt.

Regards,

Sourav