将数据流Flink到表

Question

我正在尝试运行这个

屏幕截图

但是我不能理解美元符号以及在我的项目中需要导入什么Table类？

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

美元符号实际上就是美元符号：$。它来自上面显示的最后一个进口产品。