Package com.activeviam.risk.ref.source.dataloadcontroller.impl

Class SimpleCsvSourceConfig<I>

java.lang.Object

com.activeviam.risk.ref.source.dataloadcontroller.impl.SimpleSourceConfig<com.qfs.msg.csv.IFileInfo<I>,com.qfs.msg.csv.ILineReader>

com.activeviam.risk.ref.source.dataloadcontroller.impl.SimpleCsvSourceConfig<I>

Type Parameters:

I - type of identifier of the files this source works with.

All Implemented Interfaces:

ICsvSourceConfig<I>, ISourceConfig<com.qfs.msg.csv.IFileInfo<I>,com.qfs.msg.csv.ILineReader>

public class SimpleCsvSourceConfig<I>
extends SimpleSourceConfig<com.qfs.msg.csv.IFileInfo<I>,com.qfs.msg.csv.ILineReader>
implements ICsvSourceConfig<I>

A flavour of SimpleSourceConfig for use with CSV file sources.

Nested Class Summary

Nested classes/interfaces inherited from class com.activeviam.risk.ref.source.dataloadcontroller.impl.SimpleSourceConfig

SimpleSourceConfig.ITopicConfig<I>

Constructor Summary

Constructors

Constructor	Description
SimpleCsvSourceConfig(com.qfs.source.impl.CSVMessageChannelFactory<I> messageChannelFactory, com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<I> source, Map<String,SimpleSourceConfig.ITopicConfig<com.qfs.msg.csv.IFileInfo<I>>> topicConfigs)

Method Summary

Modifier and Type	Method	Description
com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<I>	getSource()

Methods inherited from class com.activeviam.risk.ref.source.dataloadcontroller.impl.SimpleSourceConfig

createChannel, getTargetStores

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.activeviam.risk.ref.source.dataloadcontroller.ISourceConfig

createChannel, getTargetStores

Constructor Detail

SimpleCsvSourceConfig

public SimpleCsvSourceConfig(com.qfs.source.impl.CSVMessageChannelFactory<I> messageChannelFactory,
                             com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<I> source,
                             Map<String,SimpleSourceConfig.ITopicConfig<com.qfs.msg.csv.IFileInfo<I>>> topicConfigs)

Method Detail

getSource

public com.activeviam.tools.dataloadcontroller.core.source.csv.CsvScopedFetchSource<I> getSource()

Specified by:

getSource in interface ICsvSourceConfig<I>

Specified by:

getSource in interface ISourceConfig<com.qfs.msg.csv.IFileInfo<I>,com.qfs.msg.csv.ILineReader>

Overrides:

getSource in class SimpleSourceConfig<com.qfs.msg.csv.IFileInfo<I>,com.qfs.msg.csv.ILineReader>

Returns:

the source object that can be registered with IDataLoadController