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

MapOperator.sum介绍

暂无

代码示例

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

@Test
public void testFirstNOnUngroupedDS() throws Exception {
  /*
   * First-n on ungrouped data set
   */
  final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
  DataSet<Tuple3<Integer, Long, String>> ds = CollectionDataSets.get3TupleDataSet(env);
  DataSet<Tuple1<Integer>> seven = ds.first(7).map(new OneMapper()).sum(0);
  List<Tuple1<Integer>> result = seven.collect();
  String expected = "(7)\n";
  compareResultAsText(result, expected);
}

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

return new Tuple2<Long, Text>(value.f0.get(), value.f1);
}).sum(0);
sumed.writeAsText(resultPath[0]);
DataSet<String> res = ds.distinct(0).map(new MapFunction<Tuple2<LongWritable, Text>, String>() {

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

@Test
public void testReplicatedSourceToCross() throws Exception {
  /*
   * Test replicated source going into cross
   */
  final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
  DataSet<Tuple1<Long>> source1 = env.createInput(new ReplicatingInputFormat<Long, GenericInputSplit>
      (new ParallelIteratorInputFormat<Long>(new NumberSequenceIterator(0L, 1000L))), BasicTypeInfo.LONG_TYPE_INFO)
      .map(new ToTuple());
  DataSet<Tuple1<Long>> source2 = env.generateSequence(0L, 1000L).map(new ToTuple());
  DataSet<Tuple1<Long>> pairs = source1.cross(source2)
      .filter(new FilterFunction<Tuple2<Tuple1<Long>, Tuple1<Long>>>() {
        @Override
        public boolean filter(Tuple2<Tuple1<Long>, Tuple1<Long>> value) throws Exception {
          return value.f0.f0.equals(value.f1.f0);
        }
      })
      .map(new MapFunction<Tuple2<Tuple1<Long>, Tuple1<Long>>, Tuple1<Long>>() {
        @Override
        public Tuple1<Long> map(Tuple2<Tuple1<Long>, Tuple1<Long>> value) throws Exception {
          return value.f0;
        }
      })
      .sum(0);
  List<Tuple1<Long>> result = pairs.collect();
  String expectedResult = "(500500)";
  compareResultAsText(result, expectedResult);
}

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

.setParallelism(parallelism)
  .name("Average score")
.sum(0)
.andSum(1);

代码示例来源：origin: org.apache.flink/flink-gelly_2.10

.setParallelism(littleParallelism)
  .name("Average score")
.sum(0)
.andSum(1);

代码示例来源：origin: org.apache.flink/flink-gelly_2.11

.setParallelism(parallelism)
  .name("Average score")
.sum(0)
.andSum(1);

代码示例来源：origin: com.alibaba.blink/flink-gelly

.setParallelism(parallelism)
  .name("Average score")
.sum(0)
.andSum(1);