Lambda表示式之map reduce & groupingBy
阿新 • • 發佈:2019-02-14
1. map & reduce
reduce操作可以實現從一組值中生成一個值。count、min、max方法,因為常用而被納入到標準庫中。事實上,這些方法都是reduce操作。
2. 使用收集器
前面使用過collect(toList())在流中生成Lst,但是有時人們還希望從流中生成其他集合(如:Set或Map),或者你希望定製一個類將你想要的東西抽象出來。
這就是“收集器”,只要將它傳給collect方法,所有的流就都可以使用它了。收集器需要靜態匯入。
資料分組
collect(groupingBy())
注:這個方法和sql中的group by是類似的概念。
如下是一個使用 map, reduce 和 groupingBy的例子:
@Override public List<BillFee> getBillList(EnterpiseSubinstanceSearchCondition enterpiseSubinstanceSearchCondition) { log.debug("#######################################企業費用報告 - 企業賬務資訊sheet 開始####################################### enterpiseSubinstanceSearchCondition = {}", enterpiseSubinstanceSearchCondition); List<BillFee> billDetails = new ArrayList<>(); Date startTime = enterpiseSubinstanceSearchCondition.getStartTime(); Date endTime = enterpiseSubinstanceSearchCondition.getEndTime(); List<String> tenantIds = enterpiseSubinstanceSearchCondition.getIdList(); for(String tenantId : tenantIds){ DateTime startTimeDT = new DateTime(startTime); DateTime endTimeDT = new DateTime(endTime); int n = 0; while(true){ DateTime et = endTimeDT.minusMonths(n); // 以一個月為基本單位:結束時間 if(et.isBefore(startTimeDT)) break; n++; DateTime st = et.minusMonths(1).plusSeconds(1); // 以一個月為基本單位:開始時間 List<SubSubinstanceItem> subinstanceItems = findSubItemsByTenantId(tenantId); List<BillFee> subinstanceBillDetails = getSubBillList(subinstanceItems, new Date(st.getMillis()), new Date(et.getMillis())); if (subinstanceBillDetails != null) { Map<String, List<BillFee>> collect = subinstanceBillDetails.stream().collect(groupingBy(BillFee::getServiceTypeName)); List<BillFee> billFeeList = new ArrayList<>(); for(Map.Entry<String, List<BillFee>> entry : collect.entrySet()){ List<BillFee> billFees = entry.getValue(); BillFee billFee1 = billFees.get(0); billFee1.setTotalPrice(billFees.stream().map(BillFee::getTotalPrice).reduce(0.0d, MathHelper::add)); billFeeList.add(billFee1); } Collections.sort(billFeeList, (arg0, arg1) -> arg0.getOrgName().compareTo(arg1.getOrgName())); // 按部門升序 billDetails.addAll(billFeeList); } } } log.debug("#######################################企業費用報告 - 企業賬務資訊sheet 結束####################################### return = {}", billDetails); return billDetails; }