Deprecated API

Contents

• Interfaces
• Classes
• Enums
• Exceptions
• Fields
• Methods
• Constructors
• Enum Constants

Interfaces

Interface	Description
org.apache.flink.contrib.streaming.state.ConfigurableRocksDBOptionsFactory	This class has been moved to ConfigurableRocksDBOptionsFactory. Please use the one under the new package instead.
org.apache.flink.contrib.streaming.state.RocksDBOptionsFactory	This class has been moved to RocksDBOptionsFactory. Please use the one under the new package instead.
org.apache.flink.legacy.table.connector.source.SourceFunctionProvider	This interface is based on the SourceFunction API, which is due to be removed. Use SourceProvider instead.
org.apache.flink.legacy.table.factories.StreamTableSinkFactory	This interface has been replaced by DynamicTableSinkFactory. The new interface creates instances of DynamicTableSink. See FLIP-95 for more information.
org.apache.flink.legacy.table.factories.StreamTableSourceFactory	This interface has been replaced by DynamicTableSourceFactory. The new interface creates instances of DynamicTableSource. See FLIP-95 for more information.
org.apache.flink.legacy.table.sinks.AppendStreamTableSink	This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.legacy.table.sinks.RetractStreamTableSink	This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.legacy.table.sinks.StreamTableSink	This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.legacy.table.sinks.UpsertStreamTableSink	This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.legacy.table.sources.StreamTableSource	This interface has been replaced by DynamicTableSource. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.streaming.api.checkpoint.ExternallyInducedSource	This interface is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.checkpoint.ListCheckpointed	If you need to do non-keyed state snapshots of your operator, use CheckpointedFunction. This should only be needed in rare cases, though.
org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction	This interface will be removed in future versions. Use the new Sink interface instead.
org.apache.flink.streaming.api.functions.source.legacy.ParallelSourceFunction	This interface is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.SourceFunction	This interface will be removed in future versions. Use the new Source interface instead. NOTE: All sub-tasks from FLINK-28045 must be closed before this API can be completely removed.
org.apache.flink.streaming.api.operators.legacy.YieldingOperatorFactory
org.apache.flink.table.catalog.CatalogLock	This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.catalog.CatalogLock.Factory	This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.connector.RequireCatalogLock	This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.connector.sink.legacy.SinkFunctionProvider	This interface is based on the SinkFunction API, which is due to be removed. Use SinkV2Provider instead.
org.apache.flink.table.descriptors.DescriptorValidator	See Descriptor for details.
org.apache.flink.table.factories.ManagedTableFactory	This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.legacy.api.constraints.Constraint	See ResolvedSchema and Constraint.
org.apache.flink.table.legacy.connector.source.AsyncTableFunctionProvider	Please use AsyncLookupFunctionProvider to implement asynchronous lookup table.
org.apache.flink.table.legacy.connector.source.TableFunctionProvider	Please use LookupFunctionProvider to implement synchronous lookup table.
org.apache.flink.table.legacy.descriptors.Descriptor	Descriptor was primarily used for the legacy connector stack and have been deprecated. Use TableDescriptor for creating sources and sinks from the Table API.
org.apache.flink.table.legacy.factories.TableFactory	This interface has been replaced by Factory.
org.apache.flink.table.legacy.factories.TableSinkFactory	This interface has been replaced by DynamicTableSinkFactory. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.table.legacy.factories.TableSourceFactory	This interface has been replaced by DynamicTableSourceFactory. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.table.legacy.sinks.OverwritableTableSink	This interface will not be supported in the new sink design around DynamicTableSink. Use SupportsOverwrite instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sinks.PartitionableTableSink	This interface will not be supported in the new sink design around DynamicTableSink. Use SupportsPartitioning instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sinks.TableSink	This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.DefinedFieldMapping	This interface will not be supported in the new source design around DynamicTableSource. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.DefinedProctimeAttribute	This interface will not be supported in the new source design around DynamicTableSource. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.DefinedRowtimeAttributes	This interface will not be supported in the new source design around DynamicTableSource. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.FieldComputer	This interface will not be supported in the new source design around DynamicTableSource. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.FilterableTableSource	This interface will not be supported in the new source design around DynamicTableSource. Use SupportsFilterPushDown instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.LimitableTableSource	This interface will not be supported in the new source design around DynamicTableSource. Use SupportsLimitPushDown instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.LookupableTableSource	This interface will not be supported in the new source design around DynamicTableSource. Use LookupTableSource instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.NestedFieldsProjectableTableSource	This interface will not be supported in the new source design around DynamicTableSource. Use SupportsProjectionPushDown instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.PartitionableTableSource	This interface will not be supported in the new source design around DynamicTableSource. Use SupportsPartitionPushDown instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.ProjectableTableSource	This interface will not be supported in the new source design around DynamicTableSource. Use SupportsProjectionPushDown instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.TableSource	This interface has been replaced by DynamicTableSource. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.table.runtime.groupwindow.WindowProperty	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.types.Key	The Key type is a relict of a deprecated and removed API and will be removed in future (2.0) versions as well.

Classes

