将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作为桥梁，使用这个类你可以将你的List (ArrayList)转换为一个Collector(ListCollector)，使用构造函数

Answer 2

感谢@karelss

解决方案:

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