jdbc-protolib/src/main/java/com/streamsets/pipeline/stage/origin/jdbc/cdc/postgres/PostgresCDCWalReceiver.java
public Optional<List<ConfigIssue>> validateSchemaAndTables(List<SchemaTableConfigBean>
      schemaTableConfigs) {
    List<ConfigIssue> issues = new ArrayList<>();
    for (SchemaTableConfigBean tables : configBean.baseConfigBean.schemaTableConfigs) {
      validateSchemaAndTable(tables).ifPresent(issues::add);
    }
    return Optional.ofNullable(issues);
  }
public Optional<List<ConfigIssue>> validateSchemaAndTables(List<SchemaTableConfigBean>
      schemaTableConfigs) {
    List<ConfigIssue> issues = new ArrayList<>();
    for (SchemaTableConfigBean tables : configBean.baseConfigBean.schemaTableConfigs) {
      validateSchemaAndTable(tables).ifPresent(issues::add);
    }
    return Optional.ofNullable(issues);
  }
public Optional < List < ConfigIssue > > validateSchemaAndTables ( List < SchemaTableConfigBean > schemaTableConfigs ) { List < ConfigIssue > issues = new ArrayList <> ( ) ; for ( SchemaTableConfigBean tables : configBean . baseConfigBean . schemaTableConfigs ) { validateSchemaAndTable ( tables ) . ifPresent ( issues :: add ) ; } return Optional . ofNullable ( issues ) ; }
TODO this is a great place for generic validator
TODO this is a great place for generic validator