Class	Description
org.apache.calcite.rex.RexUtil.ExprSimplifier
org.apache.flink.client.deployment.executors.AbstractJobClusterExecutor
org.apache.flink.configuration.QueryableStateOptions	The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackend	This class has been moved to EmbeddedRocksDBStateBackend. Please use the one under the new package instead.
org.apache.flink.contrib.streaming.state.EmbeddedRocksDBStateBackendFactory	This class has been moved to EmbeddedRocksDBStateBackendFactory. Please use the one under the new package instead.
org.apache.flink.contrib.streaming.state.RocksDBConfigurableOptions	This class has been moved to RocksDBConfigurableOptions. Please use the one under the new package instead.
org.apache.flink.contrib.streaming.state.RocksDBNativeMetricOptions	This class has been moved to RocksDBNativeMetricOptions. Please use the one under the new package instead.
org.apache.flink.contrib.streaming.state.RocksDBOptions	This class has been moved to RocksDBNativeMetricOptions. Please use the one under the new package instead.
org.apache.flink.core.testutils.FlinkMatchers	You should assertj assertions, which have built-in assertions for CompletableFuture. To check chains of Throwable causes, use FlinkAssertions.anyCauseMatches(String) or FlinkAssertions.anyCauseMatches(Class, String)
org.apache.flink.legacy.table.descriptors.RowtimeValidator	See Rowtime for details.
org.apache.flink.legacy.table.descriptors.SchemaValidator	See Schema for details.
org.apache.flink.legacy.table.sinks.OutputFormatTableSink	This interface has been replaced by DynamicTableSink. The new interface consumes internal data structures. See FLIP-95 for more information.
org.apache.flink.legacy.table.sources.InputFormatTableSource	This interface has been replaced by DynamicTableSource. The new interface produces internal data structures. See FLIP-95 for more information.
org.apache.flink.queryablestate.client.QueryableStateClient	The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.runtime.checkpoint.SubtaskState	Internal class for savepoint backwards compatibility. Don't use for other purposes.
org.apache.flink.runtime.checkpoint.TaskState	Internal class for savepoint backwards compatibility. Don't use for other purposes.
org.apache.flink.runtime.entrypoint.JobClusterEntrypoint	Per-job mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.
org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler	This class is subsumed by SubtaskMetricsHandler and is only kept for backwards-compatibility.
org.apache.flink.runtime.rest.messages.YarnCancelJobTerminationHeaders	This should be removed once we can send arbitrary REST calls via the Yarn proxy.
org.apache.flink.runtime.rest.messages.YarnStopJobTerminationHeaders	This should be removed once we can send arbitrary REST calls via the Yarn proxy.
org.apache.flink.runtime.state.filesystem.AbstractFileStateBackend	State backends should no longer implement CheckpointStorage functionality. Please inherit AbstractStateBackend instead. Custom checkpoint storage can be additionally implemented as a separate class.
org.apache.flink.streaming.api.datastream.QueryableStateStream	The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.streaming.api.functions.sink.filesystem.legacy.StreamingFileSink	Use FileSink instead.
org.apache.flink.streaming.api.functions.sink.legacy.DiscardingSink	This interface will be removed in future versions. Use the new DiscardingSink interface instead.
org.apache.flink.streaming.api.functions.sink.legacy.OutputFormatSinkFunction	Please use the StreamingFileSink for writing to files from a streaming program.
org.apache.flink.streaming.api.functions.sink.legacy.PrintSinkFunction	This interface will be removed in future versions. Use the new PrintSink interface instead.
org.apache.flink.streaming.api.functions.sink.legacy.RichSinkFunction	This interface will be removed in future versions. Use the new Sink interface instead.
org.apache.flink.streaming.api.functions.sink.legacy.SocketClientSink	This interface will be removed in future versions. Use the new Sink interface instead.
org.apache.flink.streaming.api.functions.sink.legacy.TwoPhaseCommitSinkFunction	This interface will be removed in future versions. Use the new Sink interface instead.
org.apache.flink.streaming.api.functions.source.datagen.DataGeneratorSource	Use org.apache.flink.connector.datagen.source.DataGeneratorSource instead.
org.apache.flink.streaming.api.functions.source.legacy.ContinuousFileMonitoringFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.FileMonitoringFunction	Internal class deprecated in favour of ContinuousFileMonitoringFunction.
org.apache.flink.streaming.api.functions.source.legacy.FileReadFunction	Internal class deprecated in favour of ContinuousFileMonitoringFunction.
org.apache.flink.streaming.api.functions.source.legacy.FromElementsFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.FromIteratorFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.FromSplittableIteratorFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.InputFormatSourceFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.RichParallelSourceFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.RichSourceFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.SocketTextStreamFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.source.legacy.StatefulSequenceSource	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.functions.timestamps.AscendingTimestampExtractor
org.apache.flink.streaming.api.legacy.io.TextInputFormat	If you want to read/write data from/to text file, please use FLIP-27 FileSource and Sink-V2 FlinkSink. This class should be removed if we drop the supports for read/write via input/output format in DataStream api.
org.apache.flink.streaming.api.legacy.io.TextOutputFormat	If you want to read/write data from/to text file, please use FLIP-27 FileSource and Sink-V2 FlinkSink. This class should be removed if we drop all supports for InputFormat and OutputFormat
org.apache.flink.streaming.api.operators.co.LegacyKeyedCoProcessOperator	Replaced by KeyedCoProcessOperator which takes KeyedCoProcessFunction
org.apache.flink.streaming.api.operators.LegacyKeyedProcessOperator	Replaced by KeyedProcessOperator which takes KeyedProcessFunction
org.apache.flink.streaming.api.operators.StreamSource	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.api.operators.StreamSourceContexts	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.runtime.tasks.SourceStreamTask	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor.SynchronizedStreamTaskActionExecutor	this class should only be used in SourceStreamTask which exposes the checkpoint lock as part of Public API.
org.apache.flink.streaming.tests.SequenceGeneratorSource	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.table.catalog.CatalogTableImpl	Use CatalogTable.of(Schema, String, List, Map) or a custom implementation instead. Don't implement against this internal class. It can lead to unintended side effects if code checks against this class instead of the common interface.
org.apache.flink.table.catalog.CatalogViewImpl	Use CatalogView.of(Schema, String, String, String, Map) or a custom implementation instead. Don't implement against this internal class. It can lead to unintended side effects if code checks against this class instead of the common interface.
org.apache.flink.table.catalog.ManagedTableListener	This interface will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.dataview.ListViewSerializer
org.apache.flink.table.dataview.ListViewSerializerSnapshot
org.apache.flink.table.dataview.ListViewTypeInfo
org.apache.flink.table.dataview.ListViewTypeInfoFactory
org.apache.flink.table.dataview.MapViewSerializer
org.apache.flink.table.dataview.MapViewSerializerSnapshot
org.apache.flink.table.dataview.MapViewTypeInfo
org.apache.flink.table.dataview.MapViewTypeInfoFactory
org.apache.flink.table.dataview.NullAwareMapSerializer
org.apache.flink.table.dataview.NullAwareMapSerializerSnapshot
org.apache.flink.table.descriptors.ConnectorDescriptorValidator
org.apache.flink.table.descriptors.DescriptorProperties	This utility will be dropped soon. DynamicTableFactory is based on ConfigOption and catalogs use CatalogPropertiesUtil.
org.apache.flink.table.descriptors.FileSystemValidator	The legacy CSV connector has been replaced by FileSource / FileSink. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.descriptors.OldCsvValidator	Use the RFC-compliant Csv format in the dedicated flink-formats/flink-csv module instead.
org.apache.flink.table.factories.TableFactoryService
org.apache.flink.table.factories.TableSinkFactoryContextImpl
org.apache.flink.table.factories.TableSourceFactoryContextImpl
org.apache.flink.table.functions.AggregateFunctionDefinition	Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.table.functions.LegacyUserDefinedFunctionInference
org.apache.flink.table.functions.ScalarFunctionDefinition	Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.table.functions.TableAggregateFunctionDefinition	Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.table.functions.TableFunctionDefinition	Non-legacy functions can simply omit this wrapper for declarations.
org.apache.flink.table.legacy.api.constraints.UniqueConstraint	See ResolvedSchema and UniqueConstraint.
org.apache.flink.table.legacy.api.TableColumn	See ResolvedSchema and Column.
org.apache.flink.table.legacy.api.TableSchema	This class has been deprecated as part of FLIP-164. It has been replaced by two more dedicated classes Schema and ResolvedSchema. Use Schema for declaration in APIs. ResolvedSchema is offered by the framework after resolution and validation.
org.apache.flink.table.legacy.api.Types	This class will be removed in future versions as it uses the old type system. It is recommended to use DataTypes instead which uses the new type system based on instances of DataType. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.legacy.api.WatermarkSpec	See ResolvedSchema and WatermarkSpec.
org.apache.flink.table.legacy.descriptors.Rowtime	This class was used for legacy connectors using Descriptor.
org.apache.flink.table.legacy.descriptors.Schema	This class was used for legacy connectors using Descriptor.
org.apache.flink.table.legacy.operations.ddl.AlterTableOptionsOperation	Please use AlterTableChangeOperation instead.
org.apache.flink.table.legacy.sources.RowtimeAttributeDescriptor	This interface will not be supported in the new source design around DynamicTableSource. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.tsextractors.ExistingField	This class will not be supported in the new source design around DynamicTableSource. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.tsextractors.StreamRecordTimestamp	This class will not be supported in the new source design around DynamicTableSource. See FLIP-95 for more information.
org.apache.flink.table.legacy.sources.tsextractors.TimestampExtractor	This interface will not be supported in the new source design around DynamicTableSource. Use the concept of computed columns instead. See FLIP-95 for more information.
org.apache.flink.table.legacy.types.logical.TypeInformationRawType	Use RawType instead.
org.apache.flink.table.legacy.utils.TypeStringUtils	This utility is based on TypeInformation. However, the Table & SQL API is currently updated to use DataTypes based on LogicalTypes. Use LogicalTypeParser instead.
org.apache.flink.table.operations.DataStreamQueryOperation
org.apache.flink.table.planner.operations.InternalDataStreamQueryOperation
org.apache.flink.table.runtime.arrow.sources.ArrowSourceFunction	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.table.runtime.groupwindow.AbstractWindowProperty	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.NamedWindowProperty	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.ProctimeAttribute	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.RowtimeAttribute	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.SliceEnd	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.WindowEnd	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.WindowReference	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they are also used to configure Python operators.
org.apache.flink.table.runtime.groupwindow.WindowStart	The POJOs in this package are used to represent the deprecated Group Window feature. Currently, they also used to configure Python operators.
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter
org.apache.flink.table.runtime.types.TypeInfoDataTypeConverter	Use InternalTypeInfo.of(LogicalType) instead if TypeInformation is really required. In many cases, InternalSerializers.create(LogicalType) should be sufficient.
org.apache.flink.table.runtime.types.TypeInfoLogicalTypeConverter
org.apache.flink.table.sinks.CsvAppendTableSinkFactory	The legacy CSV connector has been replaced by FileSink. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sinks.CsvBatchTableSinkFactory	The legacy CSV connector has been replaced by FileSink. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sinks.CsvTableSink	The legacy CSV connector has been replaced by FileSink. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sinks.CsvTableSinkFactoryBase	The legacy CSV connector has been replaced by FileSink. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sinks.TableSinkBase	This class is implementing the deprecated TableSink interface. Implement DynamicTableSink directly instead.
org.apache.flink.table.sources.CsvAppendTableSourceFactory	The legacy CSV connector has been replaced by FileSource. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.CsvBatchTableSourceFactory	The legacy CSV connector has been replaced by FileSource. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.CsvTableSource	The legacy CSV connector has been replaced by FileSource. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.CsvTableSourceFactoryBase	The legacy CSV connector has been replaced by FileSource. It is kept only to support tests for the legacy connector stack.
org.apache.flink.table.sources.format.CsvInputFormat
org.apache.flink.table.sources.format.RowCsvInputFormat	All Flink DataSet APIs are deprecated since Flink 1.18 and will be removed in a future Flink major version. You can still build your application in DataSet, but you should move to either the DataStream and/or Table API.
org.apache.flink.table.types.utils.LegacyTypeInfoDataTypeConverter	Use DataTypeFactory.createDataType(TypeInformation) instead. Note that this method will not create legacy types anymore. It fully uses the new type system available only in the planner.
org.apache.flink.table.typeutils.TimeIndicatorTypeInfo	This class will be removed in future versions as it is used for the old type system. It is recommended to use DataTypes instead. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.typeutils.TimeIntervalTypeInfo	This class will be removed in future versions as it is used for the old type system. It is recommended to use DataTypes instead. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.test.util.AbstractTestBaseJUnit4	Use AbstractTestBase instead.
org.apache.flink.test.util.JavaProgramTestBaseJUnit4	Use JavaProgramTestBase instead.
org.apache.flink.test.util.MultipleProgramsTestBaseJUnit4	Use MultipleProgramsTestBase instead.
org.apache.flink.walkthrough.common.sink.AlertSink
org.apache.flink.walkthrough.common.source.TransactionSource	This class is based on the SourceFunction API, which is due to be removed. Use the new Source API instead.
org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint	Per-mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.
org.apache.flink.yarn.executors.YarnJobClusterExecutor
org.apache.flink.yarn.executors.YarnJobClusterExecutorFactory

