Configuring sources using Spring Beans

@Qualifier(SP_QUALIFIER__CUSTOMISATIONS)
Consumer<IDatastoreConfigurator> addFieldToStore()`

    @Bean
    @Qualifier(SP_QUALIFIER__CUSTOMISATIONS)
    public Consumer<IDatastoreConfigurator> addFieldToStore() {
        return configurator -> {
            configurator.appendFields(SensiDatastoreDescriptionConfig.SCHEMA, StoreNames.TENOR_STORE_NAME,
                    List.of(
                            new CustomField(DOUBLE_NUMBER_OF_DAYS, ILiteralType.DOUBLE),
                            new CustomField(TEST_FIELD, ILiteralType.STRING)
                    )
            );
        };
    }

@Qualifier(SP_QUALIFIER__SENSI_TOPIC_COLUMNS)
@Order(10)
public Function<Map<String, CsvTopicColumns>, List<CsvTopicColumns>> addFieldAndCalculator()

    @Bean
    @Qualifier(SP_QUALIFIER__SENSI_TOPIC_COLUMNS)
    @Order(10)
    public Function<Map<String, CsvTopicColumns>, List<CsvTopicColumns>> addFieldAndCalculator() {
        return previousConfig -> {
            // We retrieve the previous columns of the topic for the Tenors store.
            CsvTopicColumns prevColumns = previousConfig.get(StoreNames.TENOR_STORE_NAME);
            List<String> newColumns = new ArrayList<>(prevColumns.getColumns());
            newColumns.add(TEST_FIELD);

            // We retrieve the previous calculators defined for the store.
            // While in this instance the topic name and the store are the same, calculators can be defined for multiple stores within a topic.
            Map<String, List<IColumnCalculator<ILineReader>>> topicCalculators = new HashMap<>(prevColumns.getCalculators());
            List<IColumnCalculator<ILineReader>> storeCalculators = new ArrayList<>(topicCalculators.get(StoreNames.TENOR_STORE_NAME));
            storeCalculators.add(new IColumnCalculator<>() {
                @Override public String getColumnName() {
                    return DOUBLE_NUMBER_OF_DAYS;
                }

                @Override public Object compute(IColumnCalculationContext<ILineReader> context) {
                    return ((Double) context.getValue(StoreFieldNames.TENOR_NUMBER_OF_DAYS)) * 2.0;
                }
            });
            topicCalculators.put(StoreNames.TENOR_STORE_NAME, storeCalculators);

            // We create a new CsvTopicColumns object with the new list of columns and the previously defined column calculators.
            return List.of(new CsvTopicColumns(
                    StoreNames.TENOR_STORE_NAME,
                    newColumns,
                    topicCalculators
            ));
        };
    }

@Qualifier(SP_QUALIFIER__SENSI_TOPIC_PUBLISHERS)
    @Order(10)
    public Function<Map<String, CsvTopicPublisher<Path>>, List<CsvTopicPublisher<Path>>> addPublisher()

    @Bean
    @Qualifier(SP_QUALIFIER__SENSI_TOPIC_PUBLISHERS)
    @Order(10)
    public Function<Map<String, CsvTopicPublisher<Path>>, List<CsvTopicPublisher<Path>>> addPublisher(
            @Autowired IDatastore datastore
    ) {
        return previousConfig -> List.of(
                new CsvTopicPublisher<>(
                        StoreNames.TENOR_STORE_NAME,
                        new ITuplePublisher<IFileInfo<Path>>() {
                            @Override
                            public void publish(IStoreMessage<? extends IFileInfo<Path>, ?> message, List<Object[]> tuples) {
                                // We use the expected index for the SensitivityName field here, while in a complete implementation the index would be an instance variable.
                                tuples.forEach(tuple -> tuple[1] = "TestValue");
                                datastore.getTransactionManager().addAll(StoreNames.TENOR_STORE_NAME, tuples);
                            }

                            @Override
                            public Collection<String> getTargetStores() {
                                return Collections.singleton(StoreNames.TENOR_STORE_NAME);
                            }
                        }
                )
        );
    }

@Configuration
@Conditional(ConfigurationVectorised.class)
public class CustomizationsConfig {
    private static final String TEST_FIELD = "TestData";
    private static final String DOUBLE_NUMBER_OF_DAYS = "DoubleNumberOfDays";

    @Bean
    @Qualifier(SP_QUALIFIER__CUSTOMISATIONS)
    public Consumer<IDatastoreConfigurator> addFieldToStore() {
        return configurator -> {
            configurator.appendFields(SensiDatastoreDescriptionConfig.SCHEMA, StoreNames.TENOR_STORE_NAME,
                    List.of(
                            new CustomField(DOUBLE_NUMBER_OF_DAYS, ILiteralType.DOUBLE),
                            new CustomField(TEST_FIELD, ILiteralType.STRING)
                    )
            );
        };
    }

    @Bean
    @Qualifier(SP_QUALIFIER__SENSI_TOPIC_COLUMNS)
    @Order(10)
    public Function<Map<String, CsvTopicColumns>, List<CsvTopicColumns>> addFieldAndCalculator() {
        return previousConfig -> {
            // We retrieve the previous columns of the topic for the Tenors store.
            CsvTopicColumns prevColumns = previousConfig.get(StoreNames.TENOR_STORE_NAME);
            List<String> newColumns = new ArrayList<>(prevColumns.getColumns());
            newColumns.add(TEST_FIELD);

            // We retrieve the previous calculators defined for the store. The Tenors store has a column calculator setting indices for each tenor.
            // While in this instance the topic name and the store are the same, calculators can be defined for multiple stores within a topic.
            Map<String, List<IColumnCalculator<ILineReader>>> topicCalculators = new HashMap<>(prevColumns.getCalculators());
            List<IColumnCalculator<ILineReader>> storeCalculators = new ArrayList<>(topicCalculators.get(StoreNames.TENOR_STORE_NAME));
            storeCalculators.add(new IColumnCalculator<>() {
                @Override public String getColumnName() {
                    return DOUBLE_NUMBER_OF_DAYS;
                }

                @Override public Object compute(IColumnCalculationContext<ILineReader> context) {
                    return ((Double) context.getValue(StoreFieldNames.TENOR_NUMBER_OF_DAYS)) * 2.0;
                }
            });
            topicCalculators.put(StoreNames.TENOR_STORE_NAME, storeCalculators);

            // We create a new CsvTopicColumns object with the new list of columns and the previously defined column calculators.
            return List.of(new CsvTopicColumns(
                    StoreNames.TENOR_STORE_NAME,
                    newColumns,
                    topicCalculators
            ));
        };
    }

    @Bean
    @Qualifier(SP_QUALIFIER__SENSI_TOPIC_PUBLISHERS)
    @Order(10)
    public Function<Map<String, CsvTopicPublisher<Path>>, List<CsvTopicPublisher<Path>>> addPublisher(
            @Autowired IDatastore datastore
    ) {
        return previousConfig -> List.of(
                new CsvTopicPublisher<>(
                        StoreNames.TENOR_STORE_NAME,
                        new ITuplePublisher<IFileInfo<Path>>() {
                            @Override
                            public void publish(IStoreMessage<? extends IFileInfo<Path>, ?> message, List<Object[]> tuples) {
                                // We use the expected index for the SensitivityName field here, while in a complete implementation the index would be an instance variable.
                                tuples.forEach(tuple -> tuple[1] = "TestValue");
                                datastore.getTransactionManager().addAll(StoreNames.TENOR_STORE_NAME, tuples);
                            }

                            @Override
                            public Collection<String> getTargetStores() {
                                return Collections.singleton(StoreNames.TENOR_STORE_NAME);
                            }
                        }
                )
        );
    }
}

@Import(value = {
        ...
		CustomizationsConfig.class

})
public class MarketRiskConfig {
    ...
}