Uses of Class
org.apache.flink.cdc.common.annotation.Internal

Packages that use Internal

Package	Description
org.apache.flink.cdc.common.annotation
org.apache.flink.cdc.common.data.binary
org.apache.flink.cdc.common.event.visitor
org.apache.flink.cdc.common.function
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.types.variant
org.apache.flink.cdc.common.utils
org.apache.flink.cdc.composer.flink
org.apache.flink.cdc.composer.flink.coordination
org.apache.flink.cdc.composer.flink.translator
org.apache.flink.cdc.composer.utils
org.apache.flink.cdc.connectors.base.config
org.apache.flink.cdc.connectors.base.source.meta.split
org.apache.flink.cdc.connectors.db2.source.dialect
org.apache.flink.cdc.connectors.doris.factory
org.apache.flink.cdc.connectors.fluss.sink.row
org.apache.flink.cdc.connectors.mongodb.source
org.apache.flink.cdc.connectors.mongodb.source.assigners.splitters
org.apache.flink.cdc.connectors.mongodb.source.config
org.apache.flink.cdc.connectors.mysql.factory
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.source.assigners
org.apache.flink.cdc.connectors.mysql.source.config
org.apache.flink.cdc.connectors.mysql.source.connection
org.apache.flink.cdc.connectors.mysql.source.enumerator
org.apache.flink.cdc.connectors.mysql.source.offset
org.apache.flink.cdc.connectors.mysql.source.split
org.apache.flink.cdc.connectors.oceanbase.factory
org.apache.flink.cdc.connectors.oracle.factory
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.oracle.source.assigner.splitter
org.apache.flink.cdc.connectors.oracle.source.reader.fetch
org.apache.flink.cdc.connectors.paimon.sink.v2
org.apache.flink.cdc.connectors.postgres.factory
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.postgres.source.enumerator
org.apache.flink.cdc.connectors.sqlserver.factory
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.sqlserver.source.dialect
org.apache.flink.cdc.connectors.starrocks.sink.utils
org.apache.flink.cdc.connectors.tidb.table
org.apache.flink.cdc.connectors.values
org.apache.flink.cdc.connectors.values.factory
org.apache.flink.cdc.connectors.values.sink
org.apache.flink.cdc.connectors.values.source
org.apache.flink.cdc.debezium.event
org.apache.flink.cdc.debezium.internal
org.apache.flink.cdc.debezium.table
org.apache.flink.cdc.debezium.utils
org.apache.flink.cdc.runtime.operators.schema.common
org.apache.flink.cdc.runtime.operators.schema.common.event
org.apache.flink.cdc.runtime.operators.schema.distributed
org.apache.flink.cdc.runtime.operators.schema.regular
org.apache.flink.cdc.runtime.operators.sink
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.partitioning
org.apache.flink.cdc.runtime.serializer
org.apache.flink.cdc.runtime.serializer.data
org.apache.flink.cdc.runtime.serializer.data.binary
org.apache.flink.cdc.runtime.serializer.data.writer
org.apache.flink.cdc.runtime.serializer.event
org.apache.flink.cdc.runtime.typeutils

Uses of Internal in org.apache.flink.cdc.common.annotation

Classes in org.apache.flink.cdc.common.annotation with annotations of type Internal

Modifier and Type	Class	Description
interface	Internal	Annotation to mark class and methods as an internal developer API that should not be used by users.
interface	VisibleForTesting	This annotations declares that a function, field, constructor, or entire type, is only visible for testing purposes.

Uses of Internal in org.apache.flink.cdc.common.data.binary

Classes in org.apache.flink.cdc.common.data.binary with annotations of type Internal

