将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);