Package com.activeviam.risk.ref.cfg.var.impl

Class VaRImportSourceConfig

java.lang.Object

com.activeviam.risk.ref.cfg.impl.ACSVSourceConfig

com.activeviam.risk.ref.cfg.var.impl.VaRImportSourceConfig

@Configuration
@Profile({"store-import","aggregated-import","scalar-sensi-store-import","scalar-sensi-aggregated-import"})
public class VaRImportSourceConfig
extends ACSVSourceConfig

VaR source configuration

Field Summary

Fields

Modifier and Type	Field	Description
Map<String,com.quartetfs.fwk.IPair<String,String>>	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, LOGGER

Constructor Summary

Constructors

Constructor	Description
VaRImportSourceConfig()

Method Summary

Modifier and Type	Method	Description
com.qfs.source.impl.CSVMessageChannelFactory<Path>	csvChannelFactory()	This function must be overridden in order to create a specific bean
com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<Path>	csvSource()
protected Map<String,com.quartetfs.fwk.IPair<String,String>>	getTopicToStoreAndFilePatternMap()
ICsvSourceConfig<Path>	varCsvSourceConfig()

Methods inherited from class com.activeviam.risk.ref.cfg.impl.ACSVSourceConfig

createCsvSource, createTopicConfig, csvSource, csvSourceConfiguration, defineTopic, getFileColumns, getLinesToSkip, getTopicToPublisherMap, getTuplePublisher, verifyFolder

Methods inherited from class java.lang.Object

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

Field Detail

patterns

@Autowired
@Qualifier("varPatterns")
public Map<String,com.quartetfs.fwk.IPair<String,String>> patterns

Constructor Detail

VaRImportSourceConfig

public VaRImportSourceConfig()

Method Detail

getTopicToStoreAndFilePatternMap

protected Map<String,com.quartetfs.fwk.IPair<String,String>> getTopicToStoreAndFilePatternMap()

Specified by:

getTopicToStoreAndFilePatternMap in class ACSVSourceConfig

csvChannelFactory

@Bean(name="VaRCsvChannelFactory")
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 class ACSVSourceConfig

Returns:

the CSVMessageChannelFactory

csvSource

@Bean(name="varCsvSource")
public com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<Path> csvSource()

Specified by:

csvSource in class ACSVSourceConfig

varCsvSourceConfig

@Bean
@Qualifier("DLC-source")
public ICsvSourceConfig<Path> varCsvSourceConfig()