Deprecated API

Contents

• Classes
• Fields
• Methods
• Constructors
• Enum Constants

Classes

Class	Description
org.apache.doris.flink.sink.batch.DorisBatchSink
org.apache.flink.cdc.connectors.mongodb.MongoDBSource
org.apache.flink.cdc.connectors.mysql.MySqlSource	please use MySqlSource instead which supports more rich features, e.g. parallel reading from historical data. The MySqlSource will be dropped in the future version.
org.apache.flink.cdc.connectors.mysql.MySqlSource.Builder	please use MySqlSource.builder() instead which supports more rich features, e.g. parallel reading from historical data. The MySqlSource.Builder will be dropped in the future version.
org.apache.flink.cdc.connectors.postgres.PostgreSQLSource
org.apache.flink.cdc.connectors.sqlserver.SqlServerSource

Fields

Field	Description
org.apache.flink.cdc.common.pipeline.PipelineOptions.PIPELINE_SCHEMA_OPERATOR_UID

Methods

Method	Description
org.apache.flink.cdc.common.udf.UserDefinedFunction.getReturnType()	Use UserDefinedFunction.getReturnType(UserDefinedFunctionContext) instead.
org.apache.flink.cdc.common.udf.UserDefinedFunction.open()	Use UserDefinedFunction.open(UserDefinedFunctionContext) instead.
org.apache.flink.cdc.common.utils.SchemaUtils.getNumericPrecision(DataType)
org.apache.flink.cdc.common.utils.SchemaUtils.inferWiderColumn(Column, Column)	Use getLeastCommonType in SchemaMergingUtils instead.
org.apache.flink.cdc.common.utils.SchemaUtils.inferWiderSchema(List<Schema>)	Use getCommonSchema in SchemaMergingUtils instead.
org.apache.flink.cdc.common.utils.SchemaUtils.inferWiderType(DataType, DataType)	Use getLeastCommonType in SchemaMergingUtils instead.
org.apache.flink.cdc.composer.definition.ModelDef.getClassName()	Factory-based models use ModelDef.getType().
org.apache.flink.cdc.composer.definition.ModelDef.getModelName()	Use ModelDef.getName().
org.apache.flink.cdc.composer.definition.ModelDef.getParameters()	Use ModelDef.getOptions().
org.apache.flink.cdc.composer.flink.translator.SchemaOperatorTranslator.getSchemaOperatorUid()
org.apache.flink.cdc.connectors.base.dialect.DataSourceDialect.createChunkSplitter(C)
org.apache.flink.cdc.connectors.fluss.sink.v2.FlussSink.createWriter(Sink.InitContext)
org.apache.flink.cdc.connectors.iceberg.sink.v2.IcebergSink.createWriter(Sink.InitContext)
org.apache.flink.cdc.connectors.mongodb.MongoDBSource.Builder.copyExisting(boolean)	please use startupOptions instead.
org.apache.flink.cdc.connectors.mongodb.MongoDBSource.Builder.copyExistingMaxThreads(int)	use initialSnapshottingMaxThreads instead.
org.apache.flink.cdc.connectors.mongodb.MongoDBSource.Builder.copyExistingPipeline(String)	use initialSnapshottingPipeline instead.
org.apache.flink.cdc.connectors.mongodb.MongoDBSource.Builder.copyExistingQueueSize(int)	use initialSnapshottingQueueSize instead.
org.apache.flink.cdc.connectors.mongodb.source.dialect.MongoDBDialect.createChunkSplitter(MongoDBSourceConfig)
org.apache.flink.cdc.connectors.mysql.source.config.MySqlSourceConfig.getTableFilters()
org.apache.flink.cdc.connectors.paimon.sink.v2.PaimonSink.createWriter(Sink.InitContext)
org.apache.flink.cdc.runtime.serializer.data.writer.BinaryArrayWriter.setNullAt(int, DataType)	Use BinaryArrayWriter.createNullSetter(DataType) for avoiding logical types during runtime.
org.apache.flink.cdc.runtime.serializer.NestedSerializersSnapshotDelegate.resolveCompatibilityWithNested(TypeSerializerSchemaCompatibility<?>, TypeSerializer<?>...)	this no method will be removed in the future. Resolving compatibility for nested serializers is now handled by CompositeTypeSerializerSnapshot.

Constructors

Constructor	Description
org.apache.flink.cdc.composer.definition.ModelDef(String, String, Map<String, String>)	Use ModelDef.of(String, String, Map) for factory-based AI model clients.

Enum Constants

Enum Constant	Description
org.apache.flink.cdc.connectors.maxcompute.options.CompressAlgorithm.SNAPPY