How to use the TableAPI to query the data in the Sql Training Rides table ?

2021-02-03 Thread cristi.cioriia
Hey guys, I'm pretty new to Flink, I hope I could get some help on getting data out of a Flink cluster. I've setup the cluster by following the steps in https://github.com/ververica/sql-training and now I wanted to retrieve the data from the Rides table in a Scala program, using the TableAPI. Th

[Flink SQL] Run SQL programatically

2021-02-01 Thread cristi.cioriia
Hey guys, We have been trying out Fink SQL to implement use-cases like "compute the last X minutes of data" and we'd like to return the computed data programatically from Scala/Java, is there a way to write a program to run SQL queries over Flink in a reactive manner? We used for now for experime