Package com.activeviam.risk.starter.cfg.impl

Class DataLoadControllerConfig

java.lang.Object

com.activeviam.risk.starter.cfg.impl.DataLoadControllerConfig

@Configuration
@Profile("dist-data-node | !dist-query-node")
public class DataLoadControllerConfig
extends Object

Configure a data load controller.

The initial data loading is defined in InitialDataLoadConfig. Scopes are resolved into directories and files using the beans in DataLoadControllerFileConfig.

Field Summary

Fields

Modifier and Type	Field	Description
static String	ALL
static String	ALL_ATTRIBUTES
static String	ALL_CONFIGURATION
static String	ALL_FACTS
static String	ALL_SENSI
static String	ATTRIBUTES
static String	DAILY_SENSI_CONFIG
static String	DYNAMIC_SENSI_PILLARS
protected static Logger	LOGGER
static String	PARENT_CHILD
static String	SENSI_CONFIG
static String	SENSI_PILLARS
static String	SENSITIVITIES
static String	STATIC_SENSI_PILLARS

Constructor Summary

Constructors

Constructor	Description
DataLoadControllerConfig()

Method Summary

Modifier and Type	Method	Description
com.activeviam.tools.dataloadcontroller.controller.IDataLoadController	dataLoadController(List<Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController>> registrations)	Spring bean for the data load controller.
Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController>	registerCsv(List<ICsvSourceConfig<?>> csvSourceConfigs)
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController>	registerTopicAliases()
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController>	registerTopicAliasesImport()
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController>	registerTopicAliasesScalar()
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController>	registerTopicAliasesStandard()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SENSI_PILLARS

public static final String SENSI_PILLARS

See Also:

Constant Field Values

STATIC_SENSI_PILLARS

public static final String STATIC_SENSI_PILLARS

See Also:

Constant Field Values

DYNAMIC_SENSI_PILLARS

public static final String DYNAMIC_SENSI_PILLARS

See Also:

Constant Field Values

DAILY_SENSI_CONFIG

public static final String DAILY_SENSI_CONFIG

See Also:

Constant Field Values

SENSI_CONFIG

public static final String SENSI_CONFIG

See Also:

Constant Field Values

SENSITIVITIES

public static final String SENSITIVITIES

See Also:

Constant Field Values

ALL_SENSI

public static final String ALL_SENSI

See Also:

Constant Field Values

PARENT_CHILD

public static final String PARENT_CHILD

See Also:

Constant Field Values

ATTRIBUTES

public static final String ATTRIBUTES

See Also:

Constant Field Values

ALL_ATTRIBUTES

public static final String ALL_ATTRIBUTES

See Also:

Constant Field Values

ALL_FACTS

public static final String ALL_FACTS

See Also:

Constant Field Values

ALL

public static final String ALL

See Also:

Constant Field Values

ALL_CONFIGURATION

public static final String ALL_CONFIGURATION

See Also:

Constant Field Values

LOGGER

protected static Logger LOGGER

Constructor Detail

DataLoadControllerConfig

public DataLoadControllerConfig()

Method Detail

dataLoadController

@Bean(destroyMethod="close")
public com.activeviam.tools.dataloadcontroller.controller.IDataLoadController dataLoadController(@Qualifier("DLC-registration")
                                                                                                 List<Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController>> registrations)

Spring bean for the data load controller. This method will also register the sources and topic aliases.

Parameters:

registrations - autowired list of registrations

Returns:

the data load controller instance

registerCsv

@Bean
@Qualifier("DLC-registration")
public Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController> registerCsv(@Qualifier("DLC-source")
                                                                                                    List<ICsvSourceConfig<?>> csvSourceConfigs)

registerTopicAliasesScalar

@Bean
@Qualifier("DLC-registration")
@Profile("scalar-sensi")
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController> registerTopicAliasesScalar()

registerTopicAliasesStandard

@Bean
@Profile("standard")
@Qualifier("DLC-registration")
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController> registerTopicAliasesStandard()

registerTopicAliasesImport

@Bean
@Profile({"store-import","aggregated-import","scalar-sensi-store-import","scalar-sensi-aggregated-import"})
@Qualifier("DLC-registration")
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController> registerTopicAliasesImport()

registerTopicAliases

@Bean
@Profile({"standard","scalar-sensi"})
@Qualifier("DLC-registration")
protected Consumer<com.activeviam.tools.dataloadcontroller.controller.IDataLoadController> registerTopicAliases()