You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 刘超 <li...@foxmail.com> on 2022/11/24 03:46:42 UTC
table api 中 怎么设置某个算子的并发度
你好 我想设置window算子的并发度 具体怎么设置呢
EnvironmentSettings environmentSetting = EnvironmentSettings.newInstance().build();
TableEnvironment tableEnvironment = TableEnvironment.create(environmentSetting);......transactions.select($("account_id"),$("transaction_time"),$("amount"))
.window(Tumble.over("10.seconds").on($("transaction_time")).as("oo"))
.groupBy($("account_id"), $("oo"))
.select(
$("account_id"),
$("oo").start().as("log_ts")).execute().print()
刘超
liuchao1019@foxmail.com