JAVA 8 收集器(Collectors) 使用

收集器功能：1.將流元素歸約和匯總 2.元素分組 3.元素分區(qū)
都是 import static java.util.stream.Collectors.*; 前提下

一、歸約和匯總

1. 查找最大最小值

maxBy(Comparator)
minBy(Comparator)

2. 匯總

求和:
summingInt(XX::getX)
summingLong(XX::getX)
summingDouble(XX::getX)
求平均值:
averagingInt(XX::getX)
averagingDouble(XX::getX)
averagingLong(XX::getX)
綜合方法，和，平均，最大最小全求出來:
summarizingInt(XX:getX)
summarizingDouble(XX:getX)
summarizingLong(XX:getX)

3. 連接字符串

joining()  --內(nèi)部使用StringBuffer拼接
joining(", ")  --可以添加參數(shù)，用什么隔開

4. 廣義的歸約匯總

reducing(M,N,W) 需要3個(gè)參數(shù) 

M   ->  初始值
N   ->  XX::getX
W   ->  一個(gè)lamda轉(zhuǎn)換函數(shù)

reducing(W) 可以一個(gè)參數(shù)

W   ->  一個(gè)Lambda轉(zhuǎn)換函數(shù)

二、分組

Collectors.groupingBy()

1.簡單分組

Collectors.groupingBy(W)  W為一個(gè)Lambda

public enum Level { LOW, NORMAL, HIGH };
Map<Integer, List<Transaction>> maps = trans.parallelStream().collect(groupingBy(Transaction::getValue));

//返回的是Key
Map<Level, List<Transaction>> maps2 = trans.parallelStream().collect(groupingBy(t -> {
    if (t.getValue() <= 500)
        return Level.LOW;
    else if (t.getValue() <= 1000)
        return Level.NORMAL;
    else
        return Level.HIGH;
}));

2.多級分組

多級就是類似按照這一級規(guī)則分完組，繼續(xù)按照下個(gè)規(guī)則繼續(xù)分組，將內(nèi)存?zhèn)鬟f給外層

即為groupingBy套用groupingBy
Collectors.groupingBy(W, groupingBy(M))  W為一個(gè)分類函數(shù) M可以為任何類型

Map<Integer, Map<Level, List<Transaction>>> maps3 = trans.parallelStream()
    .collect(groupingBy(Transaction::getYear, groupingBy(t -> {
        if (t.getValue() <= 500)
            return Level.LOW;
        else if (t.getValue() <= 1000)
            return Level.NORMAL;
        else
            return Level.HIGH;
    })));

3.按子組收集數(shù)據(jù)

傳遞給groupingBy的第二個(gè)收集器可以是==任何類型==

普通的單函數(shù)groupingBy(f) 實(shí)際上為 groupingBy(f, toList())

Map<Integer, Optional<T>> maps4 = trans.stream().collect(groupingBy(T::getYear,
    maxBy(Comparator.comparingInt(T::getValue))));

3.1 把收集器結(jié)果轉(zhuǎn)換為另一種類型

Collectors.collectingAndThen(W,M) 返回一個(gè)收集器
W：要轉(zhuǎn)換的收集器 M：轉(zhuǎn)換函數(shù)

Map<Integer, Transaction> maps5 = trans.stream().collect(groupingBy(Transaction::getYear,
    collectingAndThen(maxBy(comparing(Transaction::getValue)), Optional::get)));

3.2 于groupingBy聯(lián)合使用的其他收集器

Collectors.mapping(W,M) 返回一個(gè)收集器
W：轉(zhuǎn)換函數(shù) M：收集函數(shù)

這里是先將值映射為Level，將生成的Level流傳給toSet，然后返回:

Map<Integer, Set<Level>> maps7 = trans.stream()
    .collect(groupingBy(Transaction::getYear, Collectors.mapping(t -> {
        if (t.getValue() <= 500)
            return Level.LOW;
        else if (t.getValue() <= 1000)
            return Level.NORMAL;
        else
            return Level.HIGH;
    }, toSet())));
    
Map<Integer, Set<Level>> maps7 = trans.stream()
    .collect(groupingBy(Transaction::getYear, Collectors.mapping(t -> {
        if (t.getValue() <= 500)
            return Level.LOW;
        else if (t.getValue() <= 1000)
            return Level.NORMAL;
        else
            return Level.HIGH;
    }, Collectors.toCollection(HashSet::new))));
    
Collectors.toCollection(HashSet::new) 可以控制其生成的流的類型

三、分區(qū)

1. 分區(qū)

Collectors.partitioningBy(W)  W必須為返回boolean值的函數(shù)
Collectors.partitioningBy(W,M)  W必須為返回boolean值的函數(shù) M為收集器

直接按照某boolean值分區(qū) true|false
Map<Boolean, List<Transaction>> map1 = trans.stream().collect(Collectors.partitioningBy(Transaction::getIsOk));

可以添加收集器參數(shù)
Map<Boolean, Map<Integer, List<Transaction>>> map2 = trans.stream()
    .collect(Collectors.partitioningBy(Transaction::getIsOk, groupingBy(Transaction::getYear)));

可以使用collectingAndThen來完成連續(xù)收集功能
Map<Boolean, Transaction> map3 = trans.stream().collect(Collectors.partitioningBy(Transaction::getIsOk,
    collectingAndThen(maxBy(Comparator.comparing(Transaction::getValue)), Optional::get)));

2.按照質(zhì)數(shù)非質(zhì)數(shù)分區(qū)

private boolean isPrime(int num) {
    int num2 = (int) Math.sqrt((double) num);
    return IntStream.rangeClosed(2, num2).noneMatch(t -> num % t == 0);
}

private  Map<Boolean, List<Integer>> getNum(int n) {
    return IntStream.rangeClosed(2, n).boxed().collect(Collectors.partitioningBy(t -> isPrime(t)));
}

Map<Boolean, List<Integer>> map4 = getNum(N);