将列表/Map转换为org.apache.flink.util.collector

vxf3dgd4 于 2021-06-21 发布在 Flink

关注(0)|答案(2)|浏览(309)

如何将列表/Map转换为org.apache.flink.util.collector？
假设我有：

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

我想得到这样的东西：

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

有什么想法吗？

Java apache-flink

来源：https://stackoverflow.com/questions/40398729/convert-a-list-map-to-org-apache-flink-util-collector

2条答案

按热度按时间

eoxn13cs1#

尝试使用这个listcollector作为桥，通过这个类，您可以使用构造函数将列表（arraylist）转换为收集器（listcollector）

赞(0）回复(0）举报 2021-06-21

hmtdttj42#

感谢@karelss
这就是解决方案：

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

赞(0）回复(0）举报 2021-06-21

我来回答

将列表/Map转换为org.apache.flink.util.collector

2条答案

相关问题

热门标签

最新问答