Class ScalarSensiSourceConfig
- java.lang.Object
-
- com.activeviam.risk.ref.cfg.impl.ACSVSourceConfig
-
- com.activeviam.risk.ref.cfg.sensi.impl.ASensiSourceConfig
-
- com.activeviam.risk.ref.cfg.sensi.impl.ScalarSensiSourceConfig
-
@Configuration @Profile("scalar-sensi & (dist-data-node | !dist-query-node)") public class ScalarSensiSourceConfig extends ASensiSourceConfig
Sensitivities source config
-
-
Field Summary
Fields Modifier and Type Field Description protected static Logger
LOGGER
-
Fields inherited from class com.activeviam.risk.ref.cfg.sensi.impl.ASensiSourceConfig
greekDescription, patterns
-
Fields inherited from class com.activeviam.risk.ref.cfg.impl.ACSVSourceConfig
datastoreConfig, DEFAULT_CSV_BUFFER_SIZE, DEFAULT_CSV_LINES_TO_SKIP, DEFAULT_CSV_PARSER_THREADS, DEFAULT_CSV_SEPARATOR, env, folder
-
-
Constructor Summary
Constructors Constructor Description ScalarSensiSourceConfig()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description com.qfs.source.impl.CSVMessageChannelFactory<Path>
csvChannelFactory()
This function must be overridden in order to create a specific beanprotected List<String>
getFileColumns(String topicName, Map<String,com.quartetfs.fwk.IPair<String,String>> topicToStoreAndFilePatternMap, com.qfs.store.IDatastoreSchemaMetadata schemaMetadata)
Retrieves the list of file columns for a given store, either from a custom list where configured, or from the store configuration.protected com.qfs.source.ITuplePublisher<com.qfs.msg.csv.IFileInfo<Path>>
getTuplePublisher(String topic)
This function is intended to be overridden in order to specify some specific tuple publishers-
Methods inherited from class com.activeviam.risk.ref.cfg.sensi.impl.ASensiSourceConfig
csvSource, getGreekTopics, getTopicToStoreAndFilePatternMap, sensiCsvSourceConfig
-
Methods inherited from class com.activeviam.risk.ref.cfg.impl.ACSVSourceConfig
createCsvSource, createTopicConfig, csvSource, csvSourceConfiguration, defineTopic, getLinesToSkip, getTopicToPublisherMap, verifyFolder
-
-
-
-
Field Detail
-
LOGGER
protected static final Logger LOGGER
-
-
Method Detail
-
csvChannelFactory
@Bean(name="SensicsvChannelFactory") public com.qfs.source.impl.CSVMessageChannelFactory<Path> csvChannelFactory()
Description copied from class:ACSVSourceConfig
This function must be overridden in order to create a specific bean- Overrides:
csvChannelFactory
in classACSVSourceConfig
- Returns:
- the CSVMessageChannelFactory
-
getFileColumns
protected List<String> getFileColumns(String topicName, Map<String,com.quartetfs.fwk.IPair<String,String>> topicToStoreAndFilePatternMap, com.qfs.store.IDatastoreSchemaMetadata schemaMetadata)
Retrieves the list of file columns for a given store, either from a custom list where configured, or from the store configuration.- Overrides:
getFileColumns
in classACSVSourceConfig
- Parameters:
topicName
- The name of the destination store.topicToStoreAndFilePatternMap
- The topic basic descriptionschemaMetadata
- The schema metadata.- Returns:
- The list of columns in the source file.
-
getTuplePublisher
protected com.qfs.source.ITuplePublisher<com.qfs.msg.csv.IFileInfo<Path>> getTuplePublisher(String topic)
Description copied from class:ACSVSourceConfig
This function is intended to be overridden in order to specify some specific tuple publishers- Overrides:
getTuplePublisher
in classACSVSourceConfig
- Parameters:
topic
- The current topic- Returns:
- A tuple publisher if any or null
-
-