Flink 数据流到 Table

Question

我正在尝试运行这个

screenshot

但我无法理解美元符号以及 Table class 需要在我的项目中导入什么？

Answer 1

您需要哪些导入在一定程度上取决于您使用的 Flink 版本，但这些是我在 Flink 1.12 和 blink sql 规划器中使用的：

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.$;

美元符号实际上是美元符号：$。它来自上面显示的最后一个导入。

Flink 数据流到 Table

Flink Datastream to Table

apache-flink