public List create()

in src/main/java/com/epam/digital/data/platform/generator/factory/impl/asyncload/AsyncDataLoadCsvProcessorKafkaScopeFactory.java [39:53]

• 14 lines of code
• 2 McCabe index (conditional complexity)

  public List<CsvProcessorScope> create(Context context) {
    return asyncDataLoadInfoProvider.getTablesWithAsyncLoad().keySet().stream()
        .map(
            tableName -> {
              var schemaName = getSchemaName(tableName, context);

              var scope = new CsvProcessorScope();
              var csvRowSchemaName = schemaName + (isNested(tableName) ? "NestedCsv" : "Model");
              scope.setClassName(csvRowSchemaName + "AsyncDataLoadCsvProcessor");
              scope.setCsvPayloadSchemaName(schemaName + "ModelArrayCsv");
              scope.setCsvRowSchemaName(csvRowSchemaName);
              return scope;
            })
        .collect(toList());
  }