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

package io.aiven.commons.kafka.connector.source.extractor

Related Packages

Package	Description
io.aiven.commons.kafka.connector.source
io.aiven.commons.kafka.connector.source.config
io.aiven.commons.kafka.connector.source.lookback
io.aiven.commons.kafka.connector.source.task

Class	Description
AvroExtractor	Transforms a stream of Avro records into individual kafka messages, one per record.
ByteArrayExtractor	ByteArrayExtractor chunks an entire object into a maximum size specified by the extractorBuffer SourceConfigFragment.Setter.extractorBuffer(int) configuration option.
CsvExtractor	This class provides a extractor to take a List of CSVRecord generated from apache csv-commons and transforms that data into a SchemaAndValue Object usable by Connect to add messages to Kafka.
Extractor	Extracts data from the native abstract source record to Key SchemaAndValue object and a stream of SchemaAndValue objects for the values.
ExtractorInfo	The Information about the extractor.
ExtractorRegistry	A registry of extractors.
ExtractorRegistry.Builder	A ExtractorRegistry builder.
InputStreamExtractor	Extracts data from the EvolvingSourceRecord to a Key SchemaAndValue object and a stream of SchemaAndValue objects for the values.
InputStreamExtractor.StreamSpliterator	A Spliterator that performs various checks on the opening/closing of the input stream.
JsonExtractor	Transforms an input stream into a number of Jason records.
ParquetExtractor	A Extractor that converts an input stream from a Parquet file into individual kafka messages, one per record.
SchemaAndValueFactory	A factory to create SchemaAndValue instances from arbitrary Objects.