?

?

是否需要env.execute()	數(shù)據(jù)處理類型	具體代碼
需要	流處理	Table table = tEnv.sqlQuery("select test() as a,test(a) as b, test(a,b,c) as c from t"); DataStream<Row> res = tEnv.toAppendStream(table, Row.class); res.print(); env.execute();
不需要	批處理	tableEnv.registerTable("tableA",tableA); Table result2 = tableEnv.sqlQuery("SELECT content,HASHCODE(content) FROM tableA"); tableEnv.toDataSet(result2,Row.class).print();

?

?原因是:

批的collect方法里顯示調(diào)用了execute

?

總結(jié)

以上是生活随笔為你收集整理的flink的Table类型的变量两种输出的形式的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。