public Flux parseFileSinkStrategy()

in backup-core/src/main/java/org/apache/iotdb/backup/core/service/ExportPipelineService.java [89:112]

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

  public Flux<String> parseFileSinkStrategy(
      ConcurrentHashMap<String, OutputStream> outputStreamMap, 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 {
              FileOutputStream out = new FileOutputStream(new File(catalogFilePath));
              String header = "FILE_NAME,ENTITY_PATH\r\n";
              out.write(header.getBytes());
              outputStreamMap.put("CATALOG", out);
            } catch (IOException e) {
              log.error("异常信息:", e);
            }
          }
          return Flux.just(catalogName);
        });
  }