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算子的并发度 具体怎么设置呢&nbsp;
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



&nbsp;