public Flux parseFileSinkStrategy()

in backup-core/src/main/java/org/apache/iotdb/backup/core/pipeline/out/source/OutCsvDataSource.java [119:140]

• 22 lines of code
• 4 McCabe index (conditional complexity)

  public Flux<String> parseFileSinkStrategy(OutputStream[] outputStream, String catalogName) {
    return Flux.deferContextual(
        context -> {
          PipelineContext<ExportModel> pcontext = context.get("pipelineContext");
          ExportModel exportModel = pcontext.getModel();
          if (exportModel.getFileSinkStrategyEnum() == FileSinkStrategyEnum.EXTRA_CATALOG) {
            File file = new File(exportModel.getFileFolder());
            if (!file.exists()) {
              file.mkdirs();
            }
            String catalogFilePath = exportModel.getFileFolder() + catalogName;
            try {
              outputStream[0] = new FileOutputStream(catalogFilePath);
              String header = "FILE_NAME,ENTITY_PATH\r\n";
              outputStream[0].write(header.getBytes());
            } catch (IOException e) {
              log.error("异常信息:", e);
            }
          }
          return Flux.just(catalogName);
        });
  }