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

Packages that use PublicEvolving

Package	Description
org.apache.flink.cdc.common.configuration
org.apache.flink.cdc.common.configuration.description
org.apache.flink.cdc.common.data
org.apache.flink.cdc.common.event
org.apache.flink.cdc.common.factories
org.apache.flink.cdc.common.pipeline
org.apache.flink.cdc.common.route
org.apache.flink.cdc.common.schema
org.apache.flink.cdc.common.sink
org.apache.flink.cdc.common.source
org.apache.flink.cdc.common.source.discover
org.apache.flink.cdc.common.types
org.apache.flink.cdc.common.types.variant
org.apache.flink.cdc.common.udf
org.apache.flink.cdc.common.utils
org.apache.flink.cdc.connectors.base
org.apache.flink.cdc.connectors.db2.source
org.apache.flink.cdc.connectors.mongodb.source
org.apache.flink.cdc.connectors.mongodb.table
org.apache.flink.cdc.connectors.mysql.source
org.apache.flink.cdc.connectors.mysql.source.offset
org.apache.flink.cdc.connectors.oracle.source
org.apache.flink.cdc.connectors.postgres.source
org.apache.flink.cdc.connectors.sqlserver.source
org.apache.flink.cdc.connectors.tidb
org.apache.flink.cdc.debezium
org.apache.flink.cdc.runtime.typeutils

Uses of PublicEvolving in org.apache.flink.cdc.common.configuration

Classes in org.apache.flink.cdc.common.configuration with annotations of type PublicEvolving

Modifier and Type	Class	Description
class	ConfigOption<T>	A ConfigOption describes a configuration parameter.
class	ConfigOptions	ConfigOptions are used to build a ConfigOption.

Uses of PublicEvolving in org.apache.flink.cdc.common.configuration.description

Classes in org.apache.flink.cdc.common.configuration.description with annotations of type PublicEvolving

Modifier and Type	Interface	Description
interface	BlockElement	Part of description that represents a block e.g.
class	Description	Description for ConfigOption.
static class	Description.DescriptionBuilder	Builder for Description.
class	Formatter	Allows providing multiple formatters for the description.
interface	InlineElement	Part of description that represents an element inside a block e.g.
class	LineBreakElement	Represents a line break in the Description.
class	LinkElement	Element that represents a link in the Description.
class	ListElement	Represents a list in the Description.
class	TextElement	Represents a text block in the Description.
static class	TextElement.TextStyle	Styles that can be applied to TextElement e.g.

Uses of PublicEvolving in org.apache.flink.cdc.common.data

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

