構建對象
class User{ private String addr }
將多個User集合中的addr按照;分割合並成一個字符串list
List<User> uList = Lists.newArrayList(); User u1 = new User(); u1.setAddr("a1;a2;a3;a4;a5"); User u2 = new User(); u2.setAddr("b1;b2;b3;b4;b5"); uList.add(a); uList.add(b); List<String> addrList = uList.stream().map(x -> x.getAddr()).flatMap(x->Arrays.stream(x.split(";"))).collect(Collectors.toList()); //或者 List<String> ridStrList = uList.stream().map(x -> x.getAddr()).map(x -> x.split(";")).flatMap(Arrays::stream).collect(Collectors.toList()); System.out.println(addrList);
說明:
flatMap的用法和含義住要通過一個案例來講解,
案例:對給定單詞列表 ["Hello","World"],你想返回列表["H","e","l","o","W","r","d"]
第一種方式
String[] words = new String[]{"Hello","World"}; List<String[]> a = Arrays.stream(words) .map(word -> word.split("")) .distinct() .collect(toList()); a.forEach(System.out::print);
代碼輸出為:[Ljava.lang.String;@12edcd21[Ljava.lang.String;@34c45dca (返回一個包含兩個String[]的list)
這個實現方式是由問題的,傳遞給map方法的lambda為每個單詞生成了一個String[](String列表)。因此,map返回的流實際上是Stream<String[]> 類型的。你真正想要的是用Stream<String>來表示一個字符串。
下方圖是上方代碼stream的運行流程
第二種方式:flatMap(對流扁平化處理)
String[] words = new String[]{"Hello","World"}; List<String> a = Arrays.stream(words) .map(word -> word.split("")) .flatMap(Arrays::stream) .distinct() .collect(toList()); a.forEach(System.out::print);
結果輸出:HeloWrd
使用flatMap方法的效果是,各個數組並不是分別映射一個流,而是映射成流的內容,所有使用map(Array::stream)時生成的單個流被合並起來,即扁平化為一個流。
下圖是運用flatMap的stream運行流程,
map
map比較簡單,可以抽取列表元素的某個屬性形成新的列表,但是無法對更深層的屬性做提取
map能夠直接操作list中的每個對象
代碼示例:
List<Integer> integers = new ArrayList<>(); //添加數據略 integers.stream.map(i -> i + 1).foreach(System.out::println); List<User> users = new ArrayList<>(); User user = new User(); user.setAddr("12345"); users.add(user); List<String> aa = users.stream().map(data -> { return data.getAddr(); }).collect(Collectors.toList()); System.out.println(aa);
flatMap
可以操作更深層的數據
代碼示例:
List<List<Integer>> outer = new ArrayList<>(); List<Integer> inner1 = new ArrayList<>(); inner1.add(1); List<Integer> inner2 = new ArrayList<>(); inner2.add(2); List<Integer> inner3 = new ArrayList<>(); inner3.add(3); List<Integer> inner4 = new ArrayList<>(); inner4.add(4); List<Integer> inner5 = new ArrayList<>(); inner5.add(5); outer.add(inner1); outer.add(inner2); outer.add(inner3); outer.add(inner4); outer.add(inner5); List<Integer> result = outer.stream().flatMap(inner -> inner.stream().map(i -> i + 1)).collect(Collectors.toList()); System.out.println(result);
Stream.flatMap,正如它的名稱所猜測的,是map和一個flat行動。這意味着您首先對元素應用一個函數,然后將其扁平化。Stream.map只對流應用函數,而不對流進行平坦處理。為了理解什么是扁平化,考慮一個像[[1,2,3],[4,5,6],[7,8,9]]這樣的具有“兩個層次”的結構。 扁平化意味着將其轉化為“一個一級”結構:[1,2,3,4,5,6,7,8,9]。注意:flatmap里面處理的是流stream。而map處理的是元素對象。這個需要注意。如下所示:
List<User> users = new ArrayList<>(); User user = new User(); user.setAddr("12345"); users.add(user); List<String> aa = users.stream().flatMap(data -> Stream.of(data.getAddr().split(""))).collect(Collectors.toList()); System.out.println(aa);