apache-flink - Flink 数据流到表
解决方案
您需要的确切导入取决于您使用的 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.$;
美元符号实际上就是美元符号:$
. 它来自上面显示的最后一个导入。