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

Class PnLImportSourceConfig

java.lang.Object

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

com.activeviam.risk.ref.cfg.pnl.impl.PnLImportSourceConfig

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

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
PnLImportSourceConfig()

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()
Map<String,com.quartetfs.fwk.IPair<String,String>>	getTopicToStoreAndFilePatternMap()
ICsvSourceConfig<Path>	pnlCsvSourceConfig()

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("pnlPatterns")
public Map<String,com.quartetfs.fwk.IPair<String,String>> patterns

Constructor Detail

PnLImportSourceConfig

public PnLImportSourceConfig()

Method Detail

getTopicToStoreAndFilePatternMap

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

Specified by:

getTopicToStoreAndFilePatternMap in class ACSVSourceConfig

csvChannelFactory

@Bean(name="pnlCsvMessageChannelFactory")
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="pnlCsvSource")
public com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<Path> csvSource()

Specified by:

csvSource in class ACSVSourceConfig

pnlCsvSourceConfig

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