Enums

Enum	Description
org.apache.flink.streaming.api.CheckpointingMode	This class has been moved to CheckpointingMode.
org.apache.flink.table.api.config.ExecutionConfigOptions.LegacyCastBehaviour

Exceptions

Exceptions	Description
org.apache.flink.table.api.AmbiguousTableFactoryException	This exception is considered internal and has been erroneously placed in the *.api package. It is replaced by AmbiguousTableFactoryException and should not be used directly anymore.
org.apache.flink.table.api.ExpressionParserException	This exception is considered internal and has been erroneously placed in the *.api package. It is replaced by ExpressionParserException and should not be used directly anymore.
org.apache.flink.table.api.NoMatchingTableFactoryException	This exception is considered internal and has been erroneously placed in the *.api package. It is replaced by NoMatchingTableFactoryException and should not be used directly anymore.

Fields

Field	Description
org.apache.calcite.rex.RexUtil.SubQueryFinder.FILTER_PREDICATE
org.apache.calcite.rex.RexUtil.SubQueryFinder.JOIN_PREDICATE
org.apache.calcite.rex.RexUtil.SubQueryFinder.PROJECT_PREDICATE
org.apache.calcite.sql2rel.SqlToRelConverter.DEFAULT_IN_SUBQUERY_THRESHOLD
org.apache.flink.api.common.state.StateDescriptor.defaultValue	To make the semantics more clear, user should manually manage the default value if the contents of the state is null
org.apache.flink.client.cli.CliFrontendParser.SAVEPOINT_RESTORE_MODE
org.apache.flink.configuration.JobManagerOptions.MIN_PARALLELISM_INCREASE	Use JobManagerOptions.SCHEDULER_EXECUTING_COOLDOWN_AFTER_RESCALING and JobManagerOptions.SCHEDULER_EXECUTING_RESOURCE_STABILIZATION_TIMEOUT.
org.apache.flink.configuration.JobManagerOptions.RESOURCE_STABILIZATION_TIMEOUT	Use JobManagerOptions.SCHEDULER_SUBMISSION_RESOURCE_STABILIZATION_TIMEOUT.
org.apache.flink.configuration.JobManagerOptions.RESOURCE_WAIT_TIMEOUT	Use JobManagerOptions.SCHEDULER_SUBMISSION_RESOURCE_WAIT_TIMEOUT.
org.apache.flink.configuration.JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MAX	Use JobManagerOptions.SCHEDULER_EXECUTING_RESOURCE_STABILIZATION_TIMEOUT.
org.apache.flink.configuration.JobManagerOptions.SCHEDULER_SCALING_INTERVAL_MIN	Use JobManagerOptions.SCHEDULER_EXECUTING_COOLDOWN_AFTER_RESCALING
org.apache.flink.configuration.TraceOptions.REPORT_EVENTS_AS_SPANS
org.apache.flink.table.api.dataview.ListView.elementType
org.apache.flink.table.api.dataview.MapView.keyType
org.apache.flink.table.api.dataview.MapView.valueType
org.apache.flink.table.codesplit.JavaLexer.tokenNames	Use JavaLexer.VOCABULARY instead.
org.apache.flink.table.codesplit.JavaParser.tokenNames	Use JavaParser.VOCABULARY instead.
org.apache.flink.table.legacy.descriptors.Schema.SCHEMA_TYPE	Schema uses the legacy type key (e.g. schema.0.type = LONG) to store type information in prior v1.9. Since v1.10, Schema uses data type key (e.g. schema.0.data-type = BIGINT) to store types.
org.apache.flink.table.module.CommonModuleOptions.MODULE_TYPE	This is only required for the legacy factory stack

