如何将下面的代码块转换为flink样式

qv7cva1a  于 2021-06-24  发布在  Flink
关注(0)|答案(1)|浏览(317)

我们有如下代码:

for(int i = 0 ; i < 10; i ++ ) {

      //do something ... 
      //doing calculating
      //do something else 

      for(int j = 0; j <  10000 )   {
            //do something calculations..
            //calculating more...
            //Getting result....

      }

 }

内环次数远多于外环次数。
如何把它变成Flink风格?

w8rqjzmb

w8rqjzmb1#

我们可以放置env.execute();在外环。Flink会处理的。完成!

相关问题