CODEWITHSUNDEEP
apache-flink
kostas yfantis
kostas yfantis

Reputation: 3

Flink Datastream to Table

I am trying to run this

screenshot

but i can't understand the dollar symbol and what Table class need to import in my project?

Upvotes: 0

Views: 386

Answers (1)

David Anderson
David Anderson

Reputation: 43499

Exactly which imports you will need depends a bit on which version of Flink you are using, but these are what I'm using with Flink 1.12 and the blink sql planner:

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.Table;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;

import static org.apache.flink.table.api.Expressions.$;

The dollar symbol is, in fact, the dollar symbol: $. It comes from the last of the imports shown above.

Upvotes: 1

Related Questions