Methods

Method	Description
org.apache.calcite.rex.RexUtil.createStructType(RelDataTypeFactory, List<? extends RexNode>, List<String>)
org.apache.calcite.rex.RexUtil.eq(RexNode, RexNode)
org.apache.calcite.rex.RexUtil.fixUp(RexBuilder, List<RexNode>, RelDataType)
org.apache.calcite.rex.RexUtil.notFn(RexBuilder)	Use RexUtil.not(org.apache.calcite.rex.RexNode)
org.apache.calcite.rex.RexUtil.simplify(RexBuilder, RexNode)	Create a RexSimplify, then call its RexSimplify.simplify(RexNode, RexUnknownAs) method.
org.apache.calcite.rex.RexUtil.simplifyAnd(RexBuilder, RexCall, boolean)
org.apache.calcite.rex.RexUtil.simplifyAnd2(RexBuilder, List<RexNode>, List<RexNode>)
org.apache.calcite.rex.RexUtil.simplifyAnd2ForUnknownAsFalse(RexBuilder, List<RexNode>, List<RexNode>)
org.apache.calcite.rex.RexUtil.simplifyAnds(RexBuilder, Iterable<? extends RexNode>)	Use RexSimplify.simplifyAnds(Iterable, RexUnknownAs).
org.apache.calcite.rex.RexUtil.simplifyOr(RexBuilder, RexCall)
org.apache.calcite.rex.RexUtil.simplifyOrs(RexBuilder, List<RexNode>)
org.apache.calcite.rex.RexUtil.simplifyPreservingType(RexBuilder, RexNode)	Use RexSimplify.simplifyPreservingType(RexNode), which allows you to specify an RexExecutor.
org.apache.calcite.sql.validate.SqlValidatorImpl.isAggregate(SqlNode)
org.apache.calcite.sql2rel.RelDecorrelator.decorrelateQuery(RelNode)
org.apache.calcite.sql2rel.SqlToRelConverter.Blackboard.convertSortExpression(SqlNode, RelFieldCollation.Direction, RelFieldCollation.NullDirection)
org.apache.calcite.sql2rel.SqlToRelConverter.enableDecorrelation()
org.apache.calcite.sql2rel.SqlToRelConverter.getInSubqueryThreshold()
org.apache.calcite.sql2rel.SqlToRelConverter.isTrimUnusedFields()
org.apache.calcite.tools.RelBuilder.aggregateCall(SqlAggFunction, boolean, RexNode, String, RexNode...)
org.apache.calcite.tools.RelBuilder.groupKey(Iterable<? extends RexNode>, boolean, Iterable<? extends Iterable<? extends RexNode>>)	Now that indicator is deprecated, use RelBuilder.groupKey(Iterable, Iterable), which has the same behavior as calling this method with indicator = false.
org.apache.flink.api.common.state.StateDescriptor.getQueryableStateName()	The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.api.common.state.StateDescriptor.isQueryable()	The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.api.common.state.StateDescriptor.setQueryable(String)	The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot.isOuterSnapshotCompatible(S)	this method is deprecated, and will be removed in the future. Please implement CompositeTypeSerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot) instead.
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot.resolveOuterSchemaCompatibility(S)	this method is deprecated, and will be removed in the future. Please implement CompositeTypeSerializerSnapshot.resolveOuterSchemaCompatibility(TypeSerializerSnapshot) instead.
org.apache.flink.client.deployment.ClusterDescriptor.deployJobCluster(ClusterSpecification, JobGraph, boolean)	Per-job mode has been deprecated in Flink 1.15 and will be removed in the future. Please use application mode instead.
org.apache.flink.connector.file.table.TableMetaStoreFactory.TableMetaStore.getLocationPath()
org.apache.flink.connector.testframe.external.sink.TestingSinkSettings.Builder.setCheckpointingMode(CheckpointingMode)
org.apache.flink.connector.testframe.external.sink.TestingSinkSettings.getCheckpointingMode()
org.apache.flink.connector.testframe.external.source.TestingSourceSettings.Builder.setCheckpointingMode(CheckpointingMode)
org.apache.flink.connector.testframe.external.source.TestingSourceSettings.getCheckpointingMode()
org.apache.flink.connector.testframe.testsuites.SinkTestSuiteBase.checkResultWithSemantic(ExternalSystemDataReader<T>, List<T>, CheckpointingMode)
org.apache.flink.connector.testframe.utils.CollectIteratorAssert.matchesRecordsFromSource(List<List<T>>, CheckpointingMode)
org.apache.flink.connector.testframe.utils.UnorderedCollectIteratorAssert.matchesRecordsFromSource(List<List<T>>, CheckpointingMode)
org.apache.flink.core.fs.FileSystem.create(Path, boolean, int, short, long)	Deprecated because not well supported across types of file systems. Control the behavior of specific file systems via configurations instead.
org.apache.flink.core.fs.FileSystem.getDefaultBlockSize()	This value is no longer used and is meaningless.
org.apache.flink.core.fs.FileSystem.initialize(Configuration)	use FileSystem.initialize(Configuration, PluginManager) instead.
org.apache.flink.core.fs.LimitedConnectionsFileSystem.create(Path, boolean, int, short, long)
org.apache.flink.core.fs.LimitedConnectionsFileSystem.getDefaultBlockSize()
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.DataTypeCase.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.CoderInfoDescriptor.Mode.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.WindowProperty.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.GroupWindow.WindowType.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.Input.InputCase.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.OverWindow.WindowType.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.FieldType.TypeInfoCase.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.Schema.TypeName.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.EmptyCleanupStrategy.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.MapStrategiesEntry.CleanupStrategyCase.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.CleanupStrategies.Strategies.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.StateVisibility.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.TtlTimeCharacteristic.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.StateDescriptor.StateTTLConfig.UpdateType.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TypeInfoCase.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.TypeInfo.TypeName.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedAggregateFunction.DataViewSpec.DataViewCase.valueOf(int)
org.apache.flink.fnexecution.v1.FlinkFnApi.UserDefinedDataStreamFunction.FunctionType.valueOf(int)
org.apache.flink.legacy.table.descriptors.SchemaValidator.deriveTableSinkSchema(DescriptorProperties)	This method combines two separate concepts of table schema and field mapping. This should be split into two methods once we have support for the corresponding interfaces (see FLINK-9870).
org.apache.flink.legacy.table.factories.StreamTableSinkFactory.createStreamTableSink(Map<String, String>)	TableSinkFactory.Context contains more information, and already contains table schema too. Please use TableSinkFactory.createTableSink(Context) instead.
org.apache.flink.legacy.table.factories.StreamTableSourceFactory.createStreamTableSource(Map<String, String>)	TableSourceFactory.Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getJobManagerLeaderRetriever(JobID)	This method should only be used by the legacy code where the JobManager acts as the master.
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getWebMonitorLeaderElection()	Use HighAvailabilityServices.getClusterRestEndpointLeaderElection() instead.
org.apache.flink.runtime.highavailability.HighAvailabilityServices.getWebMonitorLeaderRetriever()	just use HighAvailabilityServices.getClusterRestEndpointLeaderRetriever() instead of this method.
org.apache.flink.runtime.io.network.buffer.Buffer.getMemorySegment()
org.apache.flink.runtime.io.network.buffer.Buffer.getMemorySegmentOffset()
org.apache.flink.runtime.jobmaster.LogicalSlot.releaseSlot()	Added because extended the actual releaseSlot method with cause parameter.
org.apache.flink.runtime.operators.hash.InMemoryPartition.overwriteRecordAt(long, T)	Don't use this, overwrites record and causes inconsistency or data loss for overwriting everything but records of the exact same size
org.apache.flink.sql.parser.impl.SimpleCharStream.getColumn()
org.apache.flink.sql.parser.impl.SimpleCharStream.getLine()
org.apache.flink.streaming.api.connector.sink2.CommittableSummary.getNumberOfPendingCommittables()
org.apache.flink.streaming.api.datastream.ConnectedStreams.keyBy(int, int)	use ConnectedStreams.keyBy(KeySelector, KeySelector)
org.apache.flink.streaming.api.datastream.DataStream.writeUsingOutputFormat(OutputFormat<T>)	Please use the StreamingFileSink explicitly using the DataStream.addSink(SinkFunction) method.
org.apache.flink.streaming.api.datastream.KeyedStream.asQueryableState(String)	The Queryable State feature is deprecated since Flink 1.18, and will be removed in a future Flink major version.
org.apache.flink.streaming.api.environment.CheckpointConfig.getCheckpointingMode()	Use CheckpointConfig.getCheckpointingConsistencyMode() instead.
org.apache.flink.streaming.api.environment.CheckpointConfig.setCheckpointingMode(CheckpointingMode)	Use CheckpointConfig.setCheckpointingConsistencyMode(org.apache.flink.core.execution.CheckpointingMode) instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.addSource(SourceFunction<OUT>)	This method relies on the SourceFunction API, which is due to be removed. Use the StreamExecutionEnvironment.fromSource(Source, WatermarkStrategy, String) method based on the new Source API instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode)	use StreamExecutionEnvironment.enableCheckpointing(long, CheckpointingMode) instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromCollection(Collection<OUT>)	This method will be removed a future release, possibly as early as version 2.0. Use StreamExecutionEnvironment.fromData(Collection) instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.fromElements(OUT...)	This method will be removed a future release, possibly as early as version 2.0. Use #fromData(OUT...) instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.generateSequence(long, long)	Use StreamExecutionEnvironment.fromSequence(long, long) instead to create a new data stream that contains NumberSequenceSource.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.getCheckpointingMode()	Use StreamExecutionEnvironment.getCheckpointingConsistencyMode() instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFile(FileInputFormat<OUT>, String)	Use FileSource#forRecordStreamFormat()/forBulkFileFormat()/forRecordFileFormat() instead. An example of reading a file using a simple TextLineInputFormat: FileSource<String> source = FileSource.forRecordStreamFormat( new TextLineInputFormat(), new Path("/foo/bar")) .build();
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.readFileStream(String, long, FileMonitoringFunction.WatchType)	Use StreamExecutionEnvironment.readFile(FileInputFormat, String, FileProcessingMode, long) instead.
org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.socketTextStream(String, int, char, long)	Use StreamExecutionEnvironment.socketTextStream(String, int, String, long) instead.
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.create()
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder.withInactivityInterval(long)	Use DefaultRollingPolicy.PolicyBuilder.withInactivityInterval(Duration) instead.
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder.withMaxPartSize(long)	Use DefaultRollingPolicy.PolicyBuilder.withMaxPartSize(MemorySize) instead.
org.apache.flink.streaming.api.functions.sink.filesystem.rollingpolicies.DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(long)	Use DefaultRollingPolicy.PolicyBuilder.withRolloverInterval(Duration) instead.
org.apache.flink.streaming.api.functions.sink.legacy.SinkFunction.invoke(IN)	Use SinkFunction.invoke(Object, Context).
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn1(ClassLoader)
org.apache.flink.streaming.api.graph.StreamConfig.getTypeSerializerIn2(ClassLoader)
org.apache.flink.streaming.api.graph.StreamGraph.getStreamEdgesOrThrow(int, int)
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.createTemporaryView(String, DataStream<T>, Expression...)	Use StreamTableEnvironment.createTemporaryView(String, DataStream, Schema) instead. In most cases, StreamTableEnvironment.createTemporaryView(String, DataStream) should already be sufficient. It integrates with the new type system and supports all kinds of DataTypes that the table runtime can consume. The semantics might be slightly different for raw and structured types.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.fromDataStream(DataStream<T>, Expression...)	Use StreamTableEnvironment.fromDataStream(DataStream, Schema) instead. In most cases, StreamTableEnvironment.fromDataStream(DataStream) should already be sufficient. It integrates with the new type system and supports all kinds of DataTypes that the table runtime can consume. The semantics might be slightly different for raw and structured types.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.registerDataStream(String, DataStream<T>)	use StreamTableEnvironment.createTemporaryView(String, DataStream)
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.registerFunction(String, TableFunction<T>)	Use TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction) instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of TableFunction for more information on the new function design.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.toAppendStream(Table, Class<T>)	Use StreamTableEnvironment.toDataStream(Table, Class) instead. It integrates with the new type system and supports all kinds of DataTypes that the table runtime can produce. The semantics might be slightly different for raw and structured types. Use toDataStream(DataTypes.of(TypeInformation.of(Class))) if TypeInformation should be used as source of truth.
org.apache.flink.table.api.bridge.java.StreamTableEnvironment.toRetractStream(Table, Class<T>)	Use StreamTableEnvironment.toChangelogStream(Table, Schema) instead. It integrates with the new type system and supports all kinds of DataTypes and every ChangelogMode that the table runtime can produce.
org.apache.flink.table.api.EnvironmentSettings.fromConfiguration(ReadableConfig)	use EnvironmentSettings.Builder.withConfiguration(Configuration) instead.
org.apache.flink.table.api.EnvironmentSettings.toConfiguration()	use EnvironmentSettings.getConfiguration() instead.
org.apache.flink.table.api.Expressions.nullOf(TypeInformation<?>)	This method will be removed in future versions as it uses the old type system. It is recommended to use Expressions.nullOf(DataType) instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.internal.BaseExpressions.cast(TypeInformation<?>)	This method will be removed in future versions as it uses the old type system. It is recommended to use BaseExpressions.cast(DataType) instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.api.internal.TableEnvironmentInternal.fromTableSource(TableSource<?>)
org.apache.flink.table.api.Table.as(Expression...)	use Table.as(String, String...)
org.apache.flink.table.api.Table.getSchema()	This method has been deprecated as part of FLIP-164. TableSchema has been replaced by two more dedicated classes Schema and ResolvedSchema. Use Schema for declaration in APIs. ResolvedSchema is offered by the framework after resolution and validation.
org.apache.flink.table.api.TableConfig.getMaxIdleStateRetentionTime()	useTableConfig.getIdleStateRetention() instead.
org.apache.flink.table.api.TableConfig.getMinIdleStateRetentionTime()	useTableConfig.getIdleStateRetention() instead.
org.apache.flink.table.api.TableConfig.setIdleStateRetentionTime(Duration, Duration)	use TableConfig.setIdleStateRetention(Duration) instead.
org.apache.flink.table.api.TableDescriptor.forManaged()	This method will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.api.TableEnvironment.getCompletionHints(String, int)	Will be removed in the next release
org.apache.flink.table.api.TableEnvironment.registerCatalog(String, Catalog)	Use TableEnvironment.createCatalog(String, CatalogDescriptor) instead. The new method uses a CatalogDescriptor to initialize the catalog instance and store the CatalogDescriptor to the CatalogStore.
org.apache.flink.table.api.TableEnvironment.registerFunction(String, ScalarFunction)	Use TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction) instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of ScalarFunction for more information on the new function design.
org.apache.flink.table.api.TableEnvironment.registerTable(String, Table)	use TableEnvironment.createTemporaryView(String, Table)
org.apache.flink.table.api.TableEnvironment.scan(String...)	use TableEnvironment.from(String)
org.apache.flink.table.api.TableResult.getTableSchema()	This method has been deprecated as part of FLIP-164. TableSchema has been replaced by two more dedicated classes Schema and ResolvedSchema. Use Schema for declaration in APIs. ResolvedSchema is offered by the framework after resolution and validation.
org.apache.flink.table.catalog.Catalog.getTableFactory()	Use Catalog.getFactory() for the new factory stack. The new factory stack uses the new table sources and sinks defined in FLIP-95 and a slightly different discovery mechanism.
org.apache.flink.table.catalog.Catalog.supportsManagedTable()	This method will be removed soon. Please see FLIP-346 for more details.
org.apache.flink.table.catalog.CatalogBaseTable.getSchema()	This method returns the deprecated TableSchema class. The old class was a hybrid of resolved and unresolved schema information. It has been replaced by the new Schema which is always unresolved and will be resolved by the framework later.
org.apache.flink.table.catalog.CatalogFunction.isGeneric()	There is no replacement for this function, as now functions have type inference strategies
org.apache.flink.table.catalog.CatalogManager.registerCatalog(String, Catalog)	This method is deprecated and will be removed in a future release. Use createCatalog instead to create a catalog using CatalogDescriptor and store it in the CatalogStore.
org.apache.flink.table.catalog.CatalogTable.of(Schema, String, List<String>, Map<String, String>)	Use the builder CatalogTable.newBuilder() instead.
org.apache.flink.table.catalog.CatalogTable.toProperties()	Only a ResolvedCatalogTable is serializable to properties.
org.apache.flink.table.catalog.FunctionCatalog.registerTempCatalogScalarFunction(ObjectIdentifier, ScalarFunction)	Use FunctionCatalog.registerTemporaryCatalogFunction(UnresolvedIdentifier, FunctionDefinition, boolean) instead.
org.apache.flink.table.catalog.FunctionCatalog.registerTempSystemAggregateFunction(String, ImperativeAggregateFunction<T, ACC>, TypeInformation<T>, TypeInformation<ACC>)	Use FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean) instead.
org.apache.flink.table.catalog.FunctionCatalog.registerTempSystemScalarFunction(String, ScalarFunction)	Use FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean) instead.
org.apache.flink.table.catalog.FunctionCatalog.registerTempSystemTableFunction(String, TableFunction<T>, TypeInformation<T>)	Use FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean) instead.
org.apache.flink.table.catalog.ResolvedCatalogBaseTable.getSchema()	This method returns the deprecated TableSchema class. The old class was a hybrid of resolved and unresolved schema information. It has been replaced by the new ResolvedSchema which is resolved by the framework and accessible via ResolvedCatalogBaseTable.getResolvedSchema().
org.apache.flink.table.codesplit.JavaLexer.getTokenNames()
org.apache.flink.table.codesplit.JavaParser.getTokenNames()
org.apache.flink.table.connector.sink.DataStreamSinkProvider.consumeDataStream(DataStream<RowData>)	Use DataStreamSinkProvider.consumeDataStream(ProviderContext, DataStream) and correctly set a unique identifier for each data stream transformation.
org.apache.flink.table.connector.source.abilities.SupportsProjectionPushDown.applyProjection(int[][])	Please implement SupportsProjectionPushDown.applyProjection(int[][], DataType)
org.apache.flink.table.connector.source.DataStreamScanProvider.produceDataStream(StreamExecutionEnvironment)
org.apache.flink.table.data.writer.BinaryArrayWriter.setNullAt(int, LogicalType)	Use BinaryArrayWriter.createNullSetter(LogicalType) for avoiding logical types during runtime.
org.apache.flink.table.data.writer.BinaryWriter.write(BinaryWriter, int, Object, LogicalType, TypeSerializer<?>)	Use BinaryWriter.createValueSetter(LogicalType) for avoiding logical types during runtime.
org.apache.flink.table.factories.CatalogFactory.createCatalog(String, Map<String, String>)	Use {@link this#createCatalog(Context)} instead and implement Factory instead of TableFactory.
org.apache.flink.table.factories.CatalogFactory.requiredContext()	Implement the Factory based stack instead.
org.apache.flink.table.factories.CatalogFactory.supportedProperties()	Implement the Factory based stack instead.
org.apache.flink.table.factories.FunctionDefinitionFactory.createFunctionDefinition(String, CatalogFunction)	Please implement FunctionDefinitionFactory.createFunctionDefinition(String, CatalogFunction, Context) instead.
org.apache.flink.table.factories.ModuleFactory.createModule(Map<String, String>)	Use ModuleFactory.createModule(Context) instead and implement Factory instead of TableFactory.
org.apache.flink.table.factories.ModuleFactory.requiredContext()	Implement the Factory based stack instead.
org.apache.flink.table.factories.ModuleFactory.supportedProperties()	Implement the Factory based stack instead.
org.apache.flink.table.functions.ImperativeAggregateFunction.getAccumulatorType()	This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated TableEnvironment.registerFunction(...) method. The new reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint) should be powerful enough to cover most use cases. For advanced users, it is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory).
org.apache.flink.table.functions.ImperativeAggregateFunction.getResultType()	This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated TableEnvironment.registerFunction(...) method. The new reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint) should be powerful enough to cover most use cases. For advanced users, it is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory).
org.apache.flink.table.functions.ScalarFunction.getParameterTypes(Class<?>[])	This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated TableEnvironment.registerFunction(...) method. The new reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint) should be powerful enough to cover most use cases. For advanced users, it is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory).
org.apache.flink.table.functions.ScalarFunction.getResultType(Class<?>[])	This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated TableEnvironment.registerFunction(...) method. The new reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint) should be powerful enough to cover most use cases. For advanced users, it is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory).
org.apache.flink.table.functions.TableFunction.getParameterTypes(Class<?>[])	This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated TableEnvironment.registerFunction(...) method. The new reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint) should be powerful enough to cover most use cases. For advanced users, it is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory).
org.apache.flink.table.functions.TableFunction.getResultType()	This method uses the old type system and is based on the old reflective extraction logic. The method will be removed in future versions and is only called when using the deprecated TableEnvironment.registerFunction(...) method. The new reflective extraction logic (possibly enriched with DataTypeHint and FunctionHint) should be powerful enough to cover most use cases. For advanced users, it is possible to override UserDefinedFunction.getTypeInference(DataTypeFactory).
org.apache.flink.table.legacy.api.TableColumn.of(String, DataType)	Use TableColumn.physical(String, DataType) instead.
org.apache.flink.table.legacy.api.TableSchema.Builder.field(String, TypeInformation<?>)	This method will be removed in future versions as it uses the old type system. It is recommended to use TableSchema.Builder.field(String, DataType) instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.legacy.api.TableSchema.fromTypeInfo(TypeInformation<?>)	This method will be removed soon. Use DataTypes to declare types.
org.apache.flink.table.legacy.api.TableSchema.getFieldType(int)	This method will be removed in future versions as it uses the old type system. It is recommended to use TableSchema.getFieldDataType(int) instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.legacy.api.TableSchema.getFieldTypes()	This method will be removed in future versions as it uses the old type system. It is recommended to use TableSchema.getFieldDataTypes() instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.legacy.api.TableSchema.toRowType()	Use TableSchema.toRowDataType() instead.
org.apache.flink.table.legacy.descriptors.Schema.field(String, TypeInformation<?>)	This method will be removed in future versions as it uses the old type system. Please use Schema.field(String, DataType) instead.
org.apache.flink.table.legacy.factories.TableSinkFactory.createTableSink(Map<String, String>)	TableSinkFactory.Context contains more information, and already contains table schema too. Please use TableSinkFactory.createTableSink(Context) instead.
org.apache.flink.table.legacy.factories.TableSourceFactory.createTableSource(Map<String, String>)	TableSourceFactory.Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.
org.apache.flink.table.legacy.sinks.TableSink.configure(String[], TypeInformation<?>[])	This method will be dropped in future versions. It is recommended to pass a static schema when instantiating the sink instead.
org.apache.flink.table.legacy.sinks.TableSink.getFieldNames()	Use the field names of TableSink.getTableSchema() instead.
org.apache.flink.table.legacy.sinks.TableSink.getFieldTypes()	Use the field types of TableSink.getTableSchema() instead.
org.apache.flink.table.legacy.sinks.TableSink.getOutputType()	This method will be removed in future versions as it uses the old type system. It is recommended to use TableSink.getConsumedDataType() instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.legacy.sources.TableSource.getReturnType()	This method will be removed in future versions as it uses the old type system. It is recommended to use TableSource.getProducedDataType() instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.legacy.sources.TableSource.getTableSchema()	Table schema is a logical description of a table and should not be part of the physical TableSource. Define schema when registering a Table either in DDL or in TableEnvironment#connect(...).
org.apache.flink.table.plan.stats.ColumnStats.getMaxValue()
org.apache.flink.table.plan.stats.ColumnStats.getMinValue()
org.apache.flink.table.planner.functions.casting.CastRule.Context.legacyBehaviour()
org.apache.flink.table.planner.functions.casting.CodeGeneratorCastRule.Context.legacyBehaviour()
org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.createSourceFunctionTransformation(StreamExecutionEnvironment, SourceFunction<RowData>, boolean, String, TypeInformation<RowData>, int, boolean)	This method relies on the SourceFunction API, which is due to be removed.
org.apache.flink.table.planner.utils.TableConfigUtils.getMaxIdleStateRetentionTime(ReadableConfig)
org.apache.flink.table.runtime.types.ClassLogicalTypeConverter.getDefaultExternalClassForType(LogicalType)
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter.fromDataTypeToLogicalType(DataType)
org.apache.flink.table.runtime.types.LogicalTypeDataTypeConverter.fromLogicalTypeToDataType(LogicalType)
org.apache.flink.table.runtime.typeutils.InternalTypeInfo.toRowFieldNames()	TypeInformation should just be a thin wrapper of a serializer. This method only exists for legacy code. It is recommended to use the RowType instead for logical operations.
org.apache.flink.table.runtime.typeutils.InternalTypeInfo.toRowFieldTypes()	TypeInformation should just be a thin wrapper of a serializer. This method only exists for legacy code. It is recommended to use the RowType instead for logical operations.
org.apache.flink.table.runtime.typeutils.InternalTypeInfo.toRowSize()	TypeInformation should just be a thin wrapper of a serializer. This method only exists for legacy code. It is recommended to use the RowType instead for logical operations.
org.apache.flink.table.sources.CsvTableSource.Builder.field(String, TypeInformation<?>)	This method will be removed in future versions as it uses the old type system. It is recommended to use CsvTableSource.Builder.field(String, DataType) instead which uses the new type system based on DataTypes. Please make sure to use either the old or the new type system consistently to avoid unintended behavior. See the website documentation for more information.
org.apache.flink.table.types.logical.utils.LogicalTypeParser.parse(String)	You should use LogicalTypeParser.parse(String, ClassLoader) to correctly load user types
org.apache.flink.table.types.utils.DataTypeUtils.projectRow(DataType, int[][])	Use the Projection type
org.apache.flink.table.types.utils.TypeConversions.fromDataTypeToLegacyInfo(DataType)	Please don't use this method anymore. It will be removed soon and we should not make the removal more painful. Sources and sinks should use the method available in context to convert, within the planner you should use either InternalTypeInfo or ExternalTypeInfo depending on the use case.
org.apache.flink.table.types.utils.TypeConversions.fromLegacyInfoToDataType(TypeInformation<?>)	Please don't use this method anymore. It will be removed soon and we should not make the removal more painful. Sources and sinks should use the method available in context to convert, within the planner you should use either InternalTypeInfo or ExternalTypeInfo depending on the use case.
org.apache.flink.table.utils.EncodingUtils.loadClass(String)	Use EncodingUtils.loadClass(String, ClassLoader) instead, in order to explicitly provide the correct classloader.
org.apache.flink.test.util.TestUtils.getMostRecentCompletedCheckpoint(File)	please use org.apache.flink.runtime.testutils.CommonTestUtils#getLatestCompletedCheckpointPath(JobID, MiniCluster) which is less prone to NoSuchFileException and IO-intensive.
org.apache.flink.test.util.TestUtils.getMostRecentCompletedCheckpointMaybe(File)	please use org.apache.flink.runtime.testutils.CommonTestUtils#getLatestCompletedCheckpointPath(JobID, MiniCluster) which is less prone to NoSuchFileException and IO-intensive.
org.apache.flink.test.util.TestUtils.waitUntilExternalizedCheckpointCreated(File)	please use org.apache.flink.runtime.testutils.CommonTestUtils#waitForCheckpoint(JobID, MiniCluster, Deadline) which is less prone to NoSuchFileException and IO-intensive.

