backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/in/sink/InRowModelFileSink.java [88:106]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                    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;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/sink/OutSqlFileSink.java [78:96]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                                        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;
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -