笑傲大数据,传送门:https://class.imooc.com/sale/bigdata
限免费领:https://pan.baidu.com/s/1mUxNF5oicB6dXek7wvf-9Q
提取码:8888
更多福利,欢迎关注微信公众号“大数据1024”
介绍:https://mp.weixin.qq.com/s/26fa9g6CHj-3jFz5oN-sxA
项目:https://mp.weixin.qq.com/s/ijdBFpwkiCb9qXxld-yJYQ
导图:https://mp.weixin.qq.com/s/WQcmymw_q6OkQ3gOduKJDg
限免费领:https://pan.baidu.com/s/1mUxNF5oicB6dXek7wvf-9Q
提取码:8888
更多福利,欢迎关注微信公众号“大数据1024”
介绍:https://mp.weixin.qq.com/s/26fa9g6CHj-3jFz5oN-sxA
项目:https://mp.weixin.qq.com/s/ijdBFpwkiCb9qXxld-yJYQ
导图:https://mp.weixin.qq.com/s/WQcmymw_q6OkQ3gOduKJDg
2020-08-26
flink1.10.1版本需要使用新的API,如下:
BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
tEnv.createTemporaryView("WordCount", input, "word, frequency");
BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
tEnv.createTemporaryView("WordCount", input, "word, frequency");
2020-08-12