Modifier and Type	Interface	Description
interface	ArrayData	Base interface of an internal data structure representing data of ArrayType.
static interface	ArrayData.ElementGetter	Accessor for getting the elements of an array during runtime.
class	DecimalData	An internal data structure representing data of DecimalType.
class	GenericArrayData	An internal data structure representing data of ArrayType.
class	GenericMapData	An internal data structure representing data of MapType.
class	GenericRecordData	An internal data structure representing data of RecordData.
class	LocalZonedTimestampData	An internal data structure representing data of LocalZonedTimestampType.
interface	MapData	Base interface of an internal data structure representing data of MapType.
interface	RecordData	Class RecordData describes the data of changed record (i.e.
static interface	RecordData.FieldGetter	Accessor for getting the field of a RecordData during runtime.
interface	StringData	An internal data structure representing data of CharType and VarCharType.
class	TimestampData	An internal data structure representing data of TimestampType.
class	ZonedTimestampData	An internal data structure representing data of ZonedTimestampType.

Uses of PublicEvolving in org.apache.flink.cdc.common.event

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

Modifier and Type	Class	Description
class	AddColumnEvent	A SchemaChangeEvent that represents an ADD COLUMN DDL, which may contain the lenient column type changes.
class	AlterColumnTypeEvent	A SchemaChangeEvent that represents an ALTER COLUMN DDL, which may contain the lenient column type changes.
class	AlterTableCommentEvent	A SchemaChangeEvent that represents an ALTER TABLE COMMENT or ALTER TABLE SET COMMENT DDL.
interface	ChangeEvent	Class ChangeEvent represents the change events of external systems, including DataChangeEvent and SchemaChangeEvent.
class	CreateTableEvent	A SchemaChangeEvent that represents an CREATE TABLE DDL.
class	DataChangeEvent	Class DataChangeEvent represents the data change events of external systems, such as INSERT, UPDATE, DELETE and so on.
class	DropColumnEvent	A SchemaChangeEvent that represents an DROP COLUMN DDL, which may contain the lenient column type changes.
class	DropTableEvent	A SchemaChangeEvent that represents an DROP TABLE DDL.
interface	Event	Class Event is the super interface defines the events of external systems flowing into Flink CDC.
interface	EventDeserializer<T>	Deserializer to deserialize given record to Event.
class	OperationType	Enum OperationType describes the type of operation that the data change event reports.
class	RenameColumnEvent	A SchemaChangeEvent that represents an RENAME COLUMN DDL, which may contain the lenient column type changes.
interface	SchemaChangeEvent	Class SchemaChangeEvent represents the changes in the table structure of the external system, such as CREATE, DROP, RENAME and so on.
class	SchemaChangeEventType	An enumeration of schema change event types for SchemaChangeEvent.
class	SchemaChangeEventTypeFamily	An enumeration of schema change event families for clustering SchemaChangeEvents into categories.
interface	SchemaChangeEventWithPreSchema	A SchemaChangeEvent that supports appending schema before change event.
class	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.
class	TruncateTableEvent	A SchemaChangeEvent that represents an TRUNCATE TABLE DDL.

Uses of PublicEvolving in org.apache.flink.cdc.common.factories

Classes in org.apache.flink.cdc.common.factories with annotations of type PublicEvolving

Modifier and Type	Interface	Description
interface	DataSinkFactory	A factory to create DataSink instances.
interface	DataSourceFactory	A factory to create DataSource instances.
interface	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.
static interface	Factory.Context	Provides session information describing the factory to be accessed.
class	FactoryHelper	A helper for working with Factory.

Uses of PublicEvolving in org.apache.flink.cdc.common.pipeline

Classes in org.apache.flink.cdc.common.pipeline with annotations of type PublicEvolving

Modifier and Type	Class	Description
class	DecimalPrecisionMode	Maximum precision mode for DECIMAL type in transform expressions.
class	HashFunctionStrategy	Partitioning strategy for DataChangeEvent in Flink CDC pipeline.
class	PipelineOptions	Predefined pipeline configuration options.
class	RouteMode	Route mode for routing rules.
class	RuntimeExecutionMode	Runtime execution mode of the pipeline includes STREAMING and BATCH, with the default value being STREAMING.
class	SchemaChangeBehavior	Behavior for handling schema changes.

Uses of PublicEvolving in org.apache.flink.cdc.common.route

Classes in org.apache.flink.cdc.common.route with annotations of type PublicEvolving

Modifier and Type	Class	Description
class	TableIdRouter	Calculates how upstream data change events should be dispatched to downstream tables.

Uses of PublicEvolving in org.apache.flink.cdc.common.schema

Classes in org.apache.flink.cdc.common.schema with annotations of type PublicEvolving

Modifier and Type	Class	Description
class	Column	Representation of a column in a Schema.
class	MetadataColumn	Representation of a metadata column.
class	PhysicalColumn	Representation of a physical column.
class	Schema	Schema of a table or data collection.
static class	Schema.Builder	A builder for constructing an immutable but still unresolved Schema.

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

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

Modifier and Type	Interface	Description
interface	DataSink	DataSink is used to write change data to external system and apply metadata changes to external systems as well.
interface	EventSinkProvider	A marker interface used to provide an event sink for writing change events to external systems.
interface	FlinkSinkFunctionProvider	FlinkSinkFunctionProvider is used to provide a Flink SinkFunction for writing events to external systems.
interface	FlinkSinkProvider	FlinkSinkProvider is used to provide a Flink Sink for writing events to external systems.
interface	MetadataApplier	MetadataApplier is used to apply metadata changes to external systems.

Uses of PublicEvolving in org.apache.flink.cdc.common.source

Classes in org.apache.flink.cdc.common.source with annotations of type PublicEvolving

Modifier and Type	Interface	Description
interface	DataSource	DataSource is used to access metadata and read change data from external systems.
interface	EventSourceProvider	A marker interface used to provide an event source for reading events from external systems.
interface	FlinkSourceFunctionProvider	FlinkSourceFunctionProvider is used to provide a Flink SourceFunction for reading events from external systems.
interface	FlinkSourceProvider	FlinkSourceProvider is used to provide a Flink Source for reading events from external systems.
interface	MetadataAccessor	MetadataAccessor is used by DataSource to access the metadata from external systems.

Uses of PublicEvolving in org.apache.flink.cdc.common.source.discover

Classes in org.apache.flink.cdc.common.source.discover with annotations of type PublicEvolving

Modifier and Type	Interface	Description
interface	ObjectIdDiscoverer<T>	Pluggable abstraction for discovering a set of object identifiers.
interface	ObjectIdDiscovererFactory<T>	SPI factory that creates an ObjectIdDiscoverer.
interface	TableDiscoverer	Table-specific specialization of ObjectIdDiscoverer whose discovered object id type is TableId.
interface	TableDiscovererFactory	Table-specific SPI factory that creates a TableDiscoverer.

Uses of PublicEvolving in org.apache.flink.cdc.common.types

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

Modifier and Type	Class	Description
class	ArrayType	Data type of an array of elements with same subtype.
class	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.
class	BinaryType	Data type of a fixed-length binary string (=a sequence of bytes).
class	BooleanType	Data type of a boolean with a (possibly) three-valued logic of TRUE, FALSE, UNKNOWN.
class	CharType	Data type of a fixed-length character string.
class	DataField	Defines the field of a row type.
class	DataTypeDefaultVisitor<R>	Implementation of DataTypeVisitor that redirects all calls to DataTypeDefaultVisitor.defaultMethod(DataType).
class	DataTypeFamily	An enumeration of data type families for clustering DataTypeRoots into categories.
class	DataTypeRoot	An enumeration of data type roots containing static information about fata data types.
class	DataTypes	A DataType can be used to declare input and/or output types of operations.
interface	DataTypeVisitor<R>	The visitor definition of DataType.
class	DateType	Data type of a date consisting of year-month-day with values ranging from 0000-01-01 to 9999-12-31.
class	DecimalType	Data type of a decimal number with fixed precision and scale.
class	DoubleType	Data type of an 8-byte double precision floating point number.
class	FloatType	Data type of a 4-byte single precision floating point number.
class	IntType	Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
class	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.
class	MapType	Data type of an associative array that maps keys (including NULL) to values (including NULL).
class	RowType	Data type of a sequence of fields.
class	SmallIntType	Data type of a 2-byte signed integer with values from -32,768 to 32,767.
class	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.
class	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.
class	TinyIntType	Data type of a 1-byte signed integer with values from -128 to 127.
class	VarBinaryType	Data type of a variable-length binary string (=a sequence of bytes).
class	VarCharType	Data type of a variable-length character string.
class	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.

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

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

Modifier and Type	Class	Description
static class	BinaryVariantBuilder.VariantArrayBuilder	Builder for a variant array.
static class	BinaryVariantBuilder.VariantObjectBuilder	Builder for a variant object.
interface	Variant	Copy from Variant.java
static class	Variant.Type	The type of variant.
interface	VariantBuilder	Copy from VariantBuilder.java
static interface	VariantBuilder.VariantArrayBuilder	Builder for a variant array.
static interface	VariantBuilder.VariantObjectBuilder	Builder for a variant object.
class	VariantTypeException	Copy from VariantTypeException.java

Uses of PublicEvolving in org.apache.flink.cdc.common.udf

Classes in org.apache.flink.cdc.common.udf with annotations of type PublicEvolving

Modifier and Type	Interface	Description
interface	UserDefinedFunction	Base interface for creating a UDF in transform projection and filtering expressions.

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

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

Modifier and Type	Class	Description
class	SchemaMergingUtils	Utils for merging Schemas and DataTypes.
class	SchemaUtils	Utils for Schema to perform the ability of evolution.

Uses of PublicEvolving in org.apache.flink.cdc.connectors.base

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

Modifier and Type	Interface	Description
interface	WatermarkDispatcher	CDC event dispatcher which provides ability to dispatch watermark.

Uses of PublicEvolving in org.apache.flink.cdc.connectors.db2.source

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

Modifier and Type	Class	Description
class	Db2SourceBuilder<T>	The builder class for Db2SourceBuilder.Db2IncrementalSource to make it easier for the users to construct a Db2SourceBuilder.Db2IncrementalSource.

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

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

Modifier and Type	Class	Description
class	MongoDBSourceBuilder<T>	The builder class for MongoDBSource to make it easier for the users to construct a MongoDBSource.

Methods in org.apache.flink.cdc.connectors.mongodb.source with annotations of type PublicEvolving

Modifier and Type	Method	Description
static <T> MongoDBSourceBuilder<T>	MongoDBSource.builder()	Get a MongoDBSourceBuilder to build a MongoDBSource.

Uses of PublicEvolving in org.apache.flink.cdc.connectors.mongodb.table

Classes in org.apache.flink.cdc.connectors.mongodb.table with annotations of type PublicEvolving

Modifier and Type	Class	Description
class	MongoDBConnectorDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data structure RowData.
class	MongoDBConnectorFullChangelogDeserializationSchema	Deserialization schema from Mongodb ChangeStreamDocument to Flink Table/SQL internal data that produces full changelog mode structure RowData.

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

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

Modifier and Type	Class	Description
class	MySqlDataSourceOptions	Configurations for MySqlDataSource.
class	MySqlSourceBuilder<T>	The builder class for MySqlSource to make it easier for the users to construct a MySqlSource.

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

Modifier and Type	Method	Description
static <T> MySqlSourceBuilder<T>	MySqlSource.builder()	Get a MySqlParallelSourceBuilder to build a MySqlSource.

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

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

Modifier and Type	Class	Description
class	BinlogOffset	A structure describes a fine grained offset in a binlog event including binlog position and gtid set etc.

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

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

Modifier and Type	Class	Description
class	OracleDataSourceOptions	Configurations for OracleDataSource.

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

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

Modifier and Type	Class	Description
class	PostgresDataSourceOptions	Configurations for PostgresDataSource.

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

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

Modifier and Type	Class	Description
class	SqlServerDataSourceOptions	Configurations for SqlServerDataSource.

Uses of PublicEvolving in org.apache.flink.cdc.connectors.tidb

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

Modifier and Type	Interface	Description
interface	TiKVChangeEventDeserializationSchema<T>	The deserialization schema describes how to turn the TiKV Change Event into data types (Java/Scala objects) that are processed by Flink.
interface	TiKVSnapshotEventDeserializationSchema<T>	The deserialization schema describes how to turn the TiKV snapshot event into data types (Java/Scala objects) that are processed by Flink.

Uses of PublicEvolving in org.apache.flink.cdc.debezium

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

Modifier and Type	Interface	Description
interface	DebeziumDeserializationSchema<T>	The deserialization schema describes how to turn the Debezium SourceRecord into data types (Java/Scala objects) that are processed by Flink.
class	DebeziumSourceFunction<T>	The DebeziumSourceFunction is a streaming data source that pulls captured change data from databases into Flink.

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

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

Modifier and Type	Class	Description
class	BinaryRecordDataGenerator	This class is used to create BinaryRecordData.