backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/sink/OutCsvFileSink.java [77:99]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                        Map<String, List<TimeSeriesRowModel>> groupMap =
                                            allList.stream()
                                                .collect(
                                                    Collectors.toMap(
                                                        k -> k.getDeviceModel().getDeviceName(),
                                                        p -> {
                                                          List<TimeSeriesRowModel> result =
                                                              new ArrayList();
                                                          result.add(p);
                                                          return result;
                                                        },
                                                        (o, n) -> {
                                                          o.addAll(n);
                                                          return o;
                                                        }));

                                        for (String groupKey : groupMap.keySet()) {
                                          if (groupKey.startsWith("finish")) {
                                            finishedFileNum.incrementAndGet();
                                            continue;
                                          }
                                          List<TimeSeriesRowModel> groupList =
                                              groupMap.get(groupKey);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/sink/OutSqlFileSink.java [78:99]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                        Map<String, List<TimeSeriesRowModel>> groupMap =
                                            allList.stream()
                                                .collect(
                                                    Collectors.toMap(
                                                        k -> k.getDeviceModel().getDeviceName(),
                                                        p -> {
                                                          List<TimeSeriesRowModel> result =
                                                              new ArrayList();
                                                          result.add(p);
                                                          return result;
                                                        },
                                                        (o, n) -> {
                                                          o.addAll(n);
                                                          return o;
                                                        }));
                                        for (String groupKey : groupMap.keySet()) {
                                          if (groupKey.startsWith("finish")) {
                                            finishedFileNum.incrementAndGet();
                                            continue;
                                          }
                                          List<TimeSeriesRowModel> groupList =
                                              groupMap.get(groupKey);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -