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

Class PnLSourceConfig

java.lang.Object

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

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

@Configuration
@Profile("(standard|scalar-sensi) & (dist-data-node | !dist-query-node)")
public class PnLSourceConfig
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
PnLSourceConfig()

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 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 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, 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

PnLSourceConfig

public PnLSourceConfig()

Method Detail

getTopicToStoreAndFilePatternMap

protected 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

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 class ACSVSourceConfig

Parameters:

topicName - The name of the destination store.

topicToStoreAndFilePatternMap - The topic basic description

schemaMetadata - The schema metadata.

Returns:

The list of columns in the source file.

pnlCsvSourceConfig

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