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



backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/sink/OutStructureFileSink.java [53:63]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  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
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -