Flink sql 之sql执行计划

flink sql 的执行计划
查看方式3种
1.方式一
// 计算iopv
Table calculateTable = tableEnv.sqlQuery("select /n" +
" fund_code,/n" +
" (sum_cash+sum_creation_cash_substitute+estimate_cash_component)/creation_redemption_unit as real_time_iopv,/n" +
" CURRENT_TIMESTAMP as computation_time /n" +
" from " + checkTable);

TableResult tableResult

Flink sql 之sql执行计划最先出现在Python成神之路

版权声明:
作者:倾城
链接:https://www.techfm.club/p/12565.html
来源:TechFM
文章版权归作者所有,未经允许请勿转载。

THE END
分享
二维码
< <上一篇
下一篇>>