Java Map Reduce By Key

如何解决Java Map Reduce By Key

我有如下对的列表：

// pairs = [(k1,obj1),(k2,obj1)]
List<Pair<String,Object> pairs;

然后我想将这些对象扩展为多个对象并按键减少它们

pairs.stream().map(pair -> {
                // every object is expanded into many objects,obj11,obj12,...
                List<Object> objects = expand(pair.getRight());
                // the return is [(k1,obj11),(k1,obj12),obj21),obj22)]
                return objects.stream().map(object -> new MutablePair<String,Object>(pair.getLeft(),object)).collect(Collectors.toList());
            }).reduce(...
                // how to reduce it by key and get a list of pairs 
            ...);

我的问题是，如何通过key来减少展开的对象并得到一个pair的列表？

我的意思是预期的结果是：

pairs = [(k1,obj22)]

解决方法

看起来您需要 flatMap 而不是 map，以及 collect 而不是 reduce：

List<Pair<String,Object>> expandedPairs =
    pairs.stream()
         .flatMap(pair -> expand(pair.getRight()).stream()
                                                 .map(object -> new MutablePair<String,Object>(pair.getLeft(),object)))
         .collect(Collectors.toList());