Constructors

Constructor	Description
org.apache.calcite.rel.logical.LogicalTableScan(RelOptCluster, RelTraitSet, RelOptTable)
org.apache.calcite.sql2rel.SqlToRelConverter(RelOptTable.ViewExpander, SqlValidator, Prepare.CatalogReader, RelOptPlanner, RexBuilder, SqlRexConvertletTable)
org.apache.flink.api.common.state.ValueStateDescriptor(String, Class<T>, T)	Use ValueStateDescriptor(String, Class) instead and manually manage the default value by checking whether the contents of the state is null.
org.apache.flink.api.common.typeutils.CompositeTypeSerializerSnapshot(Class<? extends TypeSerializer>)	correspondingSerializerClass is not used to resolve and cast after FLIP-263, please use CompositeTypeSerializerSnapshot() instead.
org.apache.flink.runtime.jobgraph.tasks.CheckpointCoordinatorConfiguration(long, long, long, int, CheckpointRetentionPolicy, boolean, boolean, int, long)	use CheckpointCoordinatorConfiguration.builder().
org.apache.flink.runtime.leaderretrieval.StandaloneLeaderRetrievalService(String)	Use StandaloneLeaderRetrievalService(String, UUID) instead
org.apache.flink.streaming.api.connector.sink2.CommittableSummary(int, int, long, int, int, int)
org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter.OutputStreamBasedInProgressFileRecoverable(RecoverableWriter.ResumeRecoverable)
org.apache.flink.streaming.api.functions.sink.filesystem.OutputStreamBasedPartFileWriter.OutputStreamBasedPendingFileRecoverable(RecoverableWriter.CommitRecoverable)
org.apache.flink.table.api.dataview.ListView(TypeInformation<?>)	This method uses the old type system. Please use a DataTypeHint instead if the reflective type extraction is not successful.
org.apache.flink.table.api.dataview.MapView(TypeInformation<?>, TypeInformation<?>)	This method uses the old type system. Please use a DataTypeHint instead if the reflective type extraction is not successful.
org.apache.flink.table.api.TableConfig()
org.apache.flink.table.expressions.CallExpression(FunctionIdentifier, FunctionDefinition, List<ResolvedExpression>, DataType)	Use CallExpression.permanent(FunctionIdentifier, FunctionDefinition, List, DataType) or CallExpression.temporary(FunctionIdentifier, FunctionDefinition, List, DataType) instead.
org.apache.flink.table.legacy.api.TableSchema(String[], TypeInformation<?>[])	Use the TableSchema.Builder instead.
org.apache.flink.table.plan.stats.ColumnStats(Long, Long, Double, Integer, Number, Number)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateExpandDistinctAggregatesRule(Class<? extends LogicalAggregate>, boolean, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateJoinTransposeRule(Class<? extends Aggregate>, RelFactories.AggregateFactory, Class<? extends Join>, RelFactories.JoinFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkAggregateRemoveRule(Class<? extends Aggregate>)
org.apache.flink.table.planner.plan.rules.logical.FlinkBushyJoinReorderRule(RelBuilderFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinPushExpressionsRule(Class<? extends Join>, RelFactories.ProjectFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinReorderRule(RelBuilderFactory)
org.apache.flink.table.planner.plan.rules.logical.FlinkJoinToMultiJoinRule(Class<? extends Join>)
org.apache.flink.table.runtime.dataview.ListViewSpec(String, int, DataType, TypeSerializer<?>)
org.apache.flink.table.runtime.dataview.MapViewSpec(String, int, DataType, boolean, TypeSerializer<?>, TypeSerializer<?>)
org.apache.flink.table.types.logical.SymbolType(boolean, Class<T>)	Symbol types have been simplified to not require a class.

Enum Constants

Enum Constant	Description
org.apache.flink.api.common.state.StateDescriptor.Type.UNKNOWN	Enum for migrating from old checkpoints/savepoint versions.
org.apache.flink.core.execution.RecoveryClaimMode.LEGACY
org.apache.flink.runtime.rest.messages.TerminationModeQueryParameter.TerminationMode.STOP	Please use the "stop" command instead.
org.apache.flink.yarn.configuration.YarnDeploymentTarget.PER_JOB