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
共有 0 条评论