Java8采集地图

Question

我有一个目标：

public class MenuPriceByDay implements Serializable {

    private BigDecimal avgPrice;
    private BigDecimal minPrice;
    private BigDecimal maxPrice;
    private Date updateDate;

..
}

另外一个是：

public class Statistics {

     double min;
     double max;
     double average;

     public Statistics() {
        super();
     }



    public Statistics(double min, double max, double average) {
        super();
        this.min = min;
        this.max = max;
        this.average = average;
    }



}

还有一份价格清单：

List<MenuPriceByDay> prices = new ArrayList<MenuPriceByDay>();

我想转换成一张地图：

Map<LocalDate, Statistics> last30DPerDay =  

        prices
            .stream()
            .collect(Collectors.toMap(MenuPriceByDay::getUpdateDate, p -> new Statistics(   p.getAvgPrice().doubleValue(),
                    p.getMaxPrice().doubleValue(),
                    p.getMinPrice().doubleValue())));

但是我遇到了一个编译问题：

Type mismatch: cannot convert from Map<Date,Object> to 
 Map<LocalDate,Statistics>

Answer 1

UpdateDate的类型为Date，您尝试以LocalDate的形式进行收集，因此只需将Date转换为LocalDate：

Map<LocalDate, Statistics> collect = prices.stream()
        .collect(Collectors.toMap(m -> m.getUpdateDate()
        .toInstant()
        .atZone(ZoneId.systemDefault())
        .toLocalDate(),
                 p -> new Statistics(p.getAvgPrice().doubleValue(),
                        p.getMaxPrice().doubleValue(),
                        p.getMinPrice().doubleValue())
        ));

关于将日期转换为LocalDate或LocalDateTime并返回的更多详细信息

或者您可以创建一个方法，如下所示：

public LocalDate convertToLocalDateViaInstant(Date dateToConvert) {
    return dateToConvert.toInstant()
            .atZone(ZoneId.systemDefault())
            .toLocalDate();
}

你的代码可以是：

  Map<LocalDate, Statistics> collect = prices.stream()
            .collect(Collectors.toMap(
                    m -> this.convertToLocalDateViaInstant(m.getUpdateDate()),
                    p -> new Statistics(p.getAvgPrice().doubleValue(),
                            p.getMaxPrice().doubleValue(),
                            p.getMinPrice().doubleValue())
            ));

更好的解决方案

最好的解决方案就是将updateDate类型更改为LocalDate：

private LocalDate updateDate;

你可以用你的代码

Answer 2

注意，当您使用Collectors.toMap时，如果您有重复的键，您可以得到IllegalStateException。

如果映射的密钥包含重复项(根据Object.equals(对象))，则在执行集合操作时抛出IllegalStateException。

您可以使用toMap(keyMapper, valueMapper, mergeFunction)代替。还有groupingBy的解决方案，在这种情况下，您应该决定在复制键时必须使用哪个统计数据：

Map<LocalDate, Optional<Statistics>> map = prices.stream()
            .collect(groupingBy(p -> p.getUpdateDate()
                            .toInstant()
                            .atZone(ZoneId.systemDefault())
                            .toLocalDate(),
                    mapping(p-> new Statistics(
                            p.getMinPrice().doubleValue(),
                            p.getAvgPrice().doubleValue(),
                            p.getMaxPrice().doubleValue()),
                            reducing((s1, s2) -> ???)      // here