backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/in/sink/InStructureFileSink.java [57:76]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private AtomicInteger finishedFileNum = new AtomicInteger();

  private AtomicLong finishedRowNum = new AtomicLong();

  @Override
  public Function<ParallelFlux<TimeSeriesRowModel>, ParallelFlux<TimeSeriesRowModel>> doExecute() {
    return sink ->
        sink.transformGroups(
            (Function<
                    GroupedFlux<Integer, TimeSeriesRowModel>,
                    Publisher<? extends TimeSeriesRowModel>>)
                integerTimeSeriesRowModelGroupedFlux ->
                    integerTimeSeriesRowModelGroupedFlux
                        // createAligned
                        // 有bug,只能先一个个的创建了，描述，如果一个序列被截断为两分数据，比如：8个时间序列，1个先执行，后7个在执行同样的的方法报异常
                        // Timeseries under this entity is not aligned, please use createTimeseries
                        // or change entity
                        // api接口还是有问题，时间序列对齐的方法改为执行insert语句
                        .buffer(1000, 1000)
                        .flatMap(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/sink/OutStructureFileSink.java [51:65]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  private AtomicInteger finishedFileNum = new AtomicInteger();

  private AtomicLong finishedRowNum = new AtomicLong();

  @Override
  public Function<ParallelFlux<TimeSeriesRowModel>, ParallelFlux<TimeSeriesRowModel>> doExecute() {
    return sink ->
        sink.transformGroups(
                (Function<
                        GroupedFlux<Integer, TimeSeriesRowModel>,
                        Publisher<? extends TimeSeriesRowModel>>)
                    integerTimeSeriesRowModelGroupedFlux ->
                        integerTimeSeriesRowModelGroupedFlux
                            .buffer(1000, 1000)
                            .flatMap(
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -