將List/Map轉換爲org.apache.flink.util.Collector

Question

如何將List/Map轉換爲org.apache.flink.util.Collector？

可以說我有這樣的：

List<Tuple2<Double, Integer>> list = new ArrayList<Tuple2<Double, Integer>>(); 

我想是這樣的：

Collector<Tuple2<Double, Integer>> data = ... list.getCollector(); 

什麼想法？

Answer 1

嘗試使用這個ListCollector橋樑，有了這個類，你可以你的列表（ArrayList的）翻譯成收藏家（ListCollector），使用constructor

Answer 2

由於@karelss

這是解決方案：

List<Tuple2<Double, Integer>> list = new ArrayList<Tuple2<Double, Integer>>(); 
list.add(...); 
Collector<Tuple2<Double, Integer>> data = new ListCollector<>(list);