Stream类全路径为：java.util.stream.Stream

     Java 8 中的 Stream 是对集合（Collection）对象功能的增强，它专注于对集合对象进行各种非常便利、高效的聚合操作（aggregate operation），或者大批量数据操作 (bulk data operation)。Stream API 借助于同样新出现的 Lambda 表达式，极大的提高编程效率和程序可读性。

  Stream将要处理的元素集合看作一种流，在流的过程中，借助Stream API对流中的元素进行操作，比如：筛选、排序、聚合等。

stream的特性

1. stream不存储数据，而是按照特定的规则对数据进行计算，一般会输出结果。
2. stream不会改变数据源，通常情况下会产生一个新的集合或一个值。
3. stream具有延迟执行特性，只有调用终端操作时，中间操作才会执行。
   

集合取某个值的集合

List<String> taskLidList = qualityVideoList.stream()
                .map(QualityDetails::getTaskLid).distinct().collect(Collectors.toList());

集合转map集合

Map<String, List<QualityResultDetails>> detailMap = detailsList.stream().filter(f -> !Strings.isNullOrEmpty(f.getTaskLid()))
                .collect(Collectors.groupingBy(QualityResultDetails::getTaskLid, Collectors.toList()));

集合转map实体

   Map<String, CustomerStaffDataVO> collect = customerStaffDataVOList.stream().collect(
            Collectors.toMap(CustomerStaffDataVO::getAdminUserLid, v -> v, (v1, v2) -> v1)
);

集合切成多个集合

 List<CustomerServiceLog> customerServiceLogLists = Lists.newArrayList();

            List<CompletableFuture> completableFutureList = Lists.newArrayList();

            List<List<String>> split = CollectionUtil.split(taskLidList, Runtime.getRuntime().availableProcessors());
            for (List<String> stringList : split) {
                completableFutureList.add(CompletableFuture.runAsync(() -> getCustomerServiceLogList(stringList, customerServiceLogLists)));
            }

            CompletableFuture.allOf(completableFutureList.toArray(new CompletableFuture[completableFutureList.size()])).join();