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 inDataLoadControllerFileConfig
.
-
-
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
All Methods Instance Methods Concrete Methods 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()
-
-
-
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
-
-
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()
-
-