Flink官網(wǎng)看到這么個例子:

DataSet<WC> words = // [...] DataSet<WC> wordCounts = words// DataSet grouping on field "word".groupBy("word")// apply ReduceFunction on grouped DataSet.reduce(new WordCounter());

第一種分開寫WordCounter.java的辦法:

import org.apache.flink.api.common.functions.ReduceFunction; public class WordCounter implements ReduceFunction<WC> {@Overridepublic WC reduce(WC in1, WC in2) {return new WC(in1.word, in1.count + in2.count);} }

?

第二種辦法:

原始代碼:

JavaPairRDD<Long, Long> removedRandomPrefixRdd = localAggrRdd.mapToPair(new PairFunction<Tuple2<String,Long>, Long, Long>() {private static final long serialVersionUID = 1L;@Overridepublic Tuple2<Long, Long> call(Tuple2<String, Long> tuple)throws Exception {long originalKey = Long.valueOf(tuple._1.split("_")[1]);return new Tuple2<Long, Long>(originalKey, tuple._2);}});

修改后的代碼:

private static PairFunction <Tuple2<String,Long>, Long, Long> func3=new PairFunction<Tuple2<String,Long>, Long, Long>() {private static final long serialVersionUID = 1L; // @Overridepublic Tuple2<Long, Long> call(Tuple2<String, Long> tuple)throws Exception{long originalKey;originalKey = Long.valueOf(tuple._1.split("_")[1]);return new Tuple2<Long, Long>(originalKey, tuple._2);} };// 第三步，去除RDD中每個key的隨機前綴。JavaPairRDD<Long, Long> removedRandomPrefixRdd = localAggrRdd.mapToPair(func3);

修改辦法:

new PairFunction<Tuple2<String,Long>, Long, Long>()

改成:

private static PairFunction <Tuple2<String,Long>, Long, Long> func3=new PairFunction<Tuple2<String,Long>, Long, Long>()

?

?

總結(jié)

以上是生活随笔為你收集整理的Java中new function另外新建个文件的写法的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。