in src/main/java/com/epam/digital/data/platform/generator/factory/impl/asyncload/AsyncDataLoadListenerScopeFactory.java [38:57]
public List<AsyncDataLoadListenerScope> create(Context context) {
var scope = new AsyncDataLoadListenerScope();
scope.setClassName("AsyncDataLoadListener");
scope.setOperation("upsert");
scope.setFilterName("asyncDataLoadListenerFilterStrategy");
var entityNamesToSchemaNames = new HashMap<String, String>();
asyncDataLoadInfoProvider.getTablesWithAsyncLoad().keySet().forEach(entityName -> {
var schemaName = getSchemaName(entityName, context);
if (isNested(entityName)) {
entityNamesToSchemaNames.put(getSchemaName("nested/" + entityName),
schemaName + "NestedCsv");
} else {
entityNamesToSchemaNames.put(getSchemaName(entityName), schemaName + "Model");
}
});
scope.setEntityNamesToSchemaNames(entityNamesToSchemaNames);
return List.of(scope);
}