All Classes and Interfaces
Class
Description
An abstract implementation of NativeInfo handling for Source.
This class handles extracting records from an iterator and returning them to Kafka.
Transforms a stream of Avro records into individual kafka messages, one per record.
Lookback that uses a buffer to track the last N records.
ByteArrayExtractor chunks an entire object into a maximum size specified by the extractorBuffer
SourceConfigFragment.Setter.extractorBuffer(int) configuration option.The definition of the common connector config functions.
The configuration definition for the common connector.
The common connector fragment.
Gets the setter for this fragment.
A Context which captures all the details about the source object that are required to
successfully send a source record onto Kafka
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.
An enumeration of distribution strategies.
An evolving source record initially retrieved from the storage layer.
Iterator that processes Native Source Data and creates AbstractSourceRecords.
Extracts data from the native abstract source record to Key SchemaAndValue object and a stream of
SchemaAndValue objects for the values.
The Information about the extractor.
A registry of extractors.
A ExtractorRegistry builder.
Extracts data from the EvolvingSourceRecord to a Key SchemaAndValue object and a stream of
SchemaAndValue objects for the values.
A Spliterator that performs various checks on the opening/closing of the input stream.
Transforms an input stream into a number of Jason records.
A Lookback that only tracks the last key seen.
Defines the strategy for providing the next key for the client to search for.
Information about the Native object.
A data source for native info from a source.
A serializer / deserializer pair for a native key.
Lookback that does not track any keys.
An offset manager that handles local updates to Kafka offset manager.
The definition of an entry in the OffsetManager.
The OffsetManager Key.
A parameter is a name/value pair
The Description of a parameter including the name and an input validator.
The builder for a ParameterDescriptor.
A Extractor that converts an input stream from a Parquet file into individual kafka messages, one
per record.
A factory to create
SchemaAndValue instances from arbitrary Objects.The common definitions for source connectors.
The common source configuration definition.
Defines properties that are shared across all Source implementations.
The SourceConfigFragment setter.
A parsed template string.
A parser for a template
A fragment of the template as segregated by the parser.
A validator for templates.
The template variable definition.
A builder for TemplateVariable instances.
A registry of template variables.
Builder for VariableTemplateRegistries.
Creates instances of TemplateVariableRegistry for generated documentation.
A piece of static text extracted by the parser.
A template part tht contains a variable definition.