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)
綜合方法靴患，和，平均猫胁，最大最小全求出來(lái):
summarizingInt(XX:getX)
summarizingDouble(XX:getX)
summarizingLong(XX:getX)
3. 連接字符串
joining() --內(nèi)部使用StringBuffer拼接
joining(", ") --可以添加參數(shù)名眉，用什么隔開(kāi)
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.簡(jiǎn)單分組
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.多級(jí)分組
多級(jí)就是類似按照這一級(jí)規(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ù)
這里是先將值映射為L(zhǎng)evel啃沪，將生成的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來(lái)完成連續(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);
