使用Flink 1.13.2版本实现第六章的代码的示例
来源：5-16 【讨论题】谈谈你对Flink中并行度的认识
leeyonyu
2021-09-07
Flink 1.13.2版本对SQL API进行了较大程度的修改，把BatchTableEnvironment和RegisterTable方法都标记为过时，创建Table的registerTable方法建议使用createTemporaryView替代，从csv中读取数据并填充到table中的fromDataSet方法也被移除，整个批处理DataSet到SQL API的实现方式有较大的变化，请老师给出一个1.13.2版本能运行的代码示例，谢谢。
写回答
2回答
-
Michael_PK
2021-09-07
照着新版本的源码方法的描述来改就可以了呢，一般方法上都带有使用说明。
00 -
Michael_PK
2021-09-07
照着新版本的源码方法的描述来改就可以了呢，一般方法上都带有使用说明。
00
相似问题