本文整理了Java中org.apache.flink.api.java.operators.MapOperator.iterate()方法的一些代码示例，展示了MapOperator.iterate()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。MapOperator.iterate()方法的具体详情如下：
包路径：org.apache.flink.api.java.operators.MapOperator
类名称：MapOperator
方法名：iterate

MapOperator.iterate介绍

暂无

代码示例

代码示例来源：origin: apache/flink

IterativeDataSet<Long> innerIteration = outerIteration.map(new IdentityMapper<Long>()).iterate(100);

代码示例来源：origin: apache/flink

IterativeDataSet<Long> mainIteration = data2.map(new IdentityMapper<Long>()).iterate(100);

代码示例来源：origin: apache/flink

@Override
protected void testProgram() throws Exception {
  ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
  DataSet<Long> data1 = env.generateSequence(1, 100);
  DataSet<Long> data2 = env.generateSequence(1, 100);
  IterativeDataSet<Long> firstIteration = data1.iterate(100);
  DataSet<Long> firstResult = firstIteration.closeWith(firstIteration.map(new IdMapper()));
  IterativeDataSet<Long> mainIteration = data2.map(new IdMapper()).iterate(100);
  DataSet<Long> joined = mainIteration.join(firstResult)
      .where(new IdKeyExtractor()).equalTo(new IdKeyExtractor())
      .with(new Joiner());
  DataSet<Long> mainResult = mainIteration.closeWith(joined);
  mainResult.output(new DiscardingOutputFormat<Long>());
  env.execute();
}