java8 reduce分组去重

 Map configMap = v1.parallelStream().collect(Collectors.groupingBy(e -> fetchGroupTaskAttr(e), Collectors.collectingAndThen(Collectors.reducing((c1, c2) -> {
                        if (null == c1.getInBaseTime() || null == c2.getInBaseTime()) {
                            //优先取同组中时间不为空的
                            return c1.getInBaseTime() != null ? c1 : c2;
                        } else {
                            return c1.getTime().after(c2.getTime()) ? c1 : c2;
                        }
                    }
            ), Optional::get)));
    
    
     /**
     * 分组
     *
     * @param info
     * @return
     */
    private static String fetchGroupTaskAttr(T info) {
        return info.getX() + "_" + info.getY();
    }