in src/main/java/com/epam/digital/data/platform/liquibase/extension/change/core/DdmTableReadParametersChange.java [69:89]
private ColumnConfig findTableColumn(DdmTableReadParametersConfig readParametersConfig,
List<DdmCreateTableChange> createTableChanges,
List<AddColumnChange> columnChanges) {
Optional<ColumnConfig> columnFromCreateTable =
createTableChanges
.stream()
.flatMap(tableChange -> tableChange.getColumns().stream())
.filter(column -> column.getName().equals(readParametersConfig.getName()))
.findFirst();
if (columnFromCreateTable.isPresent()) {
return columnFromCreateTable.get();
}
Optional<AddColumnConfig> columnFromAddColumn =
columnChanges
.stream()
.flatMap(tableChange -> tableChange.getColumns().stream())
.filter(column -> column.getName().equals(readParametersConfig.getName()))
.findFirst();
return columnFromAddColumn.orElse(null);
}