backup-core/src/main/java/org/apache/iotdb/backup/core/ExportStarter.java [99:138]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                  return context;
                });
    return pipeline.start();
  }

  @Override
  public void shutDown() {
    this.pipeline.shutDown();
  }

  /**
   * 查看导出文件进度
   *
   * @return
   */
  @Override
  public Double[] rateOfProcess() {
    Double[] rateArray = new Double[2];
    pipeSinkList.forEach(
        pipesink -> {
          Double[] d = pipesink.rateOfProcess();
          rateArray[0] += d[0];
          rateArray[1] += d[1];
        });
    return rateArray;
  }

  /**
   * 查看文件导出行数
   *
   * @return
   */
  @Override
  public Long finishedRowNum() {
    AtomicLong result = new AtomicLong();
    pipeSinkList.forEach(
        pipesink -> {
          result.addAndGet(pipesink.finishedRowNum());
        });
    return result.get();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



backup-core/src/main/java/org/apache/iotdb/backup/core/ImportStarter.java [90:129]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                  return context;
                });
    return pipeline.start();
  }

  @Override
  public void shutDown() {
    this.pipeline.shutDown();
  }

  /**
   * 查看导出文件进度
   *
   * @return
   */
  @Override
  public Double[] rateOfProcess() {
    Double[] rateArray = new Double[2];
    pipeSinkList.forEach(
        pipesink -> {
          Double[] d = pipesink.rateOfProcess();
          rateArray[0] += d[0];
          rateArray[1] += d[1];
        });
    return rateArray;
  }

  /**
   * 查看文件导出行数
   *
   * @return
   */
  @Override
  public Long finishedRowNum() {
    AtomicLong result = new AtomicLong();
    pipeSinkList.forEach(
        pipesink -> {
          result.addAndGet(pipesink.finishedRowNum());
        });
    return result.get();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -