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

  /**
   * 把每条'rails'里的数据做一个buffer，批处理插入功能 rails 轨道，对应的是一条线程，目前是一个文件一个线程 一下数据代表的是iotdb java原生导入接口对应的入参
   * String deviceId； 设备路径 List<Long> timeSeriesList = new ArrayList<>(); 一行对应的timeseries
   * List<List<String>> measurementsList = new ArrayList<>(); 一样对应的measurement，List<String>
   * 一列对应的measurement List<List<TSDataType>> typesList = new ArrayList<>(); 同上 List<List<Object>>
   * valuesList = new ArrayList<>(); 同上
   *
   * @return
   */
  @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/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
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -