Deprecated API

Contents

• Classes
• Enums
• Fields
• Methods
• Constructors

Classes

Class	Description
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.operations.ddl.AlterTableOptionsOperation	Please use AlterTableChangeOperation instead.
org.apache.flink.table.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.sources.tsextractors.StreamRecordTimestamp	This class will not be supported in the new source design around DynamicTableSource. See FLIP-95 for more information.

Enums

Enum	Description
org.apache.flink.table.api.config.ExecutionConfigOptions.LegacyCastBehaviour

Fields

Field	Description
org.apache.flink.table.api.config.ExecutionConfigOptions.TABLE_EXEC_LEGACY_TRANSFORMATION_UIDS	Use ExecutionConfigOptions.TABLE_EXEC_UID_GENERATION instead.
org.apache.flink.table.api.config.ExecutionConfigOptions.TABLE_EXEC_SHUFFLE_MODE	Use ExecutionOptions.BATCH_SHUFFLE_MODE instead.

Methods

Method	Description
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(Time, Time)	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.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.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.

Constructors

Constructor	Description
org.apache.flink.table.api.TableConfig()