Modifier and Type	Interface	Description
interface	BinaryFormat	Binary format spanning MemorySegments.
class	BinaryMapData	[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
class	BinaryRecordData	An implementation of RecordData which is backed by MemorySegment instead of Object.
class	BinarySection	A basic implementation of BinaryFormat which describe a section of memory.
class	BinarySegmentUtils	Utilities for binary data segments which heavily uses MemorySegment.
class	BinaryStringData	A lazily binary implementation of StringData which is backed by MemorySegments and String.
class	LazyBinaryFormat<T>	An abstract implementation fo BinaryFormat which is lazily serialized into binary or lazily deserialized into Java object.
interface	NullAwareGetters	Provides null related getters.

Uses of Internal in org.apache.flink.cdc.common.event.visitor

Classes in org.apache.flink.cdc.common.event.visitor with annotations of type Internal

Modifier and Type	Class	Description
class	SchemaChangeEventVisitor	Visitor clas for all SchemaChangeEvents and returns a specific typed object.
interface	VisitorHandler<EVT extends SchemaChangeEvent,T,E extends Throwable>	Visitor for TruncateTableEvents.
interface	VoidVisitorHandler<EVT extends SchemaChangeEvent,E extends Throwable>	Visitor for TruncateTableEvents.

Uses of Internal in org.apache.flink.cdc.common.function

Classes in org.apache.flink.cdc.common.function with annotations of type Internal

Modifier and Type	Class	Description
class	DefaultHashContext	Default implementation of HashFunction.HashContext.
interface	HashFunction<T>	The hash function used to calculate the hash code from a given event.
static interface	HashFunction.HashContext	Runtime context for calculating an event hash code.
interface	HashFunctionProvider<T>	Provider that provides HashFunction to help PrePartitionOperator to shuffle event to designated subtask.

Uses of Internal in org.apache.flink.cdc.common.sink

Classes in org.apache.flink.cdc.common.sink with annotations of type Internal

Modifier and Type	Class	Description
class	ForwardHashFunctionProvider	A HashFunctionProvider that preserves the upstream subtask distribution.

Uses of Internal in org.apache.flink.cdc.common.types.variant

Classes in org.apache.flink.cdc.common.types.variant with annotations of type Internal

Modifier and Type	Class	Description
class	BinaryVariant	Copy from BinaryVariant.java.
class	BinaryVariantBuilder	Copy from BinaryVariantBuilder.java
class	BinaryVariantInternalBuilder	Copy from BinaryVariantBuilder.java
class	BinaryVariantUtil	Copy from BinaryVariantUtil.java

Uses of Internal in org.apache.flink.cdc.common.utils

Classes in org.apache.flink.cdc.common.utils with annotations of type Internal

Modifier and Type	Class	Description
class	StringUtf8Utils	Utilities for String UTF-8.

Uses of Internal in org.apache.flink.cdc.composer.flink

Classes in org.apache.flink.cdc.composer.flink with annotations of type Internal

Modifier and Type	Class	Description
class	FlinkEnvironmentUtils	Utilities for StreamExecutionEnvironment.
class	FlinkPipelineComposer	Composer for translating data pipeline to a Flink DataStream job.

Uses of Internal in org.apache.flink.cdc.composer.flink.coordination

Classes in org.apache.flink.cdc.composer.flink.coordination with annotations of type Internal

Modifier and Type	Class	Description
class	OperatorIDGenerator	Generating OperatorID for communication between Flink operators.

Uses of Internal in org.apache.flink.cdc.composer.flink.translator

Classes in org.apache.flink.cdc.composer.flink.translator with annotations of type Internal

Modifier and Type	Class	Description
class	DataSinkTranslator	Translator used to build DataSink for given DataStream.
class	DataSourceTranslator	Translator used to build DataSource which will generate a DataStream.
class	PartitioningTranslator	Translator used to build RegularPrePartitionOperator or DistributedPrePartitionOperator, EventPartitioner and PostPartitionProcessor that are responsible for events partition.
class	SchemaOperatorTranslator	Translator used to build SchemaOperator for schema event process.

Uses of Internal in org.apache.flink.cdc.composer.utils

Classes in org.apache.flink.cdc.composer.utils with annotations of type Internal

Modifier and Type	Class	Description
class	FactoryDiscoveryUtils	Discovery utilities for Factory.

Uses of Internal in org.apache.flink.cdc.connectors.base.config

Classes in org.apache.flink.cdc.connectors.base.config with annotations of type Internal

Modifier and Type	Class	Description
class	JdbcSourceConfigFactory	A SourceConfig.Factory to provide SourceConfig of JDBC data source.

Uses of Internal in org.apache.flink.cdc.connectors.base.source.meta.split

Constructors in org.apache.flink.cdc.connectors.base.source.meta.split with annotations of type Internal

Constructor	Description
SnapshotSplit(io.debezium.relational.TableId tableId, String splitId, org.apache.flink.table.types.logical.RowType splitKeyType, Object[] splitStart, Object[] splitEnd, Offset highWatermark, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)	This constructor should not be used directly.

Uses of Internal in org.apache.flink.cdc.connectors.db2.source.dialect

Classes in org.apache.flink.cdc.connectors.db2.source.dialect with annotations of type Internal

Modifier and Type	Class	Description
class	Db2ChunkSplitter	The splitter to split the table into chunks using primary-key (by default) or a given split key.

Uses of Internal in org.apache.flink.cdc.connectors.doris.factory

Classes in org.apache.flink.cdc.connectors.doris.factory with annotations of type Internal

Modifier and Type	Class	Description
class	DorisDataSinkFactory	A dummy DataSinkFactory to create DorisDataSink.

Uses of Internal in org.apache.flink.cdc.connectors.fluss.sink.row

Classes in org.apache.flink.cdc.connectors.fluss.sink.row with annotations of type Internal

Modifier and Type	Class	Description
class	CdcAsFlussRow	Wraps a CDC RecordData as a Fluss InternalRow.

Uses of Internal in org.apache.flink.cdc.connectors.mongodb.source

Classes in org.apache.flink.cdc.connectors.mongodb.source with annotations of type Internal

Modifier and Type	Class	Description
class	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.

Uses of Internal in org.apache.flink.cdc.connectors.mongodb.source.assigners.splitters

Classes in org.apache.flink.cdc.connectors.mongodb.source.assigners.splitters with annotations of type Internal

Modifier and Type	Class	Description
class	SampleBucketSplitStrategy	The Sample Splitter.
class	ShardedSplitStrategy	The Sharded Splitter
class	SingleSplitStrategy	The Single Partitioner
class	SplitContext	The split context used by SplitStrategy to split collection into a set of chunks for MongoDB data source.
interface	SplitStrategy	The MongoDBChunkSplitter used to split collection into a set of chunks for MongoDB data source.
class	SplitVectorSplitStrategy	The SplitVector Splitter.

Uses of Internal in org.apache.flink.cdc.connectors.mongodb.source.config

Classes in org.apache.flink.cdc.connectors.mongodb.source.config with annotations of type Internal

Modifier and Type	Class	Description
class	MongoDBSourceConfigFactory	A factory to construct MongoDBSourceConfig.

Uses of Internal in org.apache.flink.cdc.connectors.mysql.factory

Classes in org.apache.flink.cdc.connectors.mysql.factory with annotations of type Internal

Modifier and Type	Class	Description
class	MySqlDataSourceFactory	A Factory to create MySqlDataSource.

Uses of Internal in org.apache.flink.cdc.connectors.mysql.source

Classes in org.apache.flink.cdc.connectors.mysql.source with annotations of type Internal

Modifier and Type	Class	Description
class	MySqlDataSource	A DataSource for mysql cdc connector.
class	MySqlEventDeserializer	Event deserializer for MySqlDataSource.
class	MySqlMetadataAccessor	MetadataAccessor for MySqlDataSource.
class	MySqlSchemaDataTypeInference	DataType inference for MySQL debezium Schema.
class	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.

Uses of Internal in org.apache.flink.cdc.connectors.mysql.source.assigners

Classes in org.apache.flink.cdc.connectors.mysql.source.assigners with annotations of type Internal

Modifier and Type	Interface	Description
interface	MySqlSplitAssigner	The MySqlSplitAssigner is responsible for deciding what split should be processed.

Uses of Internal in org.apache.flink.cdc.connectors.mysql.source.config

Classes in org.apache.flink.cdc.connectors.mysql.source.config with annotations of type Internal

Modifier and Type	Class	Description
class	MySqlSourceConfigFactory	A factory to construct MySqlSourceConfig.

Uses of Internal in org.apache.flink.cdc.connectors.mysql.source.connection

Classes in org.apache.flink.cdc.connectors.mysql.source.connection with annotations of type Internal

Modifier and Type	Interface	Description
interface	ConnectionPools	A JDBC connection pools that consists of HikariDataSource.

Uses of Internal in org.apache.flink.cdc.connectors.mysql.source.enumerator

Classes in org.apache.flink.cdc.connectors.mysql.source.enumerator with annotations of type Internal

Modifier and Type	Class	Description
class	MySqlSourceEnumerator	A MySQL CDC source enumerator that enumerates receive the split request and assign the split to source readers.

Uses of Internal in org.apache.flink.cdc.connectors.mysql.source.offset

Classes in org.apache.flink.cdc.connectors.mysql.source.offset with annotations of type Internal

Modifier and Type	Class	Description
class	BinlogOffsetSerializer	Serializer implementation for a BinlogOffset.

Methods in org.apache.flink.cdc.connectors.mysql.source.offset with annotations of type Internal

Modifier and Type	Method	Description
static BinlogOffset	BinlogOffset.ofNonStopping()

Uses of Internal in org.apache.flink.cdc.connectors.mysql.source.split

Constructors in org.apache.flink.cdc.connectors.mysql.source.split with annotations of type Internal

Constructor	Description
MySqlSnapshotSplit(io.debezium.relational.TableId tableId, String splitId, org.apache.flink.table.types.logical.RowType splitKeyType, Object[] splitStart, Object[] splitEnd, BinlogOffset highWatermark, Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> tableSchemas)	This constructor should not be used directly.

Uses of Internal in org.apache.flink.cdc.connectors.oceanbase.factory

Classes in org.apache.flink.cdc.connectors.oceanbase.factory with annotations of type Internal

Modifier and Type	Class	Description
class	OceanBaseDataSinkFactory	A DataSinkFactory to create OceanBaseDataSink.

Uses of Internal in org.apache.flink.cdc.connectors.oracle.factory

Classes in org.apache.flink.cdc.connectors.oracle.factory with annotations of type Internal

Modifier and Type	Class	Description
class	OracleDataSourceFactory	A Factory to create OracleDataSource.

Uses of Internal in org.apache.flink.cdc.connectors.oracle.source

Classes in org.apache.flink.cdc.connectors.oracle.source with annotations of type Internal

Modifier and Type	Class	Description
class	OracleEventDeserializer	Event deserializer for OracleDataSource.
class	OracleMetadataAccessor	MetadataAccessor for OracleDataSource.
class	OracleSchemaDataTypeInference	DataType inference for oracle debezium Schema.
class	OracleSourceBuilder<T>	The builder class for OracleSourceBuilder.OracleIncrementalSource to make it easier for the users to construct a OracleSourceBuilder.OracleIncrementalSource.

Uses of Internal in org.apache.flink.cdc.connectors.oracle.source.assigner.splitter

Classes in org.apache.flink.cdc.connectors.oracle.source.assigner.splitter with annotations of type Internal

Modifier and Type	Class	Description
class	OracleChunkSplitter	The ChunkSplitter used to split Oracle table into a set of chunks for JDBC data source.

Uses of Internal in org.apache.flink.cdc.connectors.oracle.source.reader.fetch

Classes in org.apache.flink.cdc.connectors.oracle.source.reader.fetch with annotations of type Internal

Modifier and Type	Class	Description
class	EventProcessorFactory	Factory to produce a LogMinerEventProcessor with enhanced processRow method to distinguish whether is bounded.
class	OracleStreamFetchTask	The task to work for fetching data of Oracle table stream split.

Uses of Internal in org.apache.flink.cdc.connectors.paimon.sink.v2

Classes in org.apache.flink.cdc.connectors.paimon.sink.v2 with annotations of type Internal

Modifier and Type	Class	Description
class	OperatorIDGenerator	Generating OperatorID for communication between Flink operators.

Uses of Internal in org.apache.flink.cdc.connectors.postgres.factory

Classes in org.apache.flink.cdc.connectors.postgres.factory with annotations of type Internal

Modifier and Type	Class	Description
class	PostgresDataSourceFactory	A Factory to create PostgresDataSource.

Uses of Internal in org.apache.flink.cdc.connectors.postgres.source

Classes in org.apache.flink.cdc.connectors.postgres.source with annotations of type Internal

Modifier and Type	Class	Description
class	PostgresChunkSplitter	The splitter to split the table into chunks using primary-key (by default) or a given split key.
class	PostgresDataSource	A DataSource for Postgres cdc connector.
class	PostgresEventDeserializer	Event deserializer for PostgresDataSource.
class	PostgresMetadataAccessor	MetadataAccessor for PostgresDataSource.
class	PostgresSchemaDataTypeInference	DataType inference for PostgresSQL debezium Schema.

Uses of Internal in org.apache.flink.cdc.connectors.postgres.source.enumerator

Classes in org.apache.flink.cdc.connectors.postgres.source.enumerator with annotations of type Internal

Modifier and Type	Class	Description
class	PostgresSourceEnumerator	The Postgres source enumerator that enumerates receive the split request and assign the split to source readers.

Uses of Internal in org.apache.flink.cdc.connectors.sqlserver.factory

Classes in org.apache.flink.cdc.connectors.sqlserver.factory with annotations of type Internal

Modifier and Type	Class	Description
class	SqlServerDataSourceFactory	A Factory to create SqlServerDataSource.

Uses of Internal in org.apache.flink.cdc.connectors.sqlserver.source

Classes in org.apache.flink.cdc.connectors.sqlserver.source with annotations of type Internal

Modifier and Type	Class	Description
class	SqlServerDataSource	A DataSource for SQL Server CDC connector.
class	SqlServerEventDeserializer	Event deserializer for SqlServerDataSource.
class	SqlServerMetadataAccessor	MetadataAccessor for SqlServerDataSource.
class	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.
class	SqlServerSchemaDataTypeInference	DataType inference for SQL Server debezium Schema.

Uses of Internal in org.apache.flink.cdc.connectors.sqlserver.source.dialect

Classes in org.apache.flink.cdc.connectors.sqlserver.source.dialect with annotations of type Internal

Modifier and Type	Class	Description
class	SqlServerChunkSplitter	The ChunkSplitter used to split SqlServer table into a set of chunks for JDBC data source.

Uses of Internal in org.apache.flink.cdc.connectors.starrocks.sink.utils

Classes in org.apache.flink.cdc.connectors.starrocks.sink.utils with annotations of type Internal

Modifier and Type	Class	Description
class	StarRocksEscapingUtils	Utilities for escaping values embedded in double-quoted StarRocks SQL literals.

Uses of Internal in org.apache.flink.cdc.connectors.tidb.table

Classes in org.apache.flink.cdc.connectors.tidb.table with annotations of type Internal

Modifier and Type	Interface	Description
interface	TiKVMetadataConverter	A converter converts TiKV Row metadata into Flink internal data structures.

Uses of Internal in org.apache.flink.cdc.connectors.values

Classes in org.apache.flink.cdc.connectors.values with annotations of type Internal

Modifier and Type	Class	Description
class	ValuesDatabase	An auxiliary class for simulating a database, use for ValuesDataSource and ValuesDataSink.

Uses of Internal in org.apache.flink.cdc.connectors.values.factory

Classes in org.apache.flink.cdc.connectors.values.factory with annotations of type Internal

Modifier and Type	Class	Description
class	ValuesDataFactory	A dummy Factory to create ValuesDataSource and ValuesDataSink.

Uses of Internal in org.apache.flink.cdc.connectors.values.sink

Classes in org.apache.flink.cdc.connectors.values.sink with annotations of type Internal

Modifier and Type	Class	Description
class	ValuesDataSink	A DataSink for "values" connector that supports schema evolution.

Uses of Internal in org.apache.flink.cdc.connectors.values.source

Classes in org.apache.flink.cdc.connectors.values.source with annotations of type Internal

Modifier and Type	Class	Description
class	ValuesDataSource	A DataSource for "values" connector that supports schema evolution.

Uses of Internal in org.apache.flink.cdc.debezium.event

Classes in org.apache.flink.cdc.debezium.event with annotations of type Internal

Modifier and Type	Class	Description
class	DebeziumEventDeserializationSchema	Debezium event deserializer for SourceRecord.
class	DebeziumSchemaDataTypeInference	DataType inference for debezium Schema.
interface	SchemaDataTypeInference	DataType inference for kafka connect Schema.
class	SourceRecordEventDeserializer	Deserializer to deserialize SourceRecord to Event.

Uses of Internal in org.apache.flink.cdc.debezium.internal

Classes in org.apache.flink.cdc.debezium.internal with annotations of type Internal

Modifier and Type	Class	Description
class	DebeziumChangeConsumer	Consume debezium change events.
class	DebeziumChangeFetcher<T>	A Handler that convert change messages from DebeziumEngine to data in Flink.
class	DebeziumOffset	The state that the Flink Debezium Consumer holds for each instance.
class	DebeziumOffsetSerializer	Serializer implementation for a DebeziumOffset.
class	Handover	The Handover is a utility to hand over data (a buffer of records) and exception from a producer thread to a consumer thread.

Uses of Internal in org.apache.flink.cdc.debezium.table

Classes in org.apache.flink.cdc.debezium.table with annotations of type Internal

Modifier and Type	Class	Description
class	AppendMetadataCollector	Emits a row with physical fields and metadata fields.
interface	MetadataConverter	A converter converts SourceRecord metadata into Flink internal data structures.
interface	RowDataMetadataConverter	A converter converts RowData metadata into Flink internal data structures.

Uses of Internal in org.apache.flink.cdc.debezium.utils

Classes in org.apache.flink.cdc.debezium.utils with annotations of type Internal

Modifier and Type	Class	Description
class	ResolvedSchemaUtils	Utilities to ResolvedSchema.

Uses of Internal in org.apache.flink.cdc.runtime.operators.schema.common

Classes in org.apache.flink.cdc.runtime.operators.schema.common with annotations of type Internal

Modifier and Type	Class	Description
class	CoordinationResponseUtils	Utilities for wrapping and unwrapping CoordinationResponse by CollectCoordinationResponse.
class	ExistingTableSchemaExpander	Handles the initial CreateTableEvent for an existing target table according to the configured ExistingTableSchemaExpansionMode.
class	SchemaManager	Schema manager handles schema changes for tables, and manages historical schema versions of tables.
class	SchemaRegistry	An abstract centralized schema registry that accepts requests from SchemaEvolutionClient.

Uses of Internal in org.apache.flink.cdc.runtime.operators.schema.common.event

Classes in org.apache.flink.cdc.runtime.operators.schema.common.event with annotations of type Internal

Modifier and Type	Class	Description
class	GetEvolvedSchemaRequest	Request to SchemaRegistry for getting schema of a table.
class	GetEvolvedSchemaResponse	Coordination response from SchemaRegistry for GetEvolvedSchemaRequest.
class	GetOriginalSchemaRequest	Request to SchemaRegistry for getting original schema of a table.
class	GetOriginalSchemaResponse	Coordination response from SchemaRegistry for GetOriginalSchemaRequest.

Uses of Internal in org.apache.flink.cdc.runtime.operators.schema.distributed

Classes in org.apache.flink.cdc.runtime.operators.schema.distributed with annotations of type Internal

Modifier and Type	Class	Description
class	SchemaCoordinatorProvider	Provider for SchemaCoordinator.
class	SchemaOperatorFactory	Factory to create SchemaOperator.

Uses of Internal in org.apache.flink.cdc.runtime.operators.schema.regular

Classes in org.apache.flink.cdc.runtime.operators.schema.regular with annotations of type Internal

Modifier and Type	Class	Description
class	BatchSchemaOperator	The operator will apply create table event and router mapper in batch mode.
class	SchemaCoordinatorProvider	Provider of SchemaCoordinator.
class	SchemaOperator	The operator will evolve schemas in SchemaCoordinator for incoming SchemaChangeEvents and block the stream for tables before their schema changes finish.
class	SchemaOperatorFactory	Factory to create SchemaOperator.

Uses of Internal in org.apache.flink.cdc.runtime.operators.sink

Classes in org.apache.flink.cdc.runtime.operators.sink with annotations of type Internal

Modifier and Type	Class	Description
class	BatchDataSinkFunctionOperator	An operator that processes records to be written into a SinkFunction in batch mode.
class	BatchDataSinkWriterOperator<CommT>	An operator that processes records to be written into a Sink in batch mode.
class	DataSinkFunctionOperator	An operator that processes records to be written into a SinkFunction.
class	DataSinkWriterOperator<CommT>	An operator that processes records to be written into a Sink.
class	DataSinkWriterOperatorFactory<CommT>	Operator factory for DataSinkWriterOperator.

Uses of Internal in org.apache.flink.cdc.runtime.operators.transform

Classes in org.apache.flink.cdc.runtime.operators.transform with annotations of type Internal

Modifier and Type	Class	Description
class	UserDefinedFunctionDescriptor	Descriptor of a UDF function.

Uses of Internal in org.apache.flink.cdc.runtime.partitioning

Classes in org.apache.flink.cdc.runtime.partitioning with annotations of type Internal

Modifier and Type	Class	Description
class	BatchRegularPrePartitionOperator	Operator for processing events from SchemaOperator before EventPartitioner with regular topology in batch mode.
class	DistributedPrePartitionOperator	Operator for processing events from upstream before flowing to SchemaOperator.
class	EventPartitioner	Partitioner that send PartitioningEvent to its target partition.
class	PartitioningEvent	A wrapper around Event, which contains the target partition number and will be used in EventPartitioner.
class	PartitioningEventKeySelector	Key selector for PartitioningEvent.
class	PostPartitionProcessor	Function for unloading Event from internal PartitioningEvent after EventPartitioner.
class	RegularPrePartitionOperator	Operator for processing events from SchemaOperator before EventPartitioner with regular topology.

Uses of Internal in org.apache.flink.cdc.runtime.serializer

Classes in org.apache.flink.cdc.runtime.serializer with annotations of type Internal

Modifier and Type	Class	Description
class	LinkedListSerializer<T>	A serializer for LinkedList.
class	VariantSerializer	Serializer for Variant.
static class	VariantSerializer.VariantSerializerSnapshot	Snapshot class for the VariantSerializer.

Uses of Internal in org.apache.flink.cdc.runtime.serializer.data

Classes in org.apache.flink.cdc.runtime.serializer.data with annotations of type Internal

Modifier and Type	Class	Description
class	GenericRecordDataSerializer	Serializer for GenericRecordData.
class	MapDataSerializer	Serializer for MapData.

Uses of Internal in org.apache.flink.cdc.runtime.serializer.data.binary

Classes in org.apache.flink.cdc.runtime.serializer.data.binary with annotations of type Internal

Modifier and Type	Class	Description
class	BinaryRecordDataSerializer	Serializer for BinaryRecordData.

Uses of Internal in org.apache.flink.cdc.runtime.serializer.data.writer

Classes in org.apache.flink.cdc.runtime.serializer.data.writer with annotations of type Internal

Modifier and Type	Class	Description
class	BinaryArrayWriter	Writer for binary array.
class	BinaryRecordDataWriter	Writer for BinaryRecordData.
interface	BinaryWriter	Writer to write a composite data format, like row, array.

Uses of Internal in org.apache.flink.cdc.runtime.serializer.event

Classes in org.apache.flink.cdc.runtime.serializer.event with annotations of type Internal

Modifier and Type	Class	Description
class	PartitioningEventSerializer	A TypeSerializer for PartitioningEvent.

Uses of Internal in org.apache.flink.cdc.runtime.typeutils

Classes in org.apache.flink.cdc.runtime.typeutils with annotations of type Internal

Modifier and Type	Class	Description
class	PartitioningEventTypeInfo	Type information for PartitioningEvent.