Login  Register

SQL query support in Flink

classic Classic list List threaded Threaded
2 messages Options Options
Embed post
Permalink
Reply | Threaded
Open this post in threaded view
| More
Print post
Permalink

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
Reply | Threaded
Open this post in threaded view
| More
Print post
Permalink

Re: SQL query support in Flink

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,


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