@Override
  public void addChange(DiffEntry change) {
    if (checkConfigFilePath(change.getNewPath())) {
      Path configFilePath = new Path(this.repositoryDir, change.getNewPath());

      try {
        Config flowConfig = loadConfigFileWithFlowNameOverrides(configFilePath);

        this.flowCatalog.put(FlowSpec.builder()
            .withConfig(flowConfig)
            .withVersion(SPEC_VERSION)
            .withDescription(SPEC_DESCRIPTION)
            .build());
      } catch (IOException e) {
        log.warn("Could not load config file: " + configFilePath);
      }
    }
  }
@ Override public void addChange ( DiffEntry change ) { if ( checkConfigFilePath ( change . getNewPath ( ) ) ) { Path configFilePath = new Path ( this . repositoryDir , change . getNewPath ( ) ) ; try { Config flowConfig = loadConfigFileWithFlowNameOverrides ( configFilePath ) ; this . flowCatalog . put ( FlowSpec . builder ( ) . withConfig ( flowConfig ) . withVersion ( SPEC_VERSION ) . withDescription ( SPEC_DESCRIPTION ) . build ( ) ) ; } catch ( IOException e ) { log . warn ( "Could not load config file: " + configFilePath ) ; } } }
Add a {@link FlowSpec} for an added, updated, or modified flow config
@param change