Flink 数据流到表答案

【问题标题】：Flink Datastream to TableFlink 数据流到表
【发布时间】：2021-03-23 03:02:49
【问题描述】：

我正在尝试运行它

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

【问题讨论】：

【解决方案1】：

您需要哪些导入取决于您使用的 Flink 版本，但这些是我在 Flink 1.12 和 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.$;

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

【讨论】：

我使用的是 Flink 1.11.1 也许这是问题所在？我会尝试 1.12 非常感谢！
我认为它应该适用于 1.11。抱歉，我已经忽略了关键的导入。
非常有帮助的答案。 Flink 的文档很烂。任何地方都没有提到这一点。