backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/source/OutCompressDataSource.java [106:123]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                  return context;
                });
  }

  /**
   * 初始化设备实体对应的outputStream
   *
   * @param pair
   * @return
   */
  public Flux<Pair<DeviceModel, List<TimeseriesModel>>> initOutputStream(
      Pair<DeviceModel, List<TimeseriesModel>> pair,
      AtomicLong fileNo,
      ConcurrentHashMap<String, OutputStream> outputStreamMap) {
    return Flux.deferContextual(
        contextView -> {
          PipelineContext<ExportModel> pcontext = contextView.get("pipelineContext");
          ExportModel exportModel = pcontext.getModel();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/source/OutSqlDataSource.java [101:118]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                  return context;
                });
  }

  /**
   * 初始化设备实体对应的outputStream
   *
   * @param pair
   * @return
   */
  public Flux<Pair<DeviceModel, List<TimeseriesModel>>> initOutputStream(
      Pair<DeviceModel, List<TimeseriesModel>> pair,
      AtomicLong fileNo,
      ConcurrentHashMap<String, OutputStream> outputStreamMap) {
    return Flux.deferContextual(
        contextView -> {
          PipelineContext<ExportModel> pcontext = contextView.get("pipelineContext");
          ExportModel exportModel = pcontext.getModel();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -