All Classes (flink-cdc-parent 3.8-SNAPSHOT API)

All Classes Interface Summary Class Summary Enum Summary Exception Summary Annotation Types Summary
Class	Description
AbstractLogMinerEventProcessor<T extends io.debezium.connector.oracle.logminer.processor.AbstractTransaction>	Copied from Debezium 1.9.8.Final.
AbstractScanFetchTask	An abstract `FetchTask` implementation to read snapshot split.
AddColumnEvent	A `SchemaChangeEvent` that represents an `ADD COLUMN` DDL, which may contain the lenient column type changes.
AddColumnEvent.ColumnPosition	relative Position of column.
AddColumnEvent.ColumnWithPosition	represents result of an ADD COLUMN DDL that may change column sequence.
AddColumnEventSerializer	A `TypeSerializer` for `AddColumnEvent`.
AddColumnEventSerializer.AddColumnEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
AddOneFunctionClass	This is an example UDF class for testing purposes only.
AddOneFunctionClass	This is an example Flink UDF class for testing purposes only.
AiEmbeddingFunctionDef	Built-in AI embedding function definitions with configurable input and output types.
AiFunctions	Built-in AI functions available to transform expressions.
AiFunctionSqlOperatorTable	Creates an SqlOperatorTable containing the built-in AI functions.
AiImageFunctionDef	Built-in AI image function definitions.
AiImageFunctionDef.Capability	Capability required by an image AI function.
AiModelClient	Marker interface for a runtime AI model client.
AiModelClientFactory	A `Factory` that creates `AiModelClient` instances.
AiTextFunctionDef	Built-in AI text generation function definitions.
AlterColumnTypeEvent	A `SchemaChangeEvent` that represents an `ALTER COLUMN` DDL, which may contain the lenient column type changes.
AlterColumnTypeEventSerializer	A `TypeSerializer` for `AlterColumnTypeEvent`.
AlterColumnTypeEventSerializer.AlterColumnTypeEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
AlterTableCommentEvent	A `SchemaChangeEvent` that represents an `ALTER TABLE COMMENT` or `ALTER TABLE SET COMMENT` DDL.
AlterTableCommentEventSerializer	A `TypeSerializer` for `AlterTableCommentEvent`.
AlterTableCommentEventSerializer.AlterTableCommentEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
AppendMetadataCollector	Emits a row with physical fields and metadata fields.
ArithmeticFunctions	Arithmetic built-in functions.
ArrayData	Base interface of an internal data structure representing data of `ArrayType`.
ArrayData.ElementGetter	Accessor for getting the elements of an array during runtime.
ArrayDataSerializer	Serializer for `ArrayData`.
ArrayDataSerializer.ArrayDataSerializerSnapshot	`TypeSerializerSnapshot` for `ArrayDataSerializer`.
ArrayType	Data type of an array of elements with same subtype.
AssertUtils	Utilities for asserting `SourceRecord` and `DebeziumSourceFunction`.
AssignerStatus	The state of split assigner finite state machine, tips: we use word status instead of word state to avoid conflict with Flink state keyword.
AssignerStatus	The state of split assigner finite state machine, tips: we use word status instead of word state to avoid conflict with Flink state keyword.
AsyncPostTransformFunction	An async post-transform function for ordered async execution.
AsyncPostTransformFunctionBuilder	Builder of `AsyncPostTransformFunction`.
AsyncPostTransformOperatorFactory	Factory for an ordered async post-transform operator with state-consistent checkpoints.
BaseParserListener	This class contains common methods for all listeners.
BaseSourceConfig	A basic Source configuration which is used by `IncrementalSource`.
BatchAppendWriter	MaxCompute upsert writer, use `UpsertSessionImpl` and `UpsertStream` to write data.
BatchDataSinkFunctionOperator	An operator that processes records to be written into a `SinkFunction` in batch mode.
BatchDataSinkWriterOperator<CommT>	An operator that processes records to be written into a `Sink` in batch mode.
BatchRegularPrePartitionOperator	Operator for processing events from `SchemaOperator` before `EventPartitioner` with regular topology in batch mode.
BatchSchemaOperator	The operator will apply create table event and router mapper in batch mode.
BatchUpsertWriter	MaxCompute upsert writer, use `UpsertSessionImpl` and `UpsertStream` to write data.
BigIntType	Data type of an 8-byte signed integer with values from -9,223,372,036,854,775,808 to 9,223,372,036,854,775,807.
BinaryArrayData	A binary implementation of `ArrayData` which is backed by `MemorySegment`s.
BinaryArrayWriter	Writer for binary array.
BinaryArrayWriter.NullSetter	Accessor for setting the elements of an array writer to `null` during runtime.
BinaryFormat	Binary format spanning `MemorySegment`s.
BinaryInternalObjectConverter	Also an `InternalObjectConverter` but encodes `RecordData` as `BinaryRecordData`.
BinaryMapData	[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
BinaryRecordData	An implementation of `RecordData` which is backed by `MemorySegment` instead of Object.
BinaryRecordDataDataUtil	Utilities for `BinaryRecordDataDataUtil`.
BinaryRecordDataExtractor	Utility methods for extracting human-readable objects from `RecordData`.
BinaryRecordDataGenerator	This class is used to create `BinaryRecordData`.
BinaryRecordDataSerializer	Serializer for `BinaryRecordData`.
BinaryRecordDataSerializer.BinaryRecordDataSerializerSnapshot	`TypeSerializerSnapshot` for `BinaryRecordDataSerializer`.
BinaryRecordDataWriter	Writer for `BinaryRecordData`.
BinarySection	A basic implementation of `BinaryFormat` which describe a section of memory.
BinarySegmentUtils	Utilities for binary data segments which heavily uses `MemorySegment`.
BinaryStringData	A lazily binary implementation of `StringData` which is backed by `MemorySegment`s and `String`.
BinaryType	Data type of a fixed-length binary string (=a sequence of bytes).
BinaryTypeReturningClass	This is an example UDF class for testing purposes only.
BinaryVariant	Copy from BinaryVariant.java.
BinaryVariantBuilder	Copy from BinaryVariantBuilder.java
BinaryVariantBuilder.VariantArrayBuilder	Builder for a variant array.
BinaryVariantBuilder.VariantObjectBuilder	Builder for a variant object.
BinaryVariantInternalBuilder	Copy from BinaryVariantBuilder.java
BinaryVariantInternalBuilder.FieldEntry	Temporarily store the information of a field.
BinaryVariantUtil	Copy from BinaryVariantUtil.java
BinaryVariantUtil.ArrayHandler<T>	1.
BinaryVariantUtil.ObjectHandler<T>	1.
BinaryWriter	Writer to write a composite data format, like row, array.
BinlogOffset	A structure describes a fine grained offset in a binlog event including binlog position and gtid set etc.
BinlogOffsetBuilder	Builder for `BinlogOffset`.
BinlogOffsetKind	Predefined kind of binlog offset.
BinlogOffsetSerializer	Serializer implementation for a `BinlogOffset`.
BinlogOffsetUtils	Utils for handling `BinlogOffset`.
BinlogPendingSplitsState	A `PendingSplitsState` for pending binlog splits.
BinlogSplitAssignedEvent	The `SourceEvent` that `MySqlSourceReader` sends to `MySqlSourceEnumerator` to notify the `MySqlBinlogSplit` assigned to itself.
BinlogSplitMetaAssembledEvent	The `SourceEvent` that `MySqlSourceReader` sends to `MySqlSourceEnumerator` once it holds a complete `MySqlBinlogSplit`, signalling that all finished snapshot split metadata has been assembled by the reader.
BinlogSplitMetaEvent	The `SourceEvent` that `MySqlSourceEnumerator` sends to `MySqlSourceReader` to pass binlog metadata, i.e.
BinlogSplitMetaRequestEvent	The `SourceEvent` that `MySqlSourceReader` sends to `MySqlSourceEnumerator` to pull binlog metadata, i.e.
BinlogSplitReader	A Debezium binlog reader implementation that also support reads binlog and filter overlapping snapshot data that `SnapshotSplitReader` read.
BinlogSplitUpdateAckEvent	The `SourceEvent` that `MySqlSourceReader` sends to `MySqlSourceEnumerator` to notify the binlog split reader has been updated.
BinlogSplitUpdateRequestEvent	The `SourceEvent` that `MySqlSourceEnumerator` broadcasts to `MySqlSourceReader` to tell the source reader to update the binlog split after newly added table snapshot splits finished.
BlobWriteContext	Context for handling BLOB fields during CDC write operations.
BlockElement	Part of description that represents a block e.g.
BooleanSerializer	Type serializer for `Boolean`.
BooleanSerializer.BooleanSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
BooleanType	Data type of a boolean with a (possibly) three-valued logic of `TRUE, FALSE, UNKNOWN`.
BsonUtils	Utility class to deal `BsonValue`s.
BucketAssignOperator	Operator that assigns bucket indices to events and wraps them for downstream partitioning.
BucketAssignOperator	Assign bucket for every given `DataChangeEvent`.
BucketWrapper	Wrapper class that implements Event and associates an event with a target bucket/task index.
BucketWrapper	Wrapper class with bucket.
BucketWrapperChangeEvent	A wrapper class for `ChangeEvent` to attach bucket id.
BucketWrapperEventSerializer	A `TypeSerializerSingleton` for `BucketWrapperChangeEvent`.
BucketWrapperEventSerializer.EventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
BucketWrapperEventTypeInfo	A `TypeInformation` for `PaimonEvent`.
BucketWrapperFlushEvent	A wrapper class for `FlushEvent` to attach bucket id and task metadata.
BucketWrapperFlushEvent	A wrapper class for `FlushEvent` to attach bucket id.
BufferedSocketInputStream	Copied from https://github.com/osheroff/mysql-binlog-connector-java project to fix https://github.com/ververica/flink-cdc-connectors/issues/460.
BuiltInScalarFunction	This is the case when the operator has a special parsing syntax or uses other Calcite-specific features that are not exposed via `SqlFunction` yet.
BuiltInScalarFunction.Builder	Builder for fluent definition of built-in functions.
BuiltInTimestampFunction	Function that used to define SQL time function like LOCALTIMESTAMP, CURRENT_TIMESTAMP, CURRENT_ROW_TIMESTAMP(), NOW() in Flink, the function support configuring the return type and the precision of return type.
BytePrimitiveArraySerializer	A serializer for byte arrays.
BytePrimitiveArraySerializer.BytePrimitiveArraySerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
ByteSerializer	Type serializer for `Byte`.
ByteSerializer.ByteSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
CachedTableFilter	A bounded cache for table filter results.
CalciteDataTypeConverter	A data type converter.
CanalJsonSerializationSchema	Serialization schema that serializes an object of FlinkCDC pipeline internal data structure `Event` into a Canal JSON bytes.
CastingFunctions	Casting built-in functions.
CatalogUtils	Rewrite to avoid using deprecated API.
CdcAsFlussArray	Wraps a CDC `ArrayData` as a Fluss `InternalArray`.
CdcAsFlussMap	Wraps a Cdc `MapData` as a Fluss `InternalMap`.
CdcAsFlussRow	Wraps a CDC `RecordData` as a Fluss `InternalRow`.
CDCClient	Copied from https://github.com/tikv/client-java project to fix https://github.com/tikv/client-java/issues/600 for 3.2.0 version.
CDCPostgresDispatcher	Postgres Dispatcher for cdc source with watermark.
ChangeEvent	Class `ChangeEvent` represents the change events of external systems, including `DataChangeEvent` and `SchemaChangeEvent`.
ChangeEventRecords	An implementation of `RecordsWithSplitIds` which contains the records of one table split.
ChangeEventUtils	Utilities for handling `ChangeEvent`s.
ChangeLogJsonFormatFactory	Format factory for providing configured instances of `SerializationSchema` to convert `Event` to json.
ChangeStreamDescriptor	A structure describes a filter of change stream targets.
ChangeStreamOffset	A structure describes a fine grained offset in a change log event including resumeToken and clusterTime.
ChangeStreamOffsetFactory	An change stream offset factory class create `ChangeStreamOffset` instance.
ChannelFactory	Copied from https://github.com/tikv/client-java project to fix https://github.com/tikv/client-java/issues/600 for 3.2.0 version.
CharType	Data type of a fixed-length character string.
CharTypeReturningClass	This is an example UDF class for testing purposes only.
ChunkRange	An internal structure describes a chunk range with a chunk start (inclusive) and chunk end (exclusive).
ChunkSplitter	The splitter used to split collection into a set of chunks.
ChunkSplitter	The `ChunkSplitter`'s task is to split table into a set of chunks or called splits (i.e.
ChunkSplitterState	The state of the `ChunkSplitter`.
ChunkSplitterState	The state of the `MySqlChunkSplitter`.
ChunkSplitterState.ChunkBound	The definition of the chunk bound.
ChunkSplitterState.ChunkBound	The definition of the chunk bound.
ChunkSplitterState.ChunkBoundType	The type of the chunk bound.
ChunkSplitterState.ChunkBoundType	The type of the chunk bound.
ChunkUtils	Utilities to split chunks of collection.
ChunkUtils	Utilities to split chunks of table.
ChunkUtils	Utilities to split chunks of table.
ChunkUtils	Utilities to split chunks of table.
CliExecutor	Executor for doing the composing and submitting logic for `CliFrontend`.
CliFrontend	The frontend entrypoint for the command-line interface of Flink CDC.
CliFrontendOptions	Command line argument options for `CliFrontend`.
CollectionDiscoveryUtils	Utilities to discovery matched collections.
CollectionDiscoveryUtils.CollectionDiscoveryInfo	Container class to hold discovered result.
Column	Representation of a column in a `Schema`.
ColumnDefinitionParserListener	Parser listener that parses column definitions of Oracle DDL statements.
ColumnSerializer	A `TypeSerializer` for `Column`.
ColumnSerializer.ColumnSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
ColumnType	Copied from mysql-binlog-connector 0.25.3 to support MYSQL_TYPE_TYPED_ARRAY.
ColumnWithPositionSerializer	A `TypeSerializer` for `AddColumnEvent.ColumnWithPosition`.
ColumnWithPositionSerializer.ColumnWithPositionSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
CommitSessionRequest	The commit session request from `MaxComputeEventWriter` to `SessionManageCoordinator`.
CommitSessionResponse	Response for a `CommitSessionRequest`.
CommonConverter	Some shared converters between Java objects and internal objects.
CompactionOperator	An Operator to trigger file compaction conditionally.
CompactionOptions	Strategy for small file compaction.
CompactionOptions.Builder	Builder for `CompactionOptions`.
ComparisonFunctions	Comparison built-in functions.
ComposeDeployment	Create deployment methods corresponding to different goals.
CompressAlgorithm	Compress algorithm for MaxCompute table.
ConfigOption<T>	A `ConfigOption` describes a configuration parameter.
ConfigOptions	`ConfigOptions` are used to build a `ConfigOption`.
ConfigOptions.ListConfigOptionBuilder<E>	Builder for `ConfigOption` of list of type `ConfigOptions.ListConfigOptionBuilder`.
ConfigOptions.OptionBuilder	The option builder is used to create a `ConfigOption`.
ConfigOptions.TypedConfigOptionBuilder<T>	Builder for `ConfigOption` with a defined atomic type.
ConfigurableFunctionClass	This is an example UDF class that reads options from configuration.
Configuration	Lightweight configuration object which stores key/value pairs.
ConfigurationUtils	Utilities for handling `Configuration`.
ConfigurationUtils	Utility class for `Configuration` related helper functions.
ConfigUtils	Utils for writer configurations.
ConnectionPoolId	The connection pool identifier.
ConnectionPoolId	The connection pool identifier.
ConnectionPools<P,C extends SourceConfig>	A pool collection that consists of multiple connection pools.
ConnectionPools	A JDBC connection pools that consists of `HikariDataSource`.
Constant	Constant use for MaxCompute Connector.
ConvertTimeBceUtil	Convert And Check TimeBce Util.
CoordinationResponseUtils	Utilities for wrapping and unwrapping `CoordinationResponse` by `CollectCoordinationResponse`.
CoordinatorExecutorThreadFactory	A thread factory class that provides some helper methods.
CreateSessionRequest	Represents a request sent from a `SessionManageOperator` to the `SessionManageCoordinator`.
CreateSessionResponse	the response of `CreateSessionRequest`, which contains the sessionId of specific `SessionIdentifier`.
CreateTableEvent	A `SchemaChangeEvent` that represents an `CREATE TABLE` DDL.
CreateTableEventSerializer	A `TypeSerializer` for `CreateTableEvent`.
CreateTableEventSerializer.CreateTableEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
CsvSerializationSchema	A `SerializationSchema` to convert `Event` into byte of csv format.
CustomAlterTableParserListener	Copied from `AlterTableParserListener` in Debezium 1.9.8.Final.
CustomColumnDefinitionParserListener	Parser listener that is parsing column definition part of MySQL statements.
CustomMySqlAntlrDdlParser	A ddl parser that will use custom listener.
CustomMySqlAntlrDdlParserListener	Copied from `MySqlAntlrDdlParserListener` in Debezium 1.9.8.final.
CustomPostgresSchema	A CustomPostgresSchema similar to PostgresSchema with customization.
CustomPostgresValueConverter	A `PostgresValueConverter` which is able to keep the date and time (wall clock) stored in PostgreSQL for `timestamp` values, instead of letting the time zone of the JVM shift them.
DatabaseHistoryUtil	Util to safely visit schema history between `DatabaseHistory` and `DebeziumSourceFunction`.
DatabaseNameMetadataColumn	A `SupportedMetadataColumn` for database_name.
DataChangeEvent	Class `DataChangeEvent` represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
DataChangeEventSerializer	A `TypeSerializer` for `DataChangeEvent`.
DataChangeEventSerializer.DataChangeEventSerializerSnapshot	`TypeSerializerSnapshot` for `DataChangeEventSerializer`.
DataField	Defines the field of a row type.
DataFieldSerializer	A `TypeSerializer` for `DataField`.
DataFieldSerializer.DataFieldSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
DataInputViewStream	An input stream that draws its data from a `DataInputView`.
DataOutputViewStream	An output stream that writes its data to a `DataOutputView`.
DataSink	`DataSink` is used to write change data to external system and apply metadata changes to external systems as well.
DataSinkFactory	A factory to create `DataSink` instances.
DataSinkFunctionOperator	An operator that processes records to be written into a `SinkFunction`.
DataSinkTranslator	Translator used to build `DataSink` for given `DataStream`.
DataSinkWriterOperator<CommT>	An operator that processes records to be written into a `Sink`.
DataSinkWriterOperatorFactory<CommT>	Operator factory for `DataSinkWriterOperator`.
DataSource	`DataSource` is used to access metadata and read change data from external systems.
DataSourceDialect<C extends SourceConfig>	The dialect of data source.
DataSourceFactory	A factory to create `DataSource` instances.
DataSourceTranslator	Translator used to build `DataSource` which will generate a `DataStream`.
DataType	Describes the data type in the Flink CDC data pipeline.
DataTypeChecks	Utilities for checking `DataType` and avoiding a lot of type casting and repetitive work.
DataTypeDefaultVisitor<R>	Implementation of `DataTypeVisitor` that redirects all calls to `DataTypeDefaultVisitor.defaultMethod(DataType)`.
DataTypeFamily	An enumeration of data type families for clustering `DataTypeRoot`s into categories.
DataTypeRoot	An enumeration of data type roots containing static information about fata data types.
DataTypes	A `DataType` can be used to declare input and/or output types of operations.
DataTypeSerializer	A `TypeSerializer` for `DataType`.
DataTypeSerializer.DataTypeSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
DataTypeUtils	Utilities for handling `DataType`s.
DataTypeVisitor<R>	The visitor definition of `DataType`.
DateData	An internal data structure representing data of `DateType`.
DateDataSerializer	Serializer for `DateData`.
DateDataSerializer.DateDataSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
DateTimeUtils	Utility functions for datetime types: date, time, timestamp.
DateType	Data type of a date consisting of `year-month-day` with values ranging from `0000-01-01` to `9999-12-31`.
Db2ChunkSplitter	The splitter to split the table into chunks using primary-key (by default) or a given split key.
Db2Connection	Copied from Debezium 1.9.8.Final.
Db2Connection.CdcEnabledTable
Db2ConnectionUtils	Utils for Db2 connection.
Db2Dialect	The `JdbcDataSourceDialect` implementation for Db2 datasource.
Db2PooledDataSourceFactory	Factory to create `JdbcConnectionPoolFactory` for SQL Server.
Db2ReadableMetaData	Defines the supported metadata columns for `Db2TableSource`.
Db2ScanFetchTask	The task to work for fetching data of Db2 table snapshot split.
Db2ScanFetchTask.Db2SnapshotSplitReadTask	A wrapped task to fetch snapshot split of table.
Db2Schema	A component used to get schema by table path.
Db2SchemaChangeEventHandler	This Db2SchemaChangeEventHandler helps to parse the source struct in SchemaChangeEvent and generate source info.
Db2Source	Source for DB2 CDC connector.
Db2Source.Builder<T>	Builder for Db2Source.
Db2SourceBuilder<T>	The builder class for `Db2SourceBuilder.Db2IncrementalSource` to make it easier for the users to construct a `Db2SourceBuilder.Db2IncrementalSource`.
Db2SourceBuilder.Db2IncrementalSource<T>	The `JdbcIncrementalSource` implementation for Db2.
Db2SourceConfig	Describes the connection information of the Db2 database and the configuration information for performing snapshotting and streaming reading, such as splitSize.
Db2SourceConfigFactory	Factory for creating `Db2SourceConfig`.
Db2SourceFetchTaskContext	The context for fetch task that fetching data of snapshot split from Db2 data source.
Db2SourceFetchTaskContext.Db2EventMetadataProvider	Copied from debezium for accessing here.
Db2StreamFetchTask	The task to work for fetching data of Db2 table stream split .
Db2StreamFetchTask.StreamSplitReadTask	A wrapped task to read all redo logs for table and also supports read bounded (from lowWatermark to highWatermark) redo logs.
Db2StreamingChangeEventSource	Copied from Debezium project(1.9.8.final)
Db2TableSource	TableSource for DB2 CDC connector.
Db2TableSourceFactory	Table source factory for DB2 CDC connector.
Db2TypeUtils	Utilities for converting from Db2 types to Flink SQL types.
Db2Utils	The utils for Db2 data source.
DebeziumChangeConsumer	Consume debezium change events.
DebeziumChangeFetcher<T>	A Handler that convert change messages from `DebeziumEngine` to data in Flink.
DebeziumChangelogMode	Changelog modes used to encode changes from Debezium to Flink internal structure.
DebeziumDeserializationSchema<T>	The deserialization schema describes how to turn the Debezium SourceRecord into data types (Java/Scala objects) that are processed by Flink.
DebeziumEventDeserializationSchema	Debezium event deserializer for `SourceRecord`.
DebeziumJsonRowDataSerializationSchema	Serialization schema that serializes an object of Flink internal data structure into a JSON bytes.
DebeziumJsonSerializationSchema	Serialization schema from FlinkCDC pipeline internal data structure `Event` to Debezium JSON.
DebeziumJsonStruct	Debezium JSON struct.
DebeziumOffset	The state that the Flink Debezium Consumer holds for each instance.
DebeziumOffsetSerializer	Serializer implementation for a `DebeziumOffset`.
DebeziumOptions	Option utils for Debezium options.
DebeziumReader<T,Split>	Reader to read split of table, the split is either snapshot split or binlog split.
DebeziumSchemaDataTypeInference	`DataType` inference for debezium `Schema`.
DebeziumSourceFunction<T>	The `DebeziumSourceFunction` is a streaming data source that pulls captured change data from databases into Flink.
DebeziumUtils	Utilities related to Debezium.
DecimalData	An internal data structure representing data of `DecimalType`.
DecimalDataSerializer	Serializer for `DecimalData`.
DecimalDataSerializer.DecimalSerializerSnapshot	`TypeSerializerSnapshot` for `DecimalDataSerializer`.
DecimalPrecisionMode	Maximum precision mode for DECIMAL type in transform expressions.
DecimalType	Data type of a decimal number with fixed precision and scale.
DecimalTypeNonNullReturningClass	This is an example UDF class for testing purposes only.
DecimalTypeReturningClass	This is an example UDF class for testing purposes only.
DefaultDataChangeEventHashFunctionProvider	The default `HashFunctionProvider` implementation for data change event.
DefaultHashContext	Default implementation of `HashFunction.HashContext`.
DefaultValueParserListener	Copied from Debezium project(v1.9.8.Final) to fix https://github.com/ververica/flink-cdc-connectors/issues/1506.
Description	Description for `ConfigOption`.
Description.DescriptionBuilder	Builder for `Description`.
DeserializationRuntimeConverter	Runtime converter that converts objects of Debezium into objects of Flink Table & SQL internal data structures.
DeserializationRuntimeConverterFactory	Factory to create `DeserializationRuntimeConverter` according to `LogicalType`.
DistributedPrePartitionOperator	Operator for processing events from upstream before flowing to `SchemaOperator`.
DorisBatchSink<IN>	Deprecated.
DorisBatchSink.Builder<IN>	build for DorisBatchSink.
DorisDataSink	A `DataSink` for "Doris" connector.
DorisDataSinkFactory	A dummy `DataSinkFactory` to create `DorisDataSink`.
DorisDataSinkOptions	DorisDataSink Options reference `DorisConfigOptions`.
DorisEventSerializer	A serializer for Event to DorisRecord.
DorisMetadataApplier	Supports `DorisDataSink` to schema evolution.
DorisRowConverter	converter `RecordData` type object to doris field.
DorisSchemaChangeManager	An enriched version of Doris' `SchemaChangeManager`.
DorisSchemaUtils	Utilities for doris schema.
DoubleSerializer	Type serializer for `Double`.
DoubleSerializer.DoubleSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
DoubleType	Data type of an 8-byte double precision floating point number.
DropColumnEvent	A `SchemaChangeEvent` that represents an `DROP COLUMN` DDL, which may contain the lenient column type changes.
DropColumnEventSerializer	A `TypeSerializer` for `DropColumnEvent`.
DropColumnEventSerializer.DropColumnEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
DropTableEvent	A `SchemaChangeEvent` that represents an `DROP TABLE` DDL.
DropTableEventSerializer	A `TypeSerializer` for `DropTableEvent`.
DropTableEventSerializer.DropTableEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyDocs	This is used to generate a dummy docs jar for this module to pass OSS repository rule.
DummyModelClient	Deterministic AI model client used by tests.
DummyModelClientFactory	Factory for the test-only `DummyModelClient`.
Elasticsearch6RequestCreator	A utility class that creates Elasticsearch 6.x specific requests.
Elasticsearch8AsyncSink<InputT>	Elasticsearch8AsyncSink is Apache Flink's Async Sink that submits Operations into an Elasticsearch cluster.
Elasticsearch8AsyncSinkBuilder<InputT>	Elasticsearch8AsyncSinkBuilder The builder to construct the Elasticsearch8Sink `Elasticsearch8AsyncSink`.
Elasticsearch8AsyncSinkBuilder.OperationConverter<T>	A wrapper that evolves the Operation, since a BulkOperationVariant is not Serializable.
Elasticsearch8AsyncSinkSerializer	`Elasticsearch8AsyncSinkSerializer` is used to serialize and deserialize `Operation` objects for Elasticsearch 8 async sink.
Elasticsearch8AsyncWriter<InputT>	Elasticsearch8AsyncWriter Apache Flink's Async Sink Writer that submits Operations into an Elasticsearch cluster.
ElasticsearchDataSink<InputT>	An implementation of `DataSink` for writing events to Elasticsearch.
ElasticsearchDataSinkFactory	Factory for creating `ElasticsearchDataSink`.
ElasticsearchDataSinkOptions	Options for the Elasticsearch data sink.
ElasticsearchEventSerializer	A serializer for Event to BulkOperationVariant.
ElasticsearchRowConverter	Converter class for serializing row data to Elasticsearch compatible formats.
ElasticsearchRowConverter.SerializationConverter	Interface for serialization converters.
ElasticsearchSinkOptions	Elasticsearch DataSink Options reference `ElasticsearchSinkOptions`.
EmbeddedEngineChangeEvent<K,V>	Copied from Debezium project.
EmbeddedFlinkDatabaseHistory	A `DatabaseHistory` implementation which store the latest table schema in Flink state.
EmbeddedFlinkDatabaseHistory	A `DatabaseHistory` implementation which store the latest table schema in Flink state.
EncodingUtils	General utilities for string-encoding.
EnhancedWriteMetadataEvent	An `OperatorEvent` that enhances a standard Hudi `WriteMetadataEvent` with additional context required for multi-table sinking.
EnumSerializer<T extends Enum<T>>	`TypeSerializer` for Java enums.
EnumSerializer.EnumSerializerSnapshot<T extends Enum<T>>	`TypeSerializerSnapshot` for `EnumSerializer`.
EnvironmentUtils	Utilities for environment information at runtime.
EnvironmentUtils	Utilities for environment information at runtime.
ErrorHandlingStrategy	Strategy for handling model request failures.
ErrorMessageUtils	This util tries to optimize error message for some exceptions.
Event	Class `Event` is the super interface defines the events of external systems flowing into Flink CDC.
EventDeserializer<T>	Deserializer to deserialize given record to `Event`.
EventDispatcherImpl<T extends io.debezium.schema.DataCollectionId>	A subclass implementation of `EventDispatcher`.
EventPartitioner	Partitioner that send `PartitioningEvent` to its target partition.
EventProcessorFactory	Factory to produce a LogMinerEventProcessor with enhanced processRow method to distinguish whether is bounded.
EventProcessorFactory.CDCEmbeddedInfinispanLogMinerEventProcessor	A `EmbeddedInfinispanLogMinerEventProcessor` with enhanced processRow method to distinguish whether is bounded.
EventProcessorFactory.CDCMemoryLogMinerEventProcessor	A `MemoryLogMinerEventProcessor` with enhanced processRow method to distinguish whether is bounded.
EventProcessorFactory.CDCRemoteInfinispanLogMinerEventProcessor	A `EventProcessorFactory.CDCRemoteInfinispanLogMinerEventProcessor` with enhanced processRow method to distinguish whether is bounded.
EventProcessorFunction	Template interface for processing CDC events in a standardized way.
EventRecordSerializationSchema	Serializer for the input `Event`.
EventSerializer	A `TypeSerializer` for `Event`.
EventSerializer.EventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
EventSinkProvider	A marker interface used to provide an event sink for writing change events to external systems.
EventSourceProvider	A marker interface used to provide an event source for reading events from external systems.
EventTypeInfo	A `TypeInformation` for `Event`.
ExistingTableSchemaExpander	Handles the initial `CreateTableEvent` for an existing target table according to the configured `ExistingTableSchemaExpansionMode`.
ExistingTableSchemaExpansionMode	Strategy for handling an existing target table when the initial `CreateTableEvent` arrives.
ExistingTableSchemaExpansionSupport	Connector-specific capabilities required to safely expand an existing target table schema.
Experimental	Experimental API.
ExtendedBucketStreamWriteFunction	Extended version of `BucketStreamWriteFunction` that exposes a public setter for the checkpoint ID.
ExternalResourceProxy<T extends org.junit.rules.ExternalResource>	A wrapper class for migrating JUnit 4 `@Rule` to JUnit 5.
Factory	Base interface for all kind of factories that create object instances from a list of key-value pairs in Flink CDC DataSource & DataSink API.
Factory.Context	Provides session information describing the factory to be accessed.
FactoryDiscoveryUtils	Discovery utilities for `Factory`.
FactoryHelper	A helper for working with `Factory`.
FactoryHelper.DefaultContext	Default implementation of `Factory.Context`.
FallbackKey	A key with FallbackKeys will fall back to the FallbackKeys if it itself is not configured.
Fetcher<T,Split>	Fetcher to fetch data of a table split, the split is either snapshot split `SnapshotSplit` or stream split `StreamSplit`.
FetchTask<Split>	The task to fetching data of a Split.
FetchTask.Context	Base context used in the execution of fetch task.
FinishedKvSnapshotConsumeEvent	Reports KV snapshots whose consumption is included in a reader checkpoint.
FinishedSnapshotSplitInfo	The information used to describe a finished snapshot split.
FinishedSnapshotSplitInfo	The information used to describe a finished snapshot split.
FinishedSnapshotSplitsAckEvent	The `SourceEvent` that `IncrementalSourceEnumerator` sends to `IncrementalSourceReader` to notify the finished snapshot splits has been received, i.e.
FinishedSnapshotSplitsAckEvent	The `SourceEvent` that `MySqlSourceEnumerator` sends to `MySqlSourceReader` to notify the finished snapshot splits has been received, i.e.
FinishedSnapshotSplitsReportEvent	The `SourceEvent` that `IncrementalSourceReader` sends to `IncrementalSourceEnumerator` to notify the snapshot split has read finished with the consistent change log position.
FinishedSnapshotSplitsReportEvent	The `SourceEvent` that `MySqlSourceReader` sends to `MySqlSourceEnumerator` to notify the snapshot split has read finished with the consistent binlog position.
FinishedSnapshotSplitsRequestEvent	The `SourceEvent` that `IncrementalSourceEnumerator` sends to `IncrementalSourceReader` to notify reader should report its finished snapshot splits, i.e.
FinishedSnapshotSplitsRequestEvent	The `SourceEvent` that `MySqlSourceEnumerator` sends to `MySqlSourceReader` to notify reader should report its finished snapshot splits, i.e.
FlinkCdcTypeSystem	A customized version of `RelDataTypeSystem`.
FlinkDatabaseHistory	Inspired from `MemoryDatabaseHistory` but we will store the HistoryRecords in Flink's state for persistence.
FlinkDatabaseSchemaHistory	The `FlinkDatabaseSchemaHistory` only stores the latest schema of the monitored tables.
FlinkEnvironmentUtils	Utilities for handling Flink configuration and environment.
FlinkEnvironmentUtils	Utilities for `StreamExecutionEnvironment`.
FlinkJsonTableChangeSerializer	The serializer responsible for converting of `TableChanges` into a JSON format.
FlinkOdpsException	Exception thrown by Flink MaxCompute Connector.
FlinkOffsetBackingStore	A implementation of `OffsetBackingStore` backed on Flink's state mechanism.
FlinkPipelineComposer	Composer for translating data pipeline to a Flink DataStream job.
FlinkPipelineExecution	A pipeline execution that run the defined pipeline via Flink's `StreamExecutionEnvironment`.
FlinkSinkFunctionProvider	`FlinkSinkFunctionProvider` is used to provide a Flink `SinkFunction` for writing events to external systems.
FlinkSinkProvider	`FlinkSinkProvider` is used to provide a Flink `Sink` for writing events to external systems.
FlinkSourceFunctionProvider	`FlinkSourceFunctionProvider` is used to provide a Flink `SourceFunction` for reading events from external systems.
FlinkSourceProvider	`FlinkSourceProvider` is used to provide a Flink `Source` for reading events from external systems.
FloatSerializer	Type serializer for `Float`.
FloatSerializer.FloatSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
FloatType	Data type of a 4-byte single precision floating point number.
FlushEvent	An `Event` from `SchemaOperator` to notify `DataSinkWriterOperator` that it start flushing.
FlushEventAlignmentOperator	Align `FlushEvent`s broadcasted by `BucketAssignOperator`.
FlushEventAlignmentOperator	Align `FlushEvent`s broadcasted by `BucketAssignOperator`.
FlushSuccessEvent	A `OperatorEvent` from sink writer to notify `SchemaRegistry` that it finished flushing.
FlussConfigUtils	Utils for parsing fluss yaml sink options.
FlussConversions	Converter between Flink CDC types and Fluss types.
FlussDataSink	A DataSink implementation for Fluss.
FlussDataSinkFactory	Factory for creating configured instances of `FlussDataSink`.
FlussDataSinkOptions	Options for `FlussDataSink`.
FlussDataSinkOptions.SinkPartitioningStrategy	The shuffle strategy for fluss sink.
FlussDataSource	A CDC-specific `DataSource` implementation for Fluss.
FlussDataSourceFactory	Factory for creating configured instances of `FlussDataSource`.
FlussDataSourceOptions	Options for Fluss DataSource.
FlussDefaultDiscoverer	The default `TableDiscoverer` for Fluss that subscribes to tables whose fully-qualified name (formatted as `"database.tableName"`) matches a user-provided Java regular expression.
FlussDefaultDiscovererFactory	`TableDiscovererFactory` for `FlussDefaultDiscoverer`.
FlussDeserializer<T>	A generic deserializer interface for converting Fluss `ScanRecord`s into output records of type `T`.
FlussEvent	FlussEvent is a wrapper for a list of genericRows.
FlussEventSerializationSchema	Serialization schema that converts a CDC data record to a Fluss event.
FlussEventSerializer<InputT>	Serializer to serialize the input record to a `FlussEvent` for `FlussSinkWriter`.
FlussHashFunctionProvider	`HashFunctionProvider` implementation for `FlussDataSink`.
FlussHybridSnapshotLogSplit	A split that first reads a full KV snapshot from a Fluss table bucket, then switches to reading change log from the snapshot's log offset.
FlussHybridSnapshotLogSplitState	The state of `FlussHybridSnapshotLogSplit`.
FlussLogSplit	A split that reads change log records from a Fluss table bucket starting at a given offset.
FlussLogSplitState	The state of `FlussLogSplit`.
FlussMetadataAccessor	A `MetadataAccessor` implementation that uses the Fluss Admin API to list databases, tables, and retrieve table schemas from a Fluss cluster.
FlussMetaDataApplier	`MetadataApplier` for fluss.
FlussOperationType	Enumeration of row operation types used in Fluss-Flink data processing.
FlussRecordDeserializer	A CDC-specific implementation of `FlussDeserializer` that converts Fluss `ScanRecord`s into Flink CDC `Event`s (DataChangeEvents).
FlussRecordEmitter<T>	A `RecordEmitter` that uses a `FlussDeserializer` to convert `FlussSourceRecord`s into the output type `T`.
FlussRowWithOp	A wrapper class that associates an `InternalRow` with an `FlussOperationType` for use in Fluss-Flink data processing.
FlussSink<InputT>	Flink sink for Fluss.
FlussSinkWriter<InputT>	Base class for Flink `SinkWriter` implementations in Fluss.
FlussSnapshotSplit	A split that reads a bounded KV snapshot from a Fluss table bucket.
FlussSource<T>	A generic Flink `Source` implementation for reading records from Fluss tables.
FlussSourceEnumerator	The enumerator for Fluss source.
FlussSourceEnumState	The state of the `FlussSourceEnumerator`, used for checkpointing.
FlussSourceEnumStateSerializer	Serializer for `FlussSourceEnumState`.
FlussSourceReader<T>	A generic `SourceReader` for Fluss, built on top of Flink's `SingleThreadMultiplexSourceReaderBase`.
FlussSourceReaderMetrics	A collection class for handling metrics in the Fluss CDC source reader.
FlussSourceRecord	A wrapper that bundles a Fluss `ScanRecord` together with the table context (table path and row type) needed for deserialization.
FlussSplitBase	Abstract base class for all Fluss source splits.
FlussSplitReader	A `SplitReader` implementation for Fluss.
FlussSplitSerializer	Serializer for `FlussSplitBase` and its subclasses.
FlussSplitState	Abstract base class for the mutable state of a `FlussSplitBase`.
FormatFunctionClass	This is an example UDF class for testing purposes only.
FormatFunctionClass	This is an example UDF class for testing purposes only.
Formatter	Allows providing multiple formatters for the description.
ForwardHashFunctionProvider	A `HashFunctionProvider` that preserves the upstream subtask distribution.
GenericArrayData	An internal data structure representing data of `ArrayType`.
GenericMapData	An internal data structure representing data of `MapType`.
GenericRecordData	An internal data structure representing data of `RecordData`.
GenericRecordDataSerializer	Serializer for `GenericRecordData`.
GeometryConverter	This class converts Oracle STRUCT objects to JTS geometries.
GetEvolvedSchemaRequest	Request to `SchemaRegistry` for getting schema of a table.
GetEvolvedSchemaResponse	Coordination response from `SchemaRegistry` for `GetEvolvedSchemaRequest`.
GetOriginalSchemaRequest	Request to `SchemaRegistry` for getting original schema of a table.
GetOriginalSchemaResponse	Coordination response from `SchemaRegistry` for `GetOriginalSchemaRequest`.
GtidUtils	Utils for handling GTIDs.
HadoopConfUtils	Utilities for building Hadoop `Configuration` from connector options.
Handover	The Handover is a utility to hand over data (a buffer of records) and exception from a producer thread to a consumer thread.
Handover.ClosedException	An exception thrown by the Handover in the `Handover.pollNext()` or `Handover.produce(List)` method, after the Handover was closed via `Handover.close()`.
HashFunction<T>	The hash function used to calculate the hash code from a given event.
HashFunction.HashContext	Runtime context for calculating an event hash code.
HashFunctionProvider<T>	Provider that provides `HashFunction` to help `PrePartitionOperator` to shuffle event to designated subtask.
HashFunctionStrategy	Partitioning strategy for `DataChangeEvent` in Flink CDC pipeline.
HistorizedRelationalDatabaseConnectorConfig	Copied from Debezium project.
HtmlFormatter	Formatter that transforms `Description` into Html representation.
HudiConfig	A utility class that holds all the configuration options for the Hudi sink.
HudiDataSink	A `DataSink` for Apache Hudi that provides the main entry point for the Flink CDC framework.
HudiDataSinkFactory	Factory for creating `HudiDataSink`.
HudiDataSinkOptions	HudiDataSink Options reference `HudiConfig`.
HudiMetadataApplier	A `MetadataApplier` that applies schema changes to Hudi tables.
HudiRecordEventSerializer	A `HudiRecordSerializer` for converting `Event` into `HoodieFlinkInternalRow` for Hudi writing.
HudiRecordSerializer<T>	A serializer interface for converting input records into `HoodieFlinkInternalRow` for Hudi writing.
HudiSink	A `Sink` implementation for Apache Hudi.
HybridPendingSplitsState	A `PendingSplitsState` for pending hybrid (snapshot & stream) splits.
HybridPendingSplitsState	A `PendingSplitsState` for pending hybrid (snapshot & binlog) splits.
HybridSplitAssigner<C extends SourceConfig>	Assigner for Hybrid split which contains snapshot splits and stream splits.
IcebergCommitter	A `Committer` for Apache Iceberg.
IcebergDataSink	A `DataSink` for Apache Iceberg.
IcebergDataSinkFactory	A `DataSinkFactory` for Apache Iceberg.
IcebergDataSinkOptions	Config options for `IcebergDataSink`.
IcebergMetadataApplier	A `MetadataApplier` for Apache Iceberg.
IcebergSink	A `Sink` implementation for Apache Iceberg.
IcebergTypeUtils	Util class for types in `IcebergDataSink`.
IcebergWriter	A `SinkWriter` for Apache Iceberg.
IcebergWriterState	The state of the `IcebergWriter`.
IcebergWriterStateSerializer	A `IcebergWriterStateSerializer` for `IcebergWriterState`.
IncrementalSource<T,C extends SourceConfig>	The basic source of Incremental Snapshot framework for datasource, it is based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change by streaming reading.
IncrementalSourceEnumerator	Incremental source enumerator that enumerates receive the split request and assign the split to source readers.
IncrementalSourceReader<T,C extends SourceConfig>	The multi-parallel source reader for table snapshot phase from `SnapshotSplit` and then single-parallel source reader for table stream phase from `StreamSplit`.
IncrementalSourceReaderContext	A wrapper class that wraps `SourceReaderContext` for sharing message between `IncrementalSourceReader` and `IncrementalSourceSplitReader`.
IncrementalSourceReaderWithCommit	Record the LSN of checkpoint `StreamSplit`, which can be used to submit to the CDC source.
IncrementalSourceRecordEmitter<T>	The `RecordEmitter` implementation for `IncrementalSourceReader`.
IncrementalSourceRecordEmitter.OutputCollector<T>	An adapter between `SourceOutput` and `Collector`.
IncrementalSourceScanFetcher	Fetcher to fetch data from table split, the split is the snapshot split `SnapshotSplit`.
IncrementalSourceSplitReader<C extends SourceConfig>	Basic class read `SourceSplitBase` and return `SourceRecord`.
IncrementalSourceStreamFetcher	Fetcher to fetch data from table split, the split is the stream split `StreamSplit`.
InlineElement	Part of description that represents an element inside a block e.g.
InstantiationUtil	Utility class to create instances from class objects.
InstantiationUtil.ClassLoaderObjectInputStream	A custom ObjectInputStream that can load classes using a specific ClassLoader.
Internal	Annotation to mark class and methods as an internal developer API that should not be used by users.
InternalClassConverter	Converts a `DataType` to its CDC Internal representation.
InternalObjectConverter	Common converters from Java objects to CDC Internal objects.
InternalSerializers	`TypeSerializer` of `DataType` for internal data structures.
IntSerializer	Type serializer for `Integer` (and `int`, via auto-boxing).
IntSerializer.IntSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
IntType	Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
JaninoCompiler	Use Janino compiler to compiler the statement of flink cdc pipeline transform into the executable code of Janino.
JaninoCompiler.Context	Contextual information for `JaninoCompiler`.
JavaClassConverter	Converts a `DataType` to its Java representation that could be used in UDF manipulation.
JavaObjectConverter	Common converters from CDC Internal type to Java type.
JdbcChunkUtils	Utilities to split chunks of table.
JdbcConnectionFactory	A factory to create JDBC connection.
JdbcConnectionFactory	A factory to create JDBC connection for MySQL.
JdbcConnectionPoolFactory	A connection pool factory to create pooled DataSource `HikariDataSource`.
JdbcConnectionPools	A Jdbc Connection pools implementation.
JdbcConnectionPools	A Jdbc Connection pools implementation.
JdbcDataSourceDialect	The dialect of JDBC data source.
JdbcIncrementalSource<T>	The basic source of Incremental Snapshot framework for JDBC datasource, it is based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change by streaming reading.
JdbcSourceChunkSplitter	The `ChunkSplitter` used to split table into a set of chunks for JDBC data source.
JdbcSourceConfig	A Source configuration which is used by `IncrementalSource` which used JDBC data source.
JdbcSourceConfigFactory	A `SourceConfig.Factory` to provide `SourceConfig` of JDBC data source.
JdbcSourceEventDispatcher<P extends io.debezium.pipeline.spi.Partition>	A subclass implementation of `EventDispatcher`.
JdbcSourceFetchTaskContext	The context for fetch task that fetching data of snapshot split from JDBC data source.
JdbcSourceOptions	Configurations for `IncrementalSource` of JDBC data source.
JdbcTableDiscoverer	A `TableDiscoverer` that reads the list of subscribed tables from a JDBC database.
JdbcTableDiscovererFactory	`TableDiscovererFactory` for `JdbcTableDiscoverer` with factory type `jdbc`.
JdbcUrlUtils	Option utils for JDBC URL properties.
JsonDebeziumDeserializationSchema	A JSON format implementation of `DebeziumDeserializationSchema` which deserializes the received `SourceRecord` to JSON String.
JsonSerializationSchema	A `SerializationSchema` to convert `Event` into byte of json format.
JsonSerializationType	type of `SerializationSchema` to serialize `Event` for kafka.
JsonStringFormatter	Copied from mysql-binlog-connector-java 0.27.2 to add whitespace before value and after comma.
K8SApplicationDeploymentExecutor	deploy flink cdc job by native k8s application mode.
KafkaDataSink	A `DataSink` for "Kafka" connector.
KafkaDataSinkFactory	A dummy `DataSinkFactory` to create `KafkaDataSink`.
KafkaDataSinkOptions	Options for `KafkaDataSinkOptions`.
KafkaMetaDataApplier	Supports `KafkaDataSink` to schema evolution.
KafkaSinkUtils	Util class for `KafkaDataSink`.
KeyFormat	Enum class for building `SerializationSchema` for `ProducerRecord`.
KeySerializationFactory	Format factory for providing configured instances of `SerializationSchema` to convert `Event` to byte.
LatestFinishedSplitsNumberEvent	The `SourceEvent` that `IncrementalSourceEnumerator` sends to `IncrementalSourceReader` to pass the latest finished snapshot splits number.
LatestFinishedSplitsNumberEvent	The `SourceEvent` that `MySqlSourceEnumerator` sends to `MySqlSourceReader` to pass the latest finished snapshot splits number.
LatestFinishedSplitsNumberRequestEvent	The `SourceEvent` that `IncrementalSourceReader` sends to `IncrementalSourceEnumerator` to ask the latest finished snapshot splits number.
LatestFinishedSplitsNumberRequestEvent	The `SourceEvent` that `MySqlSourceReader` sends to `MySqlSourceEnumerator` to ask the latest finished snapshot splits number.
LazyBinaryFormat<T>	An abstract implementation fo `BinaryFormat` which is lazily serialized into binary or lazily deserialized into Java object.
LeaseContext	Context for a Fluss KV snapshot lease.
LifecycleFunctionClass	This is an example UDF class for testing purposes only.
LineBreakElement	Represents a line break in the `Description`.
LinkedListSerializer<T>	A serializer for `LinkedList`.
LinkedListSerializer.LinkedListSerializerSnapshot<T>	Snapshot class for the `LinkedListSerializer`.
LinkElement	Element that represents a link in the `Description`.
ListElement	Represents a list in the `Description`.
ListSerializer<T>	A serializer for `Lists`.
ListSerializer.ListSerializerSnapshot<T>	Snapshot class for the `ListSerializer`.
ListUtils	A utility class for `List`.
LocalZonedTimestampData	An internal data structure representing data of `LocalZonedTimestampType`.
LocalZonedTimestampDataSerializer	Serializer for `LocalZonedTimestampData`.
LocalZonedTimestampDataSerializer.LocalZonedTimestampDataSerializerSnapshot	`TypeSerializerSnapshot` for `TimestampDataSerializer`.
LocalZonedTimestampType	Data type of a timestamp WITH LOCAL time zone consisting of `year-month-day hour:minute:second[.fractional] zone` with up to nanosecond precision and values ranging from `0000-01-01 00:00:00.000000000 +14:59` to `9999-12-31 23:59:59.999999999 -14:59`.
LocalZonedTimestampTypeReturningClass	This is an example UDF class for testing purposes only.
LogicalFunctions	Logical built-in functions.
LogMinerAdapter	Copied from Debezium 1.9.8.Final.
LogMinerChangeRecordEmitter	Copied from Debezium 1.9.8.Final.
LogMinerStreamingChangeEventSource	Copied from Debezium 1.9.8.Final.
LongSerializer	Type serializer for `Long`.
LongSerializer.LongSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
Lsn	Copied from Debezium 1.9.8.final without changes due to the NoSuchMethodError, caused by the fact that current Debezium release java version is 11, so we need to compile this file by java 8 compiler.
LsnFactory	A factory to create `LsnOffset`.
LsnFactory	A factory to create `LsnOffset`.
LsnOffset	A structure describes an offset in a Lsn event.
LsnOffset	A structure describes an offset in a Lsn event.
MapData	Base interface of an internal data structure representing data of `MapType`.
MapDataSerializer	Serializer for `MapData`.
MapDataSerializer.MapDataSerializerSnapshot	`TypeSerializerSnapshot` for `MapDataSerializer`.
MapDataUtil	Utilities for `MapData`.
MapSerializer<K,V>	A serializer for `Map`.
MapSerializer.MapSerializerSnapshot<K,V>	Snapshot class for the `MapSerializer`.
MapType	Data type of an associative array that maps keys (including `NULL`) to values (including `NULL`).
MaxComputeDataSink	A `DataSink` for "MaxCompute" connector.
MaxComputeDataSinkFactory	A `DataSinkFactory` for "MaxCompute" connector.
MaxComputeDataSinkOptions	Options for MaxCompute Data Sink.
MaxComputeEventSink	A `Sink` of `Event` to MaxCompute.
MaxComputeEventWriter	a `SinkWriter` for `Event` for MaxCompute.
MaxComputeHashFunctionProvider	Hash function for maxcompute to distribute data change event to different maxcompute sink by primary key.
MaxComputeMetadataApplier	A `MetadataApplier` for "MaxCompute" connector.
MaxComputeOptions	basic options for MaxCompute.
MaxComputeOptions.Builder	builder for maxcompute options.
MaxComputeUtils	common utils use for maxcompute connector.
MaxComputeWriteOptions	extended options for maxcompute.
MaxComputeWriteOptions.Builder	builder for maxcompute write options.
MaxComputeWriter	the interface of all writer to write `ArrayRecord` to maxcompute.
MetadataAccessor	`MetadataAccessor` is used by `DataSource` to access the metadata from external systems.
MetadataApplier	`MetadataApplier` is used to apply metadata changes to external systems.
MetadataColumn	Representation of a metadata column.
MetadataColumns	Contains all supported metadata columns that could be used in transform expressions.
MetadataColumnSerializer	A `TypeSerializer` for `MetadataColumn`.
MetadataColumnSerializer.MetadataColumnSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
MetadataConverter	A converter converts `SourceRecord` metadata into Flink internal data structures.
ModelContext	Context passed to `AiModelClientFactory.createClient(org.apache.flink.cdc.common.model.ModelContext)` at pipeline assembly time.
ModelDef	Definition of an AI model declared in a pipeline.
ModelOptions	Options of built-in model.
MongoClientPool	A MongoDB Client pools.
MongoDBChunkSplitter	The splitter used to split collection into a set of chunks for MongoDB data source.
MongoDBConnectorDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data structure `RowData`.
MongoDBConnectorFullChangelogDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data that produces full changelog mode structure `RowData`.
MongoDBConnectorSourceConnector	SourceConnector uses `MongoDBConnectorSourceTask`.
MongoDBConnectorSourceTask	Source Task that proxies mongodb kafka connector's `MongoSourceTask` to adapt to `DebeziumChangeFetcher`.
MongoDBDialect	The `DataSourceDialect` implementation for MongoDB datasource.
MongoDBEnvelope	An immutable descriptor for the structure of `ChangeStreamDocument` envelopes.
MongoDBFetchTaskContext	The context for fetch task that fetching data of snapshot split from MongoDB data source.
MongoDBReadableMetadata	Defines the supported metadata columns for `MongoDBTableSource`.
MongoDBRecordEmitter<T>	The `RecordEmitter` implementation for `IncrementalSourceReader`.
MongoDBScanFetchTask	The task to work for fetching data of MongoDB collection snapshot split .
MongoDBSource	Deprecated.
MongoDBSource<T>	The MongoDB CDC Source based on FLIP-27 which supports parallel reading snapshot of collection and then continue to capture data change from change stream.
MongoDBSource.Builder<T>	Builder class of `MongoDBSource`.
MongoDBSourceBuilder<T>	The builder class for `MongoDBSource` to make it easier for the users to construct a `MongoDBSource`.
MongoDBSourceConfig	A MongoDB Source configuration which is used by `MongoDBSource`.
MongoDBSourceConfigFactory	A factory to construct `MongoDBSourceConfig`.
MongoDBSourceOptions	Configurations for `MongoDBSource`.
MongoDBSslUtils	Utilities for building SSL context from MongoDB connector configuration.
MongoDBStreamFetchTask	The task to work for fetching data of MongoDB stream split .
MongoDBTableSource	A `DynamicTableSource` that describes how to create a MongoDB change stream events source from a logical description.
MongoDBTableSourceFactory	Factory for creating configured instance of `MongoDBTableSource`.
MongoRecordUtils	Utility class to deal record.
MongoUtils	Utilities of MongoDB operations.
MultiTableCommittableChannelComputer	`ChannelComputer` for `MultiTableCommittable`.
MultiTableEventStreamWriteFunction	Multi-table wrapper function that routes events to table-specific EventExtendedBucketStreamWriteFunction instances.
MultiTableStreamWriteOperatorCoordinator	A custom OperatorCoordinator that manages Hudi writes for multiple tables.
MultiTableStreamWriteOperatorCoordinator.Provider	Provider for `MultiTableStreamWriteOperatorCoordinator`.
MultiTableWriteOperator	Multi-table write operator for Apache Hudi that handles CDC events from multiple tables.
MultiTableWriteOperatorFactory<I>	Custom WriteOperatorFactory that creates our extended multi-table StreamWriteOperatorCoordinator instead of Hudi's original single-table coordinator.
MySqlBinlogSplit	The split to describe the binlog of MySql table(s).
MySqlBinlogSplitAssigner	A `MySqlSplitAssigner` which only read binlog from current binlog position.
MySqlBinlogSplitReadTask	Task to read all binlog for table and also supports read bounded (from lowWatermark to highWatermark) binlog.
MySqlBinlogSplitState	The state of split to describe the binlog of MySql table(s).
MySqlChunkSplitter	The `ChunkSplitter` implementation for MySQL.
MySqlConnection	Copied from Debezium project(1.9.8.final) to add custom jdbc properties in the jdbc url.
MySqlConnection.MySqlConnectionConfiguration	Connection configuration to create a `MySqlConnection`.
MySqlDataSource	A `DataSource` for mysql cdc connector.
MySqlDataSourceFactory	A `Factory` to create `MySqlDataSource`.
MySqlDataSourceOptions	Configurations for `MySqlDataSource`.
MysqlDebeziumTimeConverter	Debezium converts the datetime type in MySQL into a UTC timestamp by default (`Timestamp` ), The time zone is hard-coded and cannot be changed.
MySqlDefaultValueConverter	Copied from Debezium project(1.9.8.final) to add BIGINT and SMALLINT to TRIM_DATA_TYPES.
MySqlDeserializationConverterFactory	Used to create `DeserializationRuntimeConverterFactory` specified to MySQL.
MySqlErrorHandler	A subclass implementation of `ErrorHandler` which filter some `DebeziumException`, we use this class instead of `MySqlErrorHandler`.
MySqlEventDeserializer	Event deserializer for `MySqlDataSource`.
MySqlFieldDefinition	used to generate field definition in ddl with "desc table".
MySqlHybridSplitAssigner	A `MySqlSplitAssigner` that splits tables into small chunk splits based on primary key range and chunk size and also continue with a binlog split.
MySqlMetadataAccessor	`MetadataAccessor` for `MySqlDataSource`.
MySqlPipelineRecordEmitter	The `RecordEmitter` implementation for pipeline mysql connector.
MySqlReadableMetadata	Defines the supported metadata columns for `MySqlTableSource`.
MySqlRecordEmitter<T>	The `RecordEmitter` implementation for `MySqlSourceReader`.
MySqlRecords	An implementation of `RecordsWithSplitIds` which contains the records of one table split.
MySqlSchema	A component used to get schema by table path.
MySqlSchemaDataTypeInference	`DataType` inference for MySQL debezium `Schema`.
MySqlSchemalessSnapshotSplit	A kind of `MySqlSnapshotSplit` without table schema information, it is useful to reduce memory usage in JobManager.
MySqlSchemaUtils	Utilities for converting from debezium `Table` types to `Schema`.
MySqlSnapshotChangeEventSource	Copied from Debezium project(1.9.8.Final) to fix MySQL 8.x compatibility.
MySqlSnapshotSplit	The split to describe a split of a MySql table snapshot.
MySqlSnapshotSplitAssigner	A `MySqlSplitAssigner` that splits tables into small chunk splits based on primary key range and chunk size.
MySqlSnapshotSplitReadTask	Task to read snapshot split of table.
MySqlSnapshotSplitState	The state of split to describe the binlog of MySql table(s).
MySqlSource	Deprecated. please use `MySqlSource` instead which supports more rich features, e.g.
MySqlSource<T>	The MySQL CDC Source based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change from binlog.
MySqlSource.Builder<T>	Deprecated. please use `MySqlSource.builder()` instead which supports more rich features, e.g.
MySqlSourceBuilder<T>	The builder class for `MySqlSource` to make it easier for the users to construct a `MySqlSource`.
MySqlSourceConfig	A MySql Source configuration which is used by `MySqlSource`.
MySqlSourceConfigFactory	A factory to construct `MySqlSourceConfig`.
MySqlSourceEnumerator	A MySQL CDC source enumerator that enumerates receive the split request and assign the split to source readers.
MySqlSourceOptions	Configurations for `MySqlSource`.
MySqlSourceReader<T>	The source reader for MySQL source splits.
MySqlSourceReaderContext	A wrapper class that wraps `SourceReaderContext` for sharing message between `MySqlSourceReader` and `MySqlSplitReader`.
MySqlSourceReaderMetrics	A collection class for handling metrics in `MySqlSourceReader`.
MySqlSplit	The split of table comes from a Table that splits by primary key.
MySqlSplitAssigner	The `MySqlSplitAssigner` is responsible for deciding what split should be processed.
MySqlSplitReader	The `SplitReader` implementation for the `MySqlSource`.
MySqlSplitSerializer	A serializer for the `MySqlSplit`.
MySqlSplitState	State of the reader, essentially a mutable version of the `MySqlSplit`.
MySqlStreamingChangeEventSource	Copied from Debezium project(1.9.8.Final) to fix https://github.com/ververica/flink-cdc-connectors/issues/1944.
MySqlStreamingChangeEventSource.BinlogPosition	Describe binlog position.
MySqlTableDefinition	used to generate table definition in ddl with "desc table".
MySqlTableSource	A `DynamicTableSource` that describes how to create a MySQL binlog source from a logical description.
MySqlTableSourceFactory	Factory for creating configured instance of `MySqlTableSource`.
MySqlTaskContextImpl	A subclass implementation of `MySqlTaskContext` which reuses one BinaryLogClient.
MySqlTypeUtils	Utilities for converting from MySQL types to Flink types.
MySqlTypeUtils	Utilities for converting from MySQL types to `DataType`s.
MySqlValidator	The validator for MySql: it only cares about the version of the database is larger than or equal to 5.7.
MySqlValueConverters	Copied from Debezium project(1.9.8.Final) to fix FLOAT converted to FLOAT64 type issue.
MySqlValueConverters.ParsingErrorHandler
NestedSerializersSnapshotDelegate	A NestedSerializersSnapshotDelegate represents the snapshots of multiple serializers that are used by an outer serializer.
NetworkConfig	A factory that creates valid ElasticsearchClient instances.
NullableSerializerWrapper<T>	Type serializer for nullable object.
NullableSerializerWrapper.NullableSerializerWrapperSnapshot<T>	Serializer configuration snapshot for compatibility and format evolution.
NullAwareGetters	Provides null related getters.
ObjectIdDiscoverer<T>	Pluggable abstraction for discovering a set of object identifiers.
ObjectIdDiscoverer.Context	Context providing runtime information for the discoverer.
ObjectIdDiscovererFactory<T>	SPI factory that creates an `ObjectIdDiscoverer`.
ObjectIdDiscovererFactory.DefaultObjectIdDiscovererContext	Default implementation of `ObjectIdDiscoverer.Context`.
ObjectUtils	Utilities for operation on `Object`.
ObjectUtils	Utilities for operation on `Object`.
OceanBaseCatalog	A `OceanBaseCatalog` for OceanBase connector that supports schema evolution.
OceanBaseCatalogException	A catalog-related, runtime exception.
OceanBaseCatalogFactory	A `OceanBaseCatalogFactory` to create `OceanBaseCatalog`.
OceanBaseColumn	Describe a column of OceanBase table.
OceanBaseColumn.Builder	Build a `OceanBaseColumn`.
OceanBaseDataSink	A `DataSink` for "OceanBase" pipeline connector.
OceanBaseDataSinkFactory	A `DataSinkFactory` to create `OceanBaseDataSink`.
OceanBaseDataSinkOptions	Options for `OceanBaseDataSink`.
OceanBaseEventSerializationSchema	A serializer for Event to Record.
OceanBaseMetadataApplier	Supports `OceanBaseDataSink` to schema evolution.
OceanBaseMySQLCatalog	A `OceanBaseCatalog` for OceanBase connector that supports schema evolution under MySQL mode.
OceanBaseMySqlTableSourceFactory	Factory class for creating table sources that capture data changes from OceanBase databases.
OceanBaseOracleCatalog	A `OceanBaseCatalog` for OceanBase connector that supports schema evolution under Oracle mode.
OceanBaseRowConvert	converter `RecordData` type object to oceanbase field.
OceanBaseSink<T>	Copy from OceanBaseSink to add `OceanBaseSink.createWriter(WriterInitContext)` method.
OceanBaseTable	Describe a OceanBase table.
OceanBaseTable.Builder	Build a `OceanBaseTable`.
OceanBaseTable.TableType	Types of OceanBase table.
OceanBaseUtils	Utilities for conversion from source table to OceanBase table.
OceanBaseUtils.CdcDataTypeTransformer	Transforms CDC `DataType` to OceanBase data type.
Offset	A structure describes a fine-grained offset in a change event including change log position.
OffsetCommitAckEvent	The `SourceEvent` that `PostgresSourceReader` broadcasts to `PostgresSourceEnumerator` to tell the enumerator that offset commit is already suspend.
OffsetCommitEvent	The `SourceEvent` that `PostgresSourceEnumerator` send to `PostgresSourceReader`, which includes current assign status.
OffsetDeserializerSerializer	read `Offset` from input stream and write `Offset` to output stream.
OffsetDeserializerSerializer.OffsetDeserializer	Deserializer for `Offset`.
OffsetDeserializerSerializer.OffsetSerializer	Serializer for `Offset`.
OffsetFactory	An offset factory class create `Offset` instance.
OnlineSchemaChangeUtils	Utility class for handling gh-ost/pt-osc online schema change events.
OpenAIChatModel	A `UserDefinedFunction` that use Model defined by OpenAI to generate text, refer to docs}.
OpenAiCompatibleModelClient	AI model client that connects to an OpenAI-compatible endpoint.
OpenAiCompatibleModelClientFactory	SPI factory for `OpenAiCompatibleModelClient`.
OpenAiCompatibleModelOptions	Config options accepted by the `openai-compatible` pipeline model.
OpenAiCompatibleModelOptions.ContentType	Content type of the user input.
OpenAiCompatibleModelOptions.ResponseFormat	Format of a text completion response.
OpenAIEmbeddingModel	A `UserDefinedFunction` that use Model defined by OpenAI to generate vector data, refer to docs}.
Operation	A single stream element which contains a `BulkOperationVariant`.
OperationSerializer	OperationSerializer is responsible for the serialization and deserialization of an `Operation`.
OperationType	Enum `OperationType` describes the type of operation that the data change event reports.
OperatorIDGenerator	Generating `OperatorID` for communication between Flink operators.
OperatorIDGenerator	Generator for creating deterministic OperatorIDs from UIDs.
OperatorIDGenerator	Generating `OperatorID` for communication between Flink operators.
OperatorUidGenerator	A generator for pipeline operator UIDs.
OptionUtils	A utility class to print configuration of connectors.
OptionUtils	A utility class to print configuration of connectors.
OptionUtils	A utility class to print configuration of connectors.
OptionUtils	A utility class to print configuration of connectors.
OptionUtils	A utility class to print configuration of connectors.
OptionUtils	A utility class to print configuration of connectors.
OptionUtils	A utility class to print configuration of connectors.
OpTsMetadataColumn	A `SupportedMetadataColumn` for op_ts.
OpTsMetadataColumn	A `SupportedMetadataColumn` for op_ts.
OpTsMetadataColumn	A `SupportedMetadataColumn` for op_ts.
OracleAlterTableParserListener	Parser listener that is parsing Oracle ALTER TABLE statements.
OracleAntlrDdlParser	A ddl parser that will use custom listener.
OracleAntlrDdlParserListener	This class is Oracle main DDL parser listener class.
OracleChunkSplitter	The `ChunkSplitter` used to split Oracle table into a set of chunks for JDBC data source.
OracleConnectionUtils	Oracle connection Utilities.
OracleDataSource	A `DynamicTableSource` that describes how to create a Oracle redo log from a logical description.
OracleDataSourceFactory	A `Factory` to create `OracleDataSource`.
OracleDataSourceOptions	Configurations for `OracleDataSource`.
OracleDeserializationConverterFactory	Used to create `DeserializationRuntimeConverterFactory` specified to Oracle.
OracleDialect	The `JdbcDataSourceDialect` implementation for Oracle datasource.
OracleEventDeserializer	Event deserializer for `OracleDataSource`.
OracleGeometry	OracleGeometry represents a geometry object in Oracle Spatial.
OracleJdbcUrlUtils	The utils to build the JDBC connection url for Oracle data source.
OracleMetadataAccessor	`MetadataAccessor` for `OracleDataSource`.
OraclePipelineRecordEmitter	The `RecordEmitter` implementation for Oracle pipeline connector.
OraclePooledDataSourceFactory	A Oracle datasource factory.
OracleReadableMetaData	Defines the supported metadata columns for `OracleTableSource`.
OracleScanFetchTask	The task to work for fetching data of Oracle table snapshot split.
OracleScanFetchTask.OracleSnapshotSplitReadTask	A wrapped task to fetch snapshot split of table.
OracleSchema	A component used to get schema by table path.
OracleSchemaChangeEventHandler	This OracleSchemaChangeEventHandler helps to parse the source struct in SchemaChangeEvent and generate source info.
OracleSchemaDataTypeInference	`DataType` inference for oracle debezium `Schema`.
OracleSchemaUtils	Utilities for converting from debezium `Table` types to `Schema`.
OracleSource	A builder to build a SourceFunction which can read snapshot and continue to consume log miner.
OracleSource.Builder<T>	Builder class of `OracleSource`.
OracleSourceBuilder<T>	The builder class for `OracleSourceBuilder.OracleIncrementalSource` to make it easier for the users to construct a `OracleSourceBuilder.OracleIncrementalSource`.
OracleSourceBuilder.OracleIncrementalSource<T>	The `JdbcIncrementalSource` implementation for Oracle.
OracleSourceConfig	Describes the connection information of the Oracle database and the configuration information for performing snapshotting and streaming reading, such as splitSize.
OracleSourceConfigFactory	A factory to initialize `OracleSourceConfig`.
OracleSourceConnection	Used to create `OracleConnection` specified to Oracle.
OracleSourceFetchTaskContext	The context for fetch task that fetching data of snapshot split from Oracle data source.
OracleSourceFetchTaskContext.OracleEventMetadataProvider	Copied from debezium for accessing here.
OracleSourceOptions	Configurations for `OracleSource`.
OracleSourceValueConverters	Oracle Value Converters for cdc.
OracleStreamFetchTask	The task to work for fetching data of Oracle table stream split.
OracleStreamFetchTask.RedoLogSplitReadTask	A wrapped task to read all redo log for table and also supports read bounded (from lowWatermark to highWatermark) redo log.
OracleTableSource	A `DynamicTableSource` that describes how to create a Oracle redo log from a logical description.
OracleTableSourceFactory	Factory for creating configured instance of `OracleTableSource`.
OracleTableSourceReader	The basic source of Incremental Snapshot framework for JDBC datasource, it is based on FLIP-27 and Watermark Signal Algorithm which supports parallel reading snapshot of table and then continue to capture data change by streaming reading.
OracleTypeUtils	Utilities for converting from oracle types to Flink types.
OracleTypeUtils	Utilities for converting from oracle types to `DataType`s.
OracleUtils	Utils to prepare Oracle SQL statement.
OracleValidator	Validates the version of the database connecting to.
PaimonCommitter	A `Committer` to commit write results for multiple tables.
PaimonDataSink	A `DataSink` for Paimon connector that supports schema evolution.
PaimonDataSinkFactory	A `DataSinkFactory` to create `PaimonDataSink`.
PaimonDataSinkOptions	copy from `CatalogOptions`.
PaimonEvent	Contains the data to be written for `PaimonWriter`.
PaimonEventSink	A `PaimonSink` to process `Event`.
PaimonHashFunction	A `HashFunction` implementation for `PaimonDataSink`.
PaimonHashFunctionProvider	A `HashFunctionProvider` implementation for `PaimonDataSink`.
PaimonMetadataApplier	A `MetadataApplier` that applies metadata changes to Paimon.
PaimonRecordEventSerializer	A `PaimonRecordSerializer` for converting `Event` into `PaimonEvent` for `PaimonWriter`.
PaimonRecordSerializer<Input>	Converting Input into `PaimonEvent` for `PaimonWriter`.
PaimonSink<InputT>	A `Sink` for Paimon.
PaimonWriter<InputT>	A `Sink` to write `DataChangeEvent` to Paimon storage.
PaimonWriterHelper	A helper class to deduce Schema of paimon table for `BucketAssignOperator`, and create FieldGetter and GenericRow for `PaimonWriter`.
PaimonWriterHelper.BinaryFieldDataGetter	A helper class for `PaimonWriter` to create FieldGetter and GenericRow.
PaimonWriterState	The state of `PaimonWriter`.
PaimonWriterStateSerializer	A `SimpleVersionedSerializer` for `PaimonWriterState`.
ParsingException	An exception representing a problem during parsing of text.
PartitioningEvent	A wrapper around `Event`, which contains the target partition number and will be used in `EventPartitioner`.
PartitioningEventKeySelector	Key selector for `PartitioningEvent`.
PartitioningEventSerializer	A `TypeSerializer` for `PartitioningEvent`.
PartitioningEventSerializer.PartitioningEventSerializerSnapshot	`TypeSerializerSnapshot` for `PartitioningEventSerializer`.
PartitioningEventTypeInfo	Type information for `PartitioningEvent`.
PartitioningTranslator	Translator used to build `RegularPrePartitionOperator` or `DistributedPrePartitionOperator`, `EventPartitioner` and `PostPartitionProcessor` that are responsible for events partition.
PartitionStrategy	Partition Strategy for sending `ProducerRecord` to kafka partition.
PendingSplitsState	A checkpoint of the current state of the containing the currently pending splits that are not yet assigned.
PendingSplitsState	A checkpoint of the current state of the containing the currently pending splits that are not yet assigned.
PendingSplitsStateSerializer	The `Serializer` for the `PendingSplitsState`.
PendingSplitsStateSerializer	The `Serializer` for the `PendingSplitsState` of MySQL CDC source.
PhysicalColumn	Representation of a physical column.
PhysicalColumnSerializer	A `TypeSerializer` for `PhysicalColumn`.
PhysicalColumnSerializer.PhysicalColumnSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
PipelineComposer	Composer for translating a pipeline definition to an execution.
PipelineDef	Definition of a pipeline.
PipelineDefinitionParser	Parsing pipeline definition files and generate `PipelineDef`.
PipelineDeploymentExecutor	PipelineDeploymentExecutor to execute flink cdc job from different target.
PipelineExecution	A pipeline execution that can be executed by a computing engine.
PipelineExecution.ExecutionInfo	Information of the execution.
PipelineKafkaRecordSerializationSchema	A `KafkaRecordSerializationSchema` to serialize `Event`.
PipelineOptions	Predefined pipeline configuration options.
PooledDataSourceFactory	A connection pool factory to create pooled DataSource `HikariDataSource`.
Position	A class that represents the position of a particular character in terms of the lines and columns of a character sequence.
PostgresChunkSplitter	The splitter to split the table into chunks using primary-key (by default) or a given split key.
PostgresConnection	`JdbcConnection` connection extension used for connecting to Postgres instances.
PostgresConnection.PostgresValueConverterBuilder
PostgresConnectionPoolFactory	A connection pool factory to create pooled Postgres `HikariDataSource`.
PostgresConnectionUtils	A utility class for accessing various Debezium PostgresConnection private-package classes/methods
PostgresDataSource	A `DataSource` for Postgres cdc connector.
PostgresDataSource.PostgresPipelineSource<T>	The `JdbcIncrementalSource` implementation for Postgres.
PostgresDataSourceFactory	A `Factory` to create `PostgresDataSource`.
PostgresDataSourceOptions	Configurations for `PostgresDataSource`.
PostgresDialect	The dialect for Postgres.
PostgresEventDeserializer	Event deserializer for `PostgresDataSource`.
PostgresMetadataAccessor	`MetadataAccessor` for `PostgresDataSource`.
PostgresObjectUtils	A factory for creating various Debezium objects
PostgresOffset	The offset for Postgres.
PostgresOffsetFactory	The factory to create `PostgresOffset`.
PostgresOffsetUtils	Utils for handling `PostgresOffset`.
PostgresPipelineRecordEmitter<T>	The `RecordEmitter` implementation for PostgreSQL pipeline connector.
PostgreSQLDeserializationConverterFactory	Used to create `DeserializationRuntimeConverterFactory` specified to PostgreSQL.
PostgreSQLReadableMetadata	Defines the supported metadata columns for `PostgreSQLTableSource`.
PostgreSQLSource	Deprecated.
PostgreSQLSource.Builder<T>	Builder class of `PostgreSQLSource`.
PostgreSQLTableFactory	Factory for creating configured instance of `PostgreSQLTableSource`.
PostgreSQLTableSource	A `DynamicTableSource` that describes how to create a PostgreSQL source from a logical description.
PostgresQueryUtils	Query-related Utilities for Postgres CDC source.
PostgresReplicationConnection	Copied from Debezium 1.9.8.Final
PostgresReplicationConnection.ReplicationConnectionBuilder
PostgresScanFetchTask	A `FetchTask` implementation for Postgres to read snapshot split.
PostgresScanFetchTask.PostgresSnapshotSplitReadTask	A SnapshotChangeEventSource implementation for Postgres to read snapshot split.
PostgresSchemaChangeEventHandler	This PostgresSchemaChangeEventHandler helps to parse the source struct in SchemaChangeEvent and generate source info.
PostgresSchemaDataTypeInference	`DataType` inference for PostgresSQL debezium `Schema`.
PostgresSchemaRecord	A SourceRecord wrapper carrying a Debezium Table for schema change propagation.
PostgresSchemaUtils	Utilities for converting from debezium `Table` types to `Schema`.
PostgresSourceBuilder<T>	The source builder for PostgresIncrementalSource.
PostgresSourceBuilder.PostgresIncrementalSource<T>	The Postgres source based on the incremental snapshot framework.
PostgresSourceConfig	The configuration for Postgres CDC source.
PostgresSourceConfigFactory	Factory to create Configuration for Postgres source.
PostgresSourceEnumerator	The Postgres source enumerator that enumerates receive the split request and assign the split to source readers.
PostgresSourceFetchTaskContext	The context of `PostgresScanFetchTask` and `PostgresStreamFetchTask`.
PostgresSourceOptions	Configurations for `PostgresSourceBuilder.PostgresIncrementalSource`.
PostgresSourceReader	The multi-parallel postgres source reader for table snapshot phase from `SnapshotSplit` and then single-parallel source reader for table stream phase from `StreamSplit`.
PostgresSourceRecordEmitter<T>	Record emitter that recognizes `PostgresSchemaRecord` as schema change events.
PostgresSourceRecordUtils	A utility class for processing `SourceRecord`s from a Postgres source.
PostgresStreamFetchTask	A `FetchTask` implementation for Postgres to read streaming changes.
PostgresStreamFetchTask.StreamSplitReadTask	A `ChangeEventSource` implementation for Postgres to read streaming changes.
PostgresStreamingChangeEventSource	Copied from Debezium 1.9.8.final
PostgresStreamingChangeEventSource.PgConnectionSupplier
PostgresTypeUtils	A utility class for converting Postgres types to Flink types.
PostgresTypeUtils	A utility class for converting Postgres types to Flink types.
PostgresValueValidator	The `RowDataDebeziumDeserializeSchema.ValueValidator` for Postgres connector.
PostPartitionProcessor	Function for unloading `Event` from internal `PartitioningEvent` after `EventPartitioner`.
PostTransformChangeInfo	PostTransformChangeInfo caches pre-transformed / pre-transformed schema, schema field getters, and binary record data generator for post-transform schema.
PostTransformConverter	The PostTransformConverter applies to convert the `DataChangeEvent` after other part of TransformRule in PostTransformOperator.
PostTransformConverters	The `PostTransformConverter` utils.
PostTransformer	Post-Transformation rule used by `PostTransformOperator`.
PostTransformOperator	A data process function that performs column filtering, calculated column evaluation & final projection.
PostTransformOperatorBuilder	Builder of `PostTransformOperator`.
PreCommitOperator	An Operator to add checkpointId to MultiTableCommittable and generate CommittableSummary.
Preconditions	A collection of static utility methods to validate input.
Predicates	A utility class for creating `Predicate` instances.
Predicates.RegExSplitterByComma	A tokenization class used to split a comma-separated list of regular expressions.
Predicates.RegExSplitterByDot	A tokenization class used to split a dot-separated list of regular expressions.
PreTransformChangeInfo	PreTransformChangeInfo caches source / pre-transformed schema, source schema field getters, and binary record data generator for pre-transform schema.
PreTransformChangeInfo.Serializer	Serializer for `PreTransformChangeInfo`.
PreTransformer	Pre-Transformation rule used by `PreTransformOperator`.
PreTransformOperator	A data process function that filters out columns which aren't (directly & indirectly) referenced.
PreTransformOperatorBuilder	Builder of `PreTransformOperator`.
PreTransformProcessor	The processor of pre-transform projection in `PreTransformOperator`.
ProjectionColumn	The ProjectionColumn applies to describe the information of the transformation column.
ProjectionColumnProcessor	The processor of the projection column.
Public	Annotation for marking classes as public, stable interfaces.
PublicEvolving	Annotation to mark classes and methods for public use, but with evolving interfaces.
PythonUdf	Generic UDF that delegates to a Python function defined inline in YAML.
PythonUdfSignature	Resolves the return type of a `PythonUdf` from its inline Python source.
RecordData	Class `RecordData` describes the data of changed record (i.e.
RecordData.FieldGetter	Accessor for getting the field of a RecordData during runtime.
RecordDataConverter	Utility class for converting CDC `RecordData` to Flink SQL `RowData`.
RecordDataSerializer	Serializer for `RecordData`.
RecordDataSerializer.RecordDataSerializerSnapshot	`TypeSerializerSnapshot` for `RecordDataSerializer`.
RecordUtils	Utility class to deal record.
RedoLogOffset	A structure describes an offset in a redo log event.
RedoLogOffsetFactory	An offset factory class create `RedoLogOffset` instance.
RegionCDCClient	Copied from https://github.com/tikv/client-java project to fix https://github.com/tikv/client-java/issues/600 for 3.2.0 version.
RegularPrePartitionOperator	Operator for processing events from `SchemaOperator` before `EventPartitioner` with regular topology.
RelationalChangeRecordEmitter<P extends io.debezium.pipeline.spi.Partition>	Copied from Debezium 1.9.8.Final.
RelationalTableFilters	Copied from Debezium 1.9.8.Final.
RelationAwarePostgresSchema	Extends PostgresSchema to dispatch Relation messages as schema change events via the event queue and expose buildAndRegisterSchema as public.
RenameColumnEvent	A `SchemaChangeEvent` that represents an `RENAME COLUMN` DDL, which may contain the lenient column type changes.
RenameColumnEventSerializer	A `TypeSerializer` for `RenameColumnEvent`.
RenameColumnEventSerializer.RenameColumnEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
ResolvedSchemaUtils	Utilities to `ResolvedSchema`.
ResumeTokenUtils	Utility class to decode resumeToken.
RetryBackoffStrategy	Strategy for calculating the delay between retry attempts.
RetryUtils	Retry utilities to execute a callable with specific retry times.
RouteDef	Definition of a router.
RouteMode	Route mode for routing rules.
RouteRule	Definition of a routing rule with replacement symbol.
RowDataDebeziumDeserializeSchema	Deserialization schema from Debezium object to Flink Table/SQL internal data structure `RowData`.
RowDataDebeziumDeserializeSchema.Builder	Builder of `RowDataDebeziumDeserializeSchema`.
RowDataDebeziumDeserializeSchema.ValueValidator	Custom validator to validate the row value.
RowDataMetadataConverter	A converter converts `RowData` metadata into Flink internal data structures.
RowDataTiKVChangeEventDeserializationSchema	Deserialization schema from TiKV Change Event to Flink Table/SQL internal data structure `RowData`.
RowDataTiKVEventDeserializationSchemaBase	Base class of deserialization schema from TiKV RowValue (Snapshot or Change Event) to Flink Table/SQL internal data structure `RowData`.
RowDataTiKVSnapshotEventDeserializationSchema	Deserialization schema from TiKV Snapshot Event to Flink Table/SQL internal data structure `RowData`.
RowDataUtils	Utils for converting `RowData` and `DataChangeEvent`.
RowDataUtils	Utils for convertion of `RowData` and `DataChangeEvent`.
RowType	Data type of a sequence of fields.
RowType.Builder	Builder of `RowType`.
RowTypeSerializer	A `TypeSerializer` for `RowType`.
RowTypeSerializer.RowTypeSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
RuntimeExecutionMode	Runtime execution mode of the pipeline includes STREAMING and BATCH, with the default value being STREAMING.
SampleBucketSplitStrategy	The Sample Splitter.
ScanIterator	Copied from https://github.com/tikv/client-java project to fix https://github.com/tikv/client-java/issues/600 for 3.2.0 version.
Schema	Schema of a table or data collection.
Schema.Builder	A builder for constructing an immutable but still unresolved `Schema`.
SchemaAdjustmentMode	Specifies how schema names should be adjusted for compatibility with the message converter used by the connector.
SchemaChangeBehavior	Behavior for handling schema changes.
SchemaChangeConfig	Configurations for schema change.
SchemaChangeEvent	Class `SchemaChangeEvent` represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
SchemaChangeEventHandler	This handler helps to parse the source struct in SchemaChangeEvent and generate source info.
SchemaChangeEventSerializer	A `TypeSerializer` for `SchemaChangeEvent`.
SchemaChangeEventSerializer.SchemaChangeEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
SchemaChangeEventType	An enumeration of schema change event types for `SchemaChangeEvent`.
SchemaChangeEventTypeFamily	An enumeration of schema change event families for clustering `SchemaChangeEvent`s into categories.
SchemaChangeEventVisitor	Visitor clas for all `SchemaChangeEvent`s and returns a specific typed object.
SchemaChangeEventWithPreSchema	A `SchemaChangeEvent` that supports appending schema before change event.
SchemaChangeOperatorEvent	An operator event that encapsulates a schema change and the resulting new schema.
SchemaChangeProvider	The SchemaChangeProvider class provides static methods to create SchemaChange objects that represent different types of schema modifications.
SchemaChangeRequest	Schema operator's request to `SchemaCoordinator` for merging an incompatible schema.
SchemaChangeRequest	The request from `SchemaOperator` to `SchemaCoordinator` to request to change schemas.
SchemaChangeResponse	Response from a `SchemaCoordinator` to broadcast a coordination consensus.
SchemaChangeResponse	The response for `SchemaChangeRequest` from `SchemaCoordinator` to `SchemaOperator`.
SchemaChangeUtil	Utilities for inferring CDC schema change events by comparing before/after Debezium table schemas.
SchemaCoordinator	Coordinator node for `SchemaOperator`.
SchemaCoordinator	Coordinator node for `SchemaOperator`.
SchemaCoordinatorProvider	Provider for `SchemaCoordinator`.
SchemaCoordinatorProvider	Provider of `SchemaCoordinator`.
SchemaDataTypeInference	`DataType` inference for kafka connect `Schema`.
SchemaDerivator	A utility class to derive how evolved schemas should change.
SchemaDispatcher	Dispatches Debezium table schema changes into the change event queue.
SchemaEvolutionClient	Client for `DataSinkWriterOperator` interact with Schema Registry (Could be distributed or regular) when table schema evolution happened.
SchemaEvolutionUtils	Schema evolution utils for maxcompute.
SchemaEvolveException	An exception occurred during schema evolution.
SchemalessSnapshotSplit	A kind of `SnapshotSplit` without table schema information, it is useful to reduce memory usage in JobManager.
SchemaManager	Schema manager handles schema changes for tables, and manages historical schema versions of tables.
SchemaManager.Serializer	Serializer for `SchemaManager`.
SchemaMergingUtils	Utils for merging `Schema`s and `DataType`s.
SchemaMetadataTransform	a Pojo class to describe the information of the primaryKeys/partitionKeys/options transformation of `Schema`.
SchemaNameMetadataColumn	A `SupportedMetadataColumn` for schema_name.
SchemaOperator	This operator merges upstream inferred schema into a centralized Schema Registry.
SchemaOperator	The operator will evolve schemas in `SchemaCoordinator` for incoming `SchemaChangeEvent`s and block the stream for tables before their schema changes finish.
SchemaOperatorFactory	Factory to create `SchemaOperator`.
SchemaOperatorFactory	Factory to create `SchemaOperator`.
SchemaOperatorMetrics	A collection class for handling metrics in `SchemaOperator`.
SchemaOperatorTranslator	Translator used to build `SchemaOperator` for schema event process.
SchemaOutOfSyncException	A wrapper class for clearly show the possible reason of a schema-out-of-sync exception thrown inside Debezium.
SchemaRecord	The Record represents a schema change event, it contains either one `HistoryRecord` or `TableChanges.TableChange`.
SchemaRegistry	An abstract centralized schema registry that accepts requests from `SchemaEvolutionClient`.
SchemaSerializer	A `TypeSerializer` for `Schema`.
SchemaSerializer.SchemaSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
SchemaUtils	Utils for `Schema` to perform the ability of evolution.
SeekBinlogToTimestampFilter<T>	A `DebeziumDeserializationSchema` which wraps a real `DebeziumDeserializationSchema` to seek binlog to the specific timestamp.
Selectors	Selectors for filtering tables.
Selectors	Selectors for filtering tables.
Selectors.SelectorsBuilder	Builder for `Selectors`.
Selectors.SelectorsBuilder	Builder for `Selectors`.
SerializerUtils	Utils for serialization and deserialization.
SerializerUtils	Utils for serialization and deserialization.
ServerIdRange	This class defines a range of server id.
SessionCommitCoordinateHelper	The SessionCommitCoordinator class is responsible for coordinating and controlling the order of session submissions by multiple concurrent executors in a distributed processing environment.
SessionIdentifier	A Session is uniquely identified through `TableId` and `partitionName`.
SessionManageCoordinatedOperatorFactory	The `AbstractStreamOperatorFactory` for `SessionManageOperator`.
SessionManageCoordinator	An OperatorCoordinator is used to manage the Session and is consistent with accepting `CreateSessionRequest` and `CommitSessionRequest` sent by the Operator.
SessionManageCoordinator.SessionManageCoordinatorProvider	The `OperatorCoordinator.Provider` of `SessionManageCoordinator`.
SessionManageOperator	Processes a `DataChangeEvent`, extracting data and encapsulating it into a `SessionIdentifier`, and then sends a `CreateSessionRequest` to the `SessionManageCoordinator` to create a writing session.
ShardedSplitStrategy	The Sharded Splitter
ShortSerializer	Type serializer for `Byte`.
ShortSerializer.ShortSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
SignalEventDispatcher	A dispatcher to dispatch watermark signal events.
SignalEventDispatcher.WatermarkKind	The watermark kind.
SingleSplitStrategy	The Single Partitioner
SinkDef	Definition of a data sink.
SinkWrapperException	A generic `RuntimeException` thrown when an error occurs in `DataSinkWriterOperator` and `DataSinkFunctionOperator`.
SinkWriterRegisterEvent	A `OperatorEvent` that register sink writer to `SchemaRegistry`.
SkewedThrottlerFunctionClass	A UDF that makes one record deliberately slower than later records.
SmallIntType	Data type of a 2-byte signed integer with values from -32,768 to 32,767.
SnapshotPendingSplitsState	A `PendingSplitsState` for pending snapshot splits.
SnapshotPendingSplitsState	A `PendingSplitsState` for pending snapshot splits.
SnapshotPhaseHook	Hook to be invoked during different stages in the snapshot phase.
SnapshotPhaseHook	Hook to be invoked during different stages in the snapshot phase.
SnapshotPhaseHooks	A container class for hooks applied in the snapshot phase, including: `SnapshotPhaseHooks.preHighWatermarkAction`: Hook to run before emitting high watermark, which is for testing whether stream events created within snapshot phase are backfilled correctly.
SnapshotPhaseHooks	A container class for hooks applied in the snapshot phase, including: `SnapshotPhaseHooks.preHighWatermarkAction`: Hook to run before emitting high watermark, which is for testing whether binlog events created within snapshot phase are backfilled correctly.
SnapshotSplit	The split to describe a split of a database table snapshot.
SnapshotSplitAssigner<C extends SourceConfig>	Assigner for snapshot split.
SnapshotSplitReader	A snapshot reader that reads data from Table in split level, the split is assigned by primary key range.
SnapshotSplitReader.SnapshotSplitChangeEventSourceContextImpl	`ChangeEventSource.ChangeEventSourceContext` implementation that keeps low/high watermark for each `MySqlSnapshotSplit`.
SnapshotSplitState	The state of split to describe the snapshot of table(s).
SoftDeleteConverter	This `PostTransformConverter` convert delete events to insert events.
SourceConfig	The source configuration which offers basic source configuration.
SourceConfig.Factory<C extends SourceConfig>	Factory for the `SourceConfig`.
SourceDef	Definition of a data source.
SourceEnumeratorMetrics	A collection class for handling metrics in `SourceEnumeratorMetrics`.
SourceEnumeratorMetrics.TableMetrics	Collection class for managing metrics of a table.
SourceOptions	Configurations for `IncrementalSource`.
SourceReaderMetrics	A collection class for handling metrics in `IncrementalSourceReader`.
SourceRecordEventDeserializer	Deserializer to deserialize `SourceRecord` to `Event`.
SourceRecords	Data structure to describe a set of `SourceRecord`.
SourceRecords	Data structure to describe a set of `SourceRecord`.
SourceRecordUtils	Utility class to deal record.
SourceSplitBase	The split of table comes from a Table that splits by primary key.
SourceSplitSerializer	A serializer for the `SourceSplitBase`.
SourceSplitState	State of the reader, essentially a mutable version of the `SourceSplitBase`.
SplitAssigner	The `SplitAssigner` is responsible for deciding what split should be processed.
SplitContext	The split context used by `SplitStrategy` to split collection into a set of chunks for MongoDB data source.
SplitKeyUtils	Utility class to deal split keys and split key ranges.
SplitKeyUtils	Utility class to deal split keys and split key ranges.
SplitKeyUtils.RangePosition	Describes the relative position of a key to a split range.
SplitStrategy	The `MongoDBChunkSplitter` used to split collection into a set of chunks for MongoDB data source.
SplitVectorSplitStrategy	The SplitVector Splitter.
SqlServerChunkSplitter	The `ChunkSplitter` used to split SqlServer table into a set of chunks for JDBC data source.
SqlServerConnectionUtils	Utils for SqlServer connection.
SqlServerDataSource	A `DataSource` for SQL Server CDC connector.
SqlServerDataSourceFactory	A `Factory` to create `SqlServerDataSource`.
SqlServerDataSourceOptions	Configurations for `SqlServerDataSource`.
SqlServerDeserializationConverterFactory	Used to create `DeserializationRuntimeConverterFactory` specified to SqlServer.
SqlServerDialect	The `JdbcDataSourceDialect` implementation for SqlServer datasource.
SqlServerEventDeserializer	Event deserializer for `SqlServerDataSource`.
SqlServerMetadataAccessor	`MetadataAccessor` for `SqlServerDataSource`.
SqlServerOffsetContext	Copied from Debezium project(1.9.8.final) to modify the io.debezium.connector.sqlserver.SqlServerOffsetContext.Loader#load(java.util.Map) method.
SqlServerOffsetContext.Loader
SqlServerPipelineRecordEmitter<T>	The `RecordEmitter` implementation for SQL Server pipeline connector.
SqlServerPipelineSource	The SQL Server CDC Source for Pipeline connector, which supports parallel reading snapshot of table and then continue to capture data change from transaction log.
SqlServerPooledDataSourceFactory	Factory to create `JdbcConnectionPoolFactory` for SQL Server.
SqlServerReadableMetadata	Defines the supported metadata columns for `SqlServerTableSource`.
SqlServerScanFetchTask	The task to work for fetching data of SqlServer table snapshot split.
SqlServerScanFetchTask.SqlServerSnapshotSplitReadTask	A wrapped task to fetch snapshot split of table.
SqlServerSchema	A component used to get schema by table path.
SqlServerSchemaChangeEventHandler	This SqlServerSchemaChangeEventHandler helps to parse the source struct in SchemaChangeEvent and generate source info.
SqlServerSchemaDataTypeInference	`DataType` inference for SQL Server debezium `Schema`.
SqlServerSchemaUtils	Utilities for converting from debezium `Table` types to `Schema`.
SqlServerSource	Deprecated.
SqlServerSource.Builder<T>	Builder class of `SqlServerSource`.
SqlServerSourceBuilder<T>	The builder class for `SqlServerSourceBuilder.SqlServerIncrementalSource` to make it easier for the users to construct a `SqlServerSourceBuilder.SqlServerIncrementalSource`.
SqlServerSourceBuilder.SqlServerIncrementalSource<T>	The `JdbcIncrementalSource` implementation for SqlServer.
SqlServerSourceConfig	Describes the connection information of the SQL Server database and the configuration information for performing snapshotting and streaming reading, such as splitSize.
SqlServerSourceConfigFactory	Factory for creating `SqlServerSourceConfig`.
SqlServerSourceFetchTaskContext	The context for fetch task that fetching data of snapshot split from SqlServer data source.
SqlServerSourceFetchTaskContext.SqlServerEventMetadataProvider	Copied from debezium for accessing here.
SqlServerStreamFetchTask	The task to work for fetching data of SqlServer table stream split .
SqlServerStreamFetchTask.StreamSplitReadTask	A wrapped task to read all binlog for table and also supports read bounded (from lowWatermark to highWatermark) binlog.
SqlServerStreamingChangeEventSource	Copied from Debezium project(1.9.8.final) to add method `SqlServerStreamingChangeEventSource.afterHandleLsn(SqlServerPartition, Lsn)`.
SqlServerTableFactory	Factory for creating configured instance of `SqlServerTableSource`.
SqlServerTableSource	A `DynamicTableSource` that describes how to create a SqlServer source from a logical description.
SqlServerTypeUtils	Utilities for converting from SqlServer types to Flink types.
SqlServerTypeUtils	A utility class for converting SQL Server types to Flink CDC types.
SqlServerUtils	The utils for SqlServer data source.
SqlServerValidator	Validator for SqlServer to validate: SqlServer CDC mechanism is enabled or not, SqlServer version is supported or not.
SqlTypeFamily	SqlTypeFamily provides SQL type categorization.
SqlTypeName	Enumeration of the type names which can be used to construct a SQL type.
SqlTypeName.Limit	Limit.
StarRocksDataSink	A `DataSink` for StarRocks connector that supports schema evolution.
StarRocksDataSinkFactory	A `DataSinkFactory` to create `StarRocksDataSink`.
StarRocksDataSinkOptions	Options for `StarRocksDataSink`.
StarRocksEnrichedCatalog	An enriched `StarRocksCatalog` with more schema evolution abilities.
StarRocksEscapingUtils	Utilities for escaping values embedded in double-quoted StarRocks SQL literals.
StarRocksMetadataApplier	A `MetadataApplier` that applies metadata changes to StarRocks.
StarRocksUtils	Utilities for conversion from source table to StarRocks table.
StarRocksUtils.CdcDataTypeTransformer	Transforms CDC `DataType` to StarRocks data type.
StartupMode	Startup modes for the Flink CDC Connectors.
StartupMode	Startup modes for the MySQL CDC Consumer.
StartupMode	Startup modes for the TiDB CDC Consumer.
StartupOptions	Flink CDC Connector startup options.
StartupOptions	Debezium startup options.
StartupOptions	Debezium startup options.
StartupOptions	TiDB CDC Source startup options.
StatefulTaskContext	A stateful task context that contains entries the debezium mysql connector task required.
StatefulTaskContext.MySqlEventMetadataProvider	Copied from debezium for accessing here.
StatementUtils	Utils to prepare SQL statement.
StaticExternalResourceProxy<T extends org.junit.rules.ExternalResource>	A wrapper class for migrating JUnit 4 `@ClassRule` to JUnit 5.
StoppableChangeEventSourceContext	A change event source context that can stop the running source by invoking `StoppableChangeEventSourceContext.stopChangeEventSource()`.
StoppableChangeEventSourceContext	A change event source context that can stop the running source by invoking `StoppableChangeEventSourceContext.stopChangeEventSource()`.
StoppableChangeEventSourceContext	A change event source context that can stop the running source by invoking `StoppableChangeEventSourceContext.stopChangeEventSource()`.
StoreSinkWriteImpl	copy from `StoreSinkWriteImpl`.
StreamPendingSplitsState	A `PendingSplitsState` for pending stream splits.
StreamSplit	The split to describe the change log of database table(s).
StreamSplitAssignedEvent	The `SourceEvent` that `IncrementalSourceReader` sends to `IncrementalSourceEnumerator` to notify the `StreamSplit` assigned to itself.
StreamSplitAssigner	Assigner for stream split.
StreamSplitMetaAssembledEvent	The `SourceEvent` that `IncrementalSourceReader` sends to `IncrementalSourceEnumerator` once it has assembled the complete stream-split metadata and no longer needs the coordinator to serve that metadata, so the coordinator can release it from memory and from the checkpointed state once the assembled split is covered by a completed checkpoint.
StreamSplitMetaEvent	The `SourceEvent` that `IncrementalSourceEnumerator` sends to `IncrementalSourceReader` to pass change log metadata, i.e.
StreamSplitMetaRequestEvent	The `SourceEvent` that `IncrementalSourceReader` sends to `IncrementalSourceEnumerator` to pull change log metadata, i.e.
StreamSplitState	The state of split to describe the change log of table(s).
StreamSplitUpdateAckEvent	The `SourceEvent` that `IncrementalSourceReader` sends to `IncrementalSourceEnumerator` to notify the stream split reader has been updated.
StreamSplitUpdateRequestEvent	The `SourceEvent` that `IncrementalSourceEnumerator` broadcasts to `IncrementalSourceSplitReader` to tell the source reader to update the stream split after newly added table snapshot splits finished.
StringData	An internal data structure representing data of `CharType` and `VarCharType`.
StringDataSerializer	Serializer for `StringData`.
StringDataSerializer.StringDataSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
StringDebeziumDeserializationSchema	A simple implementation of `DebeziumDeserializationSchema` which converts the received `SourceRecord` into String.
StringFunctions	String built-in functions.
StringSerializer	Type serializer for `String`.
StringSerializer.StringSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
StringUtf8Utils	Utilities for String UTF-8.
StringUtils	Utility class to convert objects into strings in vice-versa.
StructFunctions	Built-in functions for collection and struct data types.
SupportedMetadataColumn	A metadata column that the source supports to read from the meta field.
SupportsEmbedding	Ability interface for `AiModelClient` implementations that can produce dense vector embeddings from text input.
SupportsImageEmbedding	Ability interface for `AiModelClient` implementations that can embed image bytes.
SupportsImageTextGeneration	Ability interface for `AiModelClient` implementations that can generate text from an image combined with a natural-language prompt.
SupportsTextGeneration	Ability interface for `AiModelClient` implementations that can perform chat-style text generation given a system prompt and a user input.
SyncRequest	A request signaling the `SessionManageCoordinator` to await requests from all operators.
TableAwareCorrespondent	A correspondent between a write task and the multi-table coordinator.
TableAwareCorrespondent.CreateTableRequest	A CoordinationRequest that encapsulates a `CreateTableEvent`.
TableAwareCorrespondent.MultiTableInstantTimeRequest	A custom coordination request that includes the TableId to request an instant for a specific table.
TableAwareCorrespondent.SchemaChangeRequest	A CoordinationRequest that represents a request to change table schema.
TableAwareCorrespondent.SchemaChangeResponse	Response for a `TableAwareCorrespondent.CreateTableRequest` or `TableAwareCorrespondent.SchemaChangeRequest`.
TableCreateConfig	Configurations for creating a StarRocks table.
TableDiscoverer	Table-specific specialization of `ObjectIdDiscoverer` whose discovered object id type is `TableId`.
TableDiscovererFactory	Table-specific SPI factory that creates a `TableDiscoverer`.
TableDiscoveryUtils	Utilities to discovery matched tables.
TableDiscoveryUtils	A utility class for table discovery.
TableFilter	A filter for tables.
TableId	The unique identifier used to represent the path of external table or external data collection, all external system data collection could map to a dedicated `TableId`.
TableIdHashFunctionProvider	A `HashFunctionProvider` implementation that hashes events based solely on `TableId`.
TableIdRouter	Calculates how upstream data change events should be dispatched to downstream tables.
TableIdSerializer	A `TypeSerializer` for `TableId`.
TableIdSerializer.TableIdSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
TableKeyRangeUtils	Utils to obtain the keyRange of table.
TableMapEventDataDeserializer	Copied from mysql-binlog-connector 0.25.3 to support MYSQL_TYPE_TYPED_ARRAY.
TableMapEventMetadataDeserializer	Copied from mysql-binlog-connector 0.27.2 to fix table metadata deserialization issue #363.
TableMetric	Metrics of commit message for each table.
TableNameMetadataColumn	A `SupportedMetadataColumn` for table_name.
TableRemovalAckEvent	Acknowledges completed table-removal requests from a source reader.
TableSchemaInfo	maintain the `SerializationSchema` of a specific `TableId`.
TableSchemaInfo	Keep a list of `RecordData.FieldGetter` for a specific `Schema`.
TableSchemaWrapper	A Wrapper for `Schema`.
TableSubscriptionEvent	Authoritative source-table subscription snapshot sent from the enumerator to a reader.
TabletType	The type of Tablet (hence MySQL) from which to stream the changes.
TDBSourceOptions	Configurations for `TiDBSource`.
TemporalConversions	Temporal conversion constants.
TemporalFunctions	Temporal built-in functions.
TestCaseUtils	Some utility methods for creating repeated-checking test cases.
TestSourceContext<T>	A testable `SourceFunction.SourceContext`.
TextElement	Represents a text block in the `Description`.
TextElement.TextStyle	Styles that can be applied to `TextElement` e.g.
ThreadLocalCache<K,V>	Provides a thread local cache with a maximum cache size per thread.
ThrottlerFunctionClass	This is an example UDF class for slowing down the pipeline deliberately.
TiDBSource	A builder to build a SourceFunction which can read snapshot and continue to read CDC events.
TiDBSource.Builder<T>	Builder class of `TiDBSource`.
TiDBSourceMetrics	A collection class for handling metrics in `TiKVRichParallelSourceFunction`.
TiDBTableSource	A `DynamicTableSource` that describes how to create a TiDB change event stream from a logical description.
TiDBTableSourceFactory	Factory for creating configured instance of `TiDBTableSource`.
TiKVAppendMetadataCollector	Emits a row with physical fields and metadata fields.
TiKVChangeEventDeserializationSchema<T>	The deserialization schema describes how to turn the TiKV Change Event into data types (Java/Scala objects) that are processed by Flink.
TiKVDeserializationRuntimeConverter	Runtime converter that converts objects of TiKV into objects of Flink Table & SQL internal data structures.
TiKVMetadataConverter	A converter converts TiKV Row metadata into Flink internal data structures.
TiKVMetadataConverter.TiKVRowValue	TiKV Row Value.
TiKVReadableMetadata	Defines the supported metadata columns for `TiDBTableSource`.
TiKVRichParallelSourceFunction<T>	The source implementation for TiKV that read snapshot events first and then read the change event.
TiKVSnapshotEventDeserializationSchema<T>	The deserialization schema describes how to turn the TiKV snapshot event into data types (Java/Scala objects) that are processed by Flink.
TimeData	An internal data structure representing data of `TimeType`.
TimeDataSerializer	Serializer for `TimeData`.
TimeDataSerializer.TimeDataSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
TimestampData	An internal data structure representing data of `TimestampType`.
TimestampDataSerializer	Serializer for `TimestampData`.
TimestampDataSerializer.TimestampDataSerializerSnapshot	`TypeSerializerSnapshot` for `TimestampDataSerializer`.
TimestampType	Data type of a timestamp WITHOUT time zone consisting of `year-month-day hour:minute:second[.fractional]` with up to nanosecond precision and values ranging from `0000-01-01 00:00:00.000000000` to `9999-12-31 23:59:59.999999999`.
TimestampTypeMetadataColumn	A `SupportedMetadataColumn` for timestamp-type.
TimestampTypeReturningClass	This is an example UDF class for testing purposes only.
TimeType	Data type of a time WITHOUT time zone consisting of `hour:minute:second[.fractional]` with up to nanosecond precision and values ranging from `00:00:00.000000000` to `23:59:59.999999999`.
TimeUtils	Collection of utilities about time intervals.
TinyIntType	Data type of a 1-byte signed integer with values from -128 to 127.
TokenStream	A stream of tokens that can be consumed by a parser.
TokenStream.CharacterArrayStream	An implementation of `TokenStream.CharacterStream` that works with a single character array.
TokenStream.CharacterStream	Interface used by a `TokenStream.Tokenizer` to iterate through the characters in the content input to the `TokenStream`.
TokenStream.Marker	An opaque marker for a position within the token stream.
TokenStream.Token	The interface defining a token, which references the characters in the actual input character stream.
TokenStream.Tokenizer	Interface for a Tokenizer component responsible for processing the characters in a `TokenStream.CharacterStream` and constructing the appropriate `TokenStream.Token` objects.
TokenStream.Tokens	A factory for Token objects, used by a `TokenStream.Tokenizer` to create tokens in the correct order.
TransformContext	Contextual information during Post-transform phase.
TransformDef	Definition of a transformation.
TransformException	A generic `RuntimeException` thrown during transform failure.
TransformExpressionCompiler	The processor of the transform expression.
TransformExpressionKey	The key applies to describe the information of the transformation expression.
TransformFilter	The TransformFilter applies to describe the information of the filter row.
TransformFilterProcessor	The processor of the transform filter.
TransformNumericExceptFirstOperandChecker	Parameter type-checking strategy where all operand types except first one must be numeric type.
TransformParser	Use Flink's calcite parser to parse the statement of flink cdc pipeline transform.
TransformProjection	The projection of transform applies to describe a projection of filtering tables.
TransformProjectionProcessor	The processor of transform projection applies to process a row of filtering tables.
TransformRule	A rule defining pre-transformations where filtered rows and irrelevant columns are removed.
TransformSchema	TransformSchema to generate the metadata of calcite.
TransformSchemaFactory	TransformSchemaFactory to generate the metadata of calcite.
TransformSqlOperatorTable	TransformSqlOperatorTable to generate the metadata of calcite.
TransformSqlReturnTypes	This is the return type definition of the call in the Transform expression, which references the class of FlinkReturnTypes in the Flink.
TransformTable	TransformTable to generate the metadata of calcite.
TransformTranslator	Translator used to build `PreTransformOperator` and `PostTransformOperator` for event transform.
TruncateTableEvent	A `SchemaChangeEvent` that represents an `TRUNCATE TABLE` DDL.
TruncateTableEventSerializer	A `TypeSerializer` for `TruncateTableEvent`.
TruncateTableEventSerializer.TruncateTableEventSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
TypeCheckUtils	Utils for type check purpose.
TypeConvertUtils	Data type mapping table This table shows the mapping relationship from Flink types to MaxCompute types and the corresponding Java type representation.
TypeHintFunctionClass	This is an example UDF class for testing purposes only.
TypeOfFunctionClass	This is an example UDF class for testing purposes only.
TypeOfFunctionClass	This is an example UDF class for testing purposes only.
TypeSerializerSingleton<T>	A `TypeSerializer` whose method duplicate() return itself.
TypeUtils	Utils for data type conversion between CDC and Paimon System.
UdfDef	Definition of a user-defined function.
UncheckedOdpsException	a wrapper class for `OdpsException` which throws `RuntimeException`.
UnsupportedSchemaChangeEventException	A special kind of `SchemaEvolveException` that sink doesn't support such event type.
UriHostMapping	Get TiKV Host Mapping Function.
UserDefinedFunction	Base interface for creating a UDF in transform projection and filtering expressions.
UserDefinedFunctionContext	Context for initialization of `UserDefinedFunction`.
UserDefinedFunctionDescriptor	Descriptor of a UDF function.
Utils	A utility class for accessing various Debezium package-private methods.
Validator	Validator to validate the connected database satisfies the cdc connector's requirements.
ValuesDatabase	An auxiliary class for simulating a database, use for `ValuesDataSource` and `ValuesDataSink`.
ValuesDatabase.ErrorOnChangeMetadataApplier	apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.
ValuesDatabase.ValuesMetadataAccessor	provide namespace/schema/table lists for `ValuesDataSource`.
ValuesDatabase.ValuesMetadataApplier	apply SchemaChangeEvent to ValuesDatabase and print it out, throw exception if illegal changes occur.
ValuesDataFactory	A dummy `Factory` to create `ValuesDataSource` and `ValuesDataSink`.
ValuesDataSink	A `DataSink` for "values" connector that supports schema evolution.
ValuesDataSink.SinkApi	SinkApi which sink based on.
ValuesDataSinkFunction	An e2e `SinkFunction` implementation that print all `DataChangeEvent` out.
ValuesDataSinkHelper	A helper class for `ValuesDataSink` to process `Event`.
ValuesDataSinkOptions	Configurations for `ValuesDataSink`.
ValuesDataSource	A `DataSource` for "values" connector that supports schema evolution.
ValuesDataSourceHelper	A helper class for `ValuesDataSource` to build events of each split.
ValuesDataSourceHelper.EventSetId	Different situations for creating sourceEvents, `ValuesDataSourceOptions.EVENT_SET_ID`.
ValuesDataSourceOptions	Configurations for `ValuesDataSource`.
VarBinaryType	Data type of a variable-length binary string (=a sequence of bytes).
VarBinaryTypeReturningClass	This is an example UDF class for testing purposes only.
VarCharType	Data type of a variable-length character string.
VarCharTypeReturningClass	This is an example UDF class for testing purposes only.
Variant	Copy from Variant.java
Variant.Type	The type of variant.
VariantAwareItemOperator	A variant-aware implementation of the ITEM operator.
VariantBuilder	Copy from VariantBuilder.java
VariantBuilder.VariantArrayBuilder	Builder for a variant array.
VariantBuilder.VariantObjectBuilder	Builder for a variant object.
VariantSerializer	Serializer for `Variant`.
VariantSerializer.VariantSerializerSnapshot	Snapshot class for the `VariantSerializer`.
VariantType	Data type of semi-structured data.
VariantTypeException	Copy from VariantTypeException.java
VersionComparable	Used to compare version numbers at runtime.
VersionComparable	Used to compare version numbers at runtime.
VisibleForTesting	This annotations declares that a function, field, constructor, or entire type, is only visible for testing purposes.
VisitorHandler<EVT extends SchemaChangeEvent,T,E extends Throwable>	Visitor for `TruncateTableEvent`s.
VitessSource	A builder to build a SourceFunction which can read and process vitess database changes.
VitessSource.Builder<T>	Builder class of `VitessSource`.
VitessTableFactory	Factory for creating configured instance of `VitessTableSource`.
VitessTableSource	A `DynamicTableSource` that describes how to create a Vitess source from a logical description.
VitessValidator	The validator for Vitess.
VoidVisitorHandler<EVT extends SchemaChangeEvent,E extends Throwable>	Visitor for `TruncateTableEvent`s.
WaitForFlushSuccessRequest	the `OperatorEvent` use for sync SessionManageOperator and SinkWriter.
WatermarkDispatcher	CDC event dispatcher which provides ability to dispatch watermark.
WatermarkEvent	Utility class to deal Watermark event.
WatermarkKind	The watermark kind.
WrappedFlussCounter	An implementation of Flink's `Counter` which wraps Fluss's Counter.
WrappedFlussGauge<T>	An implementation of Flink's `Gauge` which wraps Fluss's Gauge.
WrapperFlussHistogram	An implementation of Flink's `Histogram` which wraps Fluss's Histogram.
WrapperFlussMeter	An implementation of Flink's `Meter` which wraps Fluss's Meter.
WrapperFlussMetricRegistry	An implementation of `MetricRegistry` which registers all metrics into Flink's metric system.
WriteResultWrapper	A wrapper class for `WriteResult` and `TableId`.
YamlParserUtils	This class contains utility methods to load standard yaml file and convert object to standard yaml syntax.
YamlPipelineDefinitionParser	Parser for converting YAML formatted pipeline definition to `PipelineDef`.
YarnApplicationDeploymentExecutor	Deploy flink cdc job by yarn application mode.
ZonedTimestampData	An internal data structure representing data of `ZonedTimestampType`.
ZonedTimestampDataSerializer	Serializer for `ZonedTimestampData`.
ZonedTimestampDataSerializer.ZonedTimestampDataSerializerSnapshot	`TypeSerializerSnapshot` for `ZonedTimestampDataSerializer`.
ZonedTimestampType	Data type of a timestamp WITH time zone consisting of `year-month-day hour:minute:second[.fractional] zone` with up to nanosecond precision and values ranging from `0000-01-01 00:00:00.000000000 +14:59` to `9999-12-31 23:59:59.999999999 -14:59`.