CODEWITHSUNDEEP
scalaapache-flinkflink-streamingflink-cepflink-sql
salc2
salc2

Reputation: 577

Create SQL Table from a DataStream in a Java/Scala program and query it from SQL Client CLI - Apache Flink

Is it possible interact with a table using Flink SQL client CLI where which table was created within a Scala/Java program running in the cluster?

Upvotes: 0

Views: 172

Answers (1)

Fabian Hueske
Fabian Hueske

Reputation: 18987

No this is not possible.

You could sink the DataStream of the Scala/Java program into a topic in a message queue or event log like Apache Kafka or Apache Pulsar and register the topic as a table in the CLI client.

Once the table is register, it can be queried with SQL in the client.

Upvotes: 2

Related Questions