Uses of Class
io.aiven.commons.kafka.connector.source.config.SourceCommonConfig

Packages that use SourceCommonConfig

Package	Description
io.aiven.commons.kafka.connector.source
io.aiven.commons.kafka.connector.source.config
io.aiven.commons.kafka.connector.source.extractor

Uses of SourceCommonConfig in io.aiven.commons.kafka.connector.source

Methods in io.aiven.commons.kafka.connector.source that return SourceCommonConfig

Modifier and Type	Method	Description
protected abstract SourceCommonConfig	AbstractSourceTask.configure(Map<String,String> props, OffsetManager offsetManager)	Called by AbstractSourceTask.start(java.util.Map<java.lang.String, java.lang.String>) to allows the concrete implementation to configure itself based on properties.

Methods in io.aiven.commons.kafka.connector.source with parameters of type SourceCommonConfig

Modifier and Type	Method	Description
protected abstract EvolvingSourceRecordIterator	AbstractSourceTask.getIterator(SourceCommonConfig config)	Gets the iterator of SourceRecords.

Constructors in io.aiven.commons.kafka.connector.source with parameters of type SourceCommonConfig

Modifier	Constructor	Description
	EvolvingSourceRecordIterator(SourceCommonConfig sourceConfig, NativeSourceData<?> nativeSourceData)	Constructor.
protected	NativeSourceData(SourceCommonConfig sourceConfig, OffsetManager offsetManager)	Constructor

Uses of SourceCommonConfig in io.aiven.commons.kafka.connector.source.config

Methods in io.aiven.commons.kafka.connector.source.config with parameters of type SourceCommonConfig

Modifier and Type	Method	Description
Extractor	SourceConfigFragment.getExtractor(SourceCommonConfig config)	Gets the Extractor instance for this source.

Uses of SourceCommonConfig in io.aiven.commons.kafka.connector.source.extractor

Fields in io.aiven.commons.kafka.connector.source.extractor declared as SourceCommonConfig

Modifier and Type	Field	Description
protected final SourceCommonConfig	Extractor.config	The source configuration for the Kafka task.

Constructors in io.aiven.commons.kafka.connector.source.extractor with parameters of type SourceCommonConfig

Modifier	Constructor	Description
	AvroExtractor(SourceCommonConfig config)	Constructs the AvroExtractor.
	ByteArrayExtractor(SourceCommonConfig config)	Constructs a ByteArray extractor using the values from the config.
	CsvExtractor(SourceCommonConfig config)	Constructor.
protected	Extractor(SourceCommonConfig config, ExtractorInfo info)	Constructor.
protected	InputStreamExtractor(SourceCommonConfig config, ExtractorInfo info)	Constructs a extractor that processes an input stream rather than a stream of objects.
	JsonExtractor(SourceCommonConfig config)	Constructs the JSON Extractor with the specified config.
	ParquetExtractor(SourceCommonConfig config)	Constructs a ParquetExtractor using the values from the configuration.