Flink用Java寫(xiě),看著太難受了。企業(yè)中都用Scala寫(xiě),誰(shuí)還用Java寫(xiě)
2020-02-10
老師我的版本是1.9.1 是這種 沒(méi)有tEnv.registerDataStream
tEnv.registerDataStreamInternal("books",map);
tEnv.registerDataStreamInternal("books",map);
2020-01-09
06:14
我目前在使用 flink1.9.0,代碼第23行這里,不能這么用了,會(huì)報(bào)錯(cuò)。
首先IDEA會(huì)提示 getTableEnvironment 這個(gè)方法不存在。
查了官方的文檔:https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/common.html#create-a-tableenvironment
正確的寫(xiě)法應(yīng)該是這樣的:
BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
然后程序執(zhí)行成功了
我目前在使用 flink1.9.0,代碼第23行這里,不能這么用了,會(huì)報(bào)錯(cuò)。
首先IDEA會(huì)提示 getTableEnvironment 這個(gè)方法不存在。
查了官方的文檔:https://ci.apache.org/projects/flink/flink-docs-stable/dev/table/common.html#create-a-tableenvironment
正確的寫(xiě)法應(yīng)該是這樣的:
BatchTableEnvironment tEnv = BatchTableEnvironment.create(env);
然后程序執(zhí)行成功了
2019-11-07