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

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

Modifier and Type	Method	Description
com.qfs.source.impl.CSVMessageChannelFactory<Path>	csvChannelFactory()	This function must be overridden in order to create a specific bean
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 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

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static Logger LOGGER

Constructor Detail

ScalarSensiSourceConfig

public ScalarSensiSourceConfig()

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

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

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

Parameters:

topic - The current topic

Returns:

A tuple publisher if any or null