All Classes and Interfaces
Class
Description
An abstract class that is the bases for programmatic configuration easier.
AbstractSourceRecord<K extends Comparable<K>,N,O extends OffsetManager.OffsetManagerEntry<O>,T extends AbstractSourceRecord<K,N,O,T>>
An abstract source record as retrieved from the storage layer.
AbstractSourceRecordIterator<K extends Comparable<K>,N,O extends OffsetManager.OffsetManagerEntry<O>,T extends AbstractSourceRecord<K,N,O,T>>
Iterator that processes cloud storage items and creates Kafka source records.
This class handles extracting records from an iterator and returning them to Kafka.
A functional interface that will abort the timer.
Performs a delay based on the number of successive
AbstractSourceTask.Backoff.delay() or AbstractSourceTask.Backoff.cleanDelay() calls without a
AbstractSourceTask.Backoff.reset().An interface to define the Backoff configuration.
A functional interface to return long values.
Calculates elapsed time and flags when expired.
Deprecated.
Defines the backoff policy for connectors.
ByteArrayTransformer chunks an entire object into a maximum size specified by the
TransformerFragment.TRANSFORMER_MAX_BUFFER_SIZE configuration option.The base configuration or all connectors.
The common configuration fragment.
Setter to programmatically set values in the configuraiotn.
The configuration fragment that defines the compression characteristics.
Config fragments encapsulate logical fragments of configuration that may be used across multiple Connectors or across
the source/sink of a connector pair.
A Context which captures all the details about the source which are required to successfully send a source record
onto Kafka
An
DistributionStrategy provides a mechanism to share the work of processing records from objects (or files)
into tasks, which are subsequently processed (potentially in parallel) by Kafka Connect workers.Fragment to handle all file name extraction operations.
Setter for the FileNameFragment.
Deprecated.
switch to
SourcenameTemplateValidator and specific sink/source validation.FilePatternUtils allows the construction of a regex pattern to extract the
Context from an Object Key.A
ConfigDef.Recommender that always supports only the predefined set of values.Defines the configuration for Kafka.
Enum for setting discovery.
The setter class to set options in a data map for the configuration.
A
RecordGrouper that groups records by topic, parition and key.A
RecordGrouper that groups records by key.This code was originally developed as part of the Apache Parquet project
LocalInputFile is an implementation needed by Parquet to read from local data files using
SeekableInputStream instances.Information about the Native object.
NativeSourceData<K extends Comparable<K>,N,O extends OffsetManager.OffsetManagerEntry<O>,T extends AbstractSourceRecord<K,N,O,T>>
Wraps an object mapper for reuse.
The definition of an entry in the OffsetManager.
The OffsetManager Key.
The setter for OutputFormatFragment.
The interface for classes that associates
SinkRecords with files by some criteria.Implements a ring buffer of items.
Defines properties that are shared across all Source implementations.
The SourceConfigFragment setter.
A simple templating engine that allows to bind variables to supplier functions.
A Spliterator that performs various checks on the opening/closing of the input stream.
A factory to create Transformers.
Fragment to manage transformer configuration.
The setter for the TransformerFragment
SinkCommonConfiginstead