All Classes

Class	Description
AbstractCatalog	Abstract class for catalogs.
AbstractCatalogStore	The AbstractCatalogStore class is an abstract base class for implementing a catalog store.
AbstractDataType<T extends AbstractDataType<T>>	Highest abstraction that describes the data type of a value in the table ecosystem.
AbstractHeapVector	Heap vector that nullable shared structure.
AbstractWritableVector	Contains the shared structure for ColumnVectors, including NULL information and dictionary.
AdaptedCallContext	Helper context that deals with adapted arguments.
AggregateExpression	Resolved and validated expression for calling an aggregate function.
AggregateFunction<T,ACC>	Base class for a user-defined aggregate function.
AggregateFunctionDefinition	Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
AmbiguousTableFactoryException	Deprecated. This exception is considered internal and has been erroneously placed in the *.api package.
AmbiguousTableFactoryException	Exception for finding more than one TableFactory for the given properties.
AndArgumentTypeStrategy	Strategy for inferring and validating an argument using a conjunction of multiple ArgumentTypeStrategys into one like f(NUMERIC && LITERAL)
AnyArgumentTypeStrategy	Strategy for an argument that can be of any type.
ArgumentCount	Defines the count of accepted arguments (including open intervals) that a function can take.
ArgumentMappingTypeStrategy	Type strategy that returns the n-th input argument, mapping it with the provided function.
ArgumentTypeStrategy	Strategy for inferring and validating a single input argument type of a function call.
ArrayColumnVector	Array column vector.
ArrayComparableElementTypeStrategy	An InputTypeStrategy that checks if the input argument is an ARRAY type and check whether its' elements are comparable.
ArrayData	Base interface of an internal data structure representing data of ArrayType.
ArrayData.ElementGetter	Accessor for getting the elements of an array during runtime.
ArrayOfStringArgumentTypeStrategy	Strategy for an argument that must be an array of strings.
ArrayType	Logical type of an array of elements with same subtype.
AsyncLookupFunction	A wrapper class of AsyncTableFunction for asynchronously lookup rows matching the lookup keys from external system.
AsyncLookupFunctionProvider	A provider for creating AsyncLookupFunction.
AsyncTableFunction<T>	Base class for a user-defined asynchronous table function.
AsyncTableFunctionProvider<T>	Deprecated. Please use AsyncLookupFunctionProvider to implement asynchronous lookup table.
AtomicDataType	A data type that does not contain further data types (e.g.
BigIntType	Logical 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.
BinaryArrayData	A binary implementation of ArrayData which is backed by MemorySegments.
BinaryFormat	Binary format spanning MemorySegments.
BinaryMapData	[4 byte(keyArray size in bytes)] + [Key BinaryArray] + [Value BinaryArray].
BinaryRawValueData<T>	A lazily binary implementation of RawValueData which is backed by MemorySegments and generic Object.
BinaryRowData	An implementation of RowData which is backed by MemorySegment instead of Object.
BinarySection	A basic implementation of BinaryFormat which describe a section of memory.
BinarySegmentUtils	Utilities for binary data segments which heavily uses MemorySegment.
BinaryStringData	A lazily binary implementation of StringData which is backed by MemorySegments and String.
BinaryType	Logical type of a fixed-length binary string (=a sequence of bytes).
BooleanColumnVector	Boolean column vector.
BooleanType	Logical type of a boolean with a (possibly) three-valued logic of TRUE, FALSE, UNKNOWN.
BuiltInFunctionDefinition	Definition of a built-in function.
BuiltInFunctionDefinition.Builder	Builder for fluent definition of built-in functions.
BuiltInFunctionDefinitions	Dictionary of function definitions for all built-in functions.
BuiltInPythonAggregateFunction	The list of the built-in aggregate functions which can be mixed with the Python UDAF.
ByteColumnVector	Byte column vector.
BytesColumnVector	Bytes column vector to get BytesColumnVector.Bytes, it include original data and offset and length.
BytesColumnVector.Bytes	Bytes data.
CacheReloadTrigger	Customized trigger for reloading lookup table entries.
CacheReloadTrigger.Context	Context of CacheReloadTrigger for getting information about times and triggering reload.
CallContext	Provides details about a function call during TypeInference.
CallExpression	Resolved and validated call expression for calling a function.
CastExecutor<IN,OUT>	Interface to model a function that performs the casting of a value from one type to another.
Catalog	This interface is responsible for reading and writing metadata such as database/table/views/UDFs from a registered catalog.
CatalogBaseTable	A common parent that describes the unresolved metadata of a table or view in a catalog.
CatalogBaseTable.TableKind	The kind of CatalogBaseTable.
CatalogColumnStatistics	Column statistics of a table or partition.
CatalogColumnStatisticsDataBase	Column statistics value base class.
CatalogColumnStatisticsDataBinary	Column statistics value of binary type.
CatalogColumnStatisticsDataBoolean	Column statistics value of boolean type.
CatalogColumnStatisticsDataDate	Column statistics value of date type.
CatalogColumnStatisticsDataDouble	Column statistics value of double type.
CatalogColumnStatisticsDataLong	Column statistics value of long type.
CatalogColumnStatisticsDataString	Column statistics value of string type.
CatalogDatabase	Interface of a database in a catalog.
CatalogDescriptor	Describes a Catalog with the catalog name and configuration.
CatalogException	A catalog-related, runtime exception.
CatalogFactory	A factory to create configured catalog instances based on string-based properties.
CatalogFactory.Context	Context provided when a catalog is created.
CatalogFunction	Interface for a function in a catalog.
CatalogLock	Deprecated. This interface will be removed soon.
CatalogLock.Factory	Deprecated. This interface will be removed soon.
CatalogNotExistException	Exception for an operation on a nonexistent catalog.
CatalogPartition	Represents a partition object in catalog.
CatalogPartitionSpec	Represents a partition spec object in catalog.
CatalogPropertiesUtil	Utilities for de/serializing Catalog objects into a map of string properties.
CatalogStore	Represents the storage where persists all Catalogs.
CatalogStoreFactory	A factory to create configured catalog store instances based on string-based properties.
CatalogStoreFactory.Context	Context provided when a catalog store is created.
CatalogStoreHolder	A holder for a CatalogStore instance and the necessary information for creating and initializing Catalog instances, including a CatalogStoreFactory, a ReadableConfig instance, and a ClassLoader instance.
CatalogStoreHolder.Builder	Builder for a fluent definition of a CatalogStoreHolder.
CatalogTable	Represents the unresolved metadata of a table in a Catalog.
CatalogTableStatistics	Statistics for a non-partitioned table or a partition of a partitioned table.
CatalogView	Represents the unresolved metadata of a view in a Catalog.
ChangelogMode	The set of changes contained in a changelog.
ChangelogMode.Builder	Builder for configuring and creating instances of ChangelogMode.
CharType	Logical type of a fixed-length character string.
ClassDataTypeConverter	Class-based data type extractor that supports extraction of clearly identifiable data types for input and output conversion.
CollectionDataType	A data type that contains an element type (e.g.
Column	Representation of a column in a ResolvedSchema.
Column.ComputedColumn	Representation of a computed column.
Column.MetadataColumn	Representation of a metadata column.
Column.PhysicalColumn	Representation of a physical column.
ColumnarArrayData	Columnar array to support access to vector column data.
ColumnarMapData	Columnar map to support access to vector column data.
ColumnarRowData	Columnar row to support access to vector column data.
ColumnStats	Column statistics.
ColumnStats.Builder	ColumnStats builder.
ColumnVector	Nullable column vector.
CommonArgumentTypeStrategy	Argument type strategy that checks and casts for a common, least restrictive type of all arguments.
CommonArrayInputTypeStrategy	An InputTypeStrategy that expects that all arguments have a common array type.
CommonCatalogOptions	A collection of ConfigOption which are consistently used in multiple catalogs.
CommonInputTypeStrategy	An InputTypeStrategy that expects that all arguments have a common type.
CommonModuleOptions	A collection of ConfigOption which are consistently used in multiple modules.
CommonTypeStrategy	Type strategy that returns a common, least restrictive type of all arguments.
ComparableTypeStrategy	An InputTypeStrategy that checks if all input arguments can be compared with each other with the minimal provided comparison.
CompositeArgumentTypeStrategy	Strategy that checks that the argument has a composite type.
ConnectorDescriptorValidator	Deprecated.
ConstantArgumentCount	Helper class for ArgumentCount with constant boundaries.
Constraint	Deprecated. See ResolvedSchema and Constraint.
Constraint	Integrity constraints, generally referred to simply as constraints, define the valid states of SQL-data by constraining the values in the base tables.
Constraint.ConstraintType	Type of the constraint.
Constraint.ConstraintType	Type of the constraint.
ConstraintArgumentTypeStrategy	Strategy for an argument that must fulfill a given constraint.
CoreModule	Module of default core metadata in Flink.
CoreModuleFactory	Factory for CoreModule.
DatabaseAlreadyExistException	Exception for trying to create a database that already exists.
DatabaseNotEmptyException	Exception for trying to drop on a database that is not empty.
DatabaseNotExistException	Exception for trying to operate on a database that doesn't exist.
DataType	Describes the data type of a value in the table ecosystem.
DataTypeConversionClassTransformation	This type transformation transforms the specified data types to a new one with the expected conversion class.
DataTypeDefaultVisitor<R>	Implementation of DataTypeVisitor that redirects all calls to DataTypeDefaultVisitor.defaultMethod(DataType).
DataTypeExtractor	Reflection-based utility that analyzes a given Type, method, or class to extract a (possibly nested) DataType from it.
DataTypeFactory	Factory for creating fully resolved data types that can be used for planning.
DataTypeHint	A hint that influences the reflection-based extraction of a DataType.
DataTypeQueryable	Indicates that a DataType can be retrieved from a class that implements this interfaces.
DataTypes	A DataType can be used to declare input and/or output types of operations.
DataTypes.AbstractField	Common helper class for resolved and unresolved fields of a row or structured type.
DataTypes.Field	Helper class for defining the field of a row or structured type.
DataTypes.Resolution	Helper class for defining the resolution of an interval.
DataTypes.UnresolvedField	Helper class for defining the unresolved field of a row or structured type.
DataTypeUtils	Utilities for handling DataTypes.
DataTypeVisitor<R>	The visitor definition of DataType.
DataView	A DataView is a collection type that can be used in the accumulator of an ImperativeAggregateFunction.
Date	Class representing a date value in statistics.
DateTimeUtils	Utility functions for datetime types: date, time, timestamp.
DateTimeUtils.TimeUnit	Enumeration of time units used to construct an interval.
DateTimeUtils.TimeUnitRange	A range of time units.
DateType	Logical type of a date consisting of year-month-day with values ranging from 0000-01-01 to 9999-12-31.
DayTimeIntervalType	Logical type for a group of day-time interval types.
DayTimeIntervalType.DayTimeResolution	Supported resolutions of this type.
DecimalColumnVector	Decimal column vector.
DecimalData	An internal data structure representing data of DecimalType.
DecimalType	Logical type of a decimal number with fixed precision and scale.
DecodingFormat<I>	A Format for a DynamicTableSource for reading rows.
DecodingFormatFactory<I>	Base interface for configuring a DecodingFormat for ScanTableSource and LookupTableSource.
DefaultCatalogTable	Default implementation of a CatalogTable.
DefaultLookupCache	Default implementation of LookupCache.
DefaultLookupCache.Builder	Builder for DefaultLookupCache.
DefinedFieldMapping	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
DefinedProctimeAttribute	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
DefinedRowtimeAttributes	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
Descriptor	Deprecated. Descriptor was primarily used for the legacy connector stack and have been deprecated.
DescriptorProperties	Deprecated. This utility will be dropped soon.
DescriptorValidator	Deprecated. See Descriptor for details.
DeserializationFormatFactory	Factory for creating a DecodingFormat for DeserializationSchema.
Dictionary	The interface for dictionary in AbstractColumnVector to decode dictionary encoded values.
DistinctType	Logical type of a user-defined distinct type.
DistinctType.Builder	A builder for a DistinctType.
DoubleColumnVector	Double column vector.
DoubleType	Logical type of an 8-byte double precision floating point number.
DynamicFilteringData	Data for dynamic filtering.
DynamicFilteringEvent	A source event to transport the DynamicFilteringData for dynamic filtering purpose.
DynamicTableFactory	Base interface for configuring a dynamic table connector for an external storage system from catalog and session information.
DynamicTableFactory.Context	Provides catalog and session information describing the dynamic table to be accessed.
DynamicTableSink	Sink of a dynamic table to an external storage system.
DynamicTableSink.Context	Context for creating runtime implementation via a DynamicTableSink.SinkRuntimeProvider.
DynamicTableSink.DataStructureConverter	Converter for mapping between Flink's internal data structures and objects specified by the given DataType that can be passed into a runtime implementation.
DynamicTableSink.SinkRuntimeProvider	Provides actual runtime implementation for writing the data.
DynamicTableSinkFactory	Creates a DynamicTableSink instance from a CatalogTable and additional context information.
DynamicTableSource	Source of a dynamic table from an external storage system.
DynamicTableSource.Context	Base context for creating runtime implementation via a ScanTableSource.ScanRuntimeProvider and LookupTableSource.LookupRuntimeProvider.
DynamicTableSource.DataStructureConverter	Converter for mapping between objects and Flink's internal data structures during runtime.
DynamicTableSourceFactory	Creates a DynamicTableSource instance from a CatalogTable and additional context information.
EncodingFormat<I>	A Format for a DynamicTableSink for writing rows.
EncodingFormatFactory<I>	Base interface for configuring an EncodingFormat for a DynamicTableSink.
EncodingUtils	General utilities for string-encoding.
ExplicitArgumentTypeStrategy	Strategy for an argument that corresponds to an explicitly defined type.
ExplicitTypeStrategy	Type strategy that returns a fixed DataType.
Expression	General interface for all kinds of expressions.
ExpressionDefaultVisitor<T>	Implementation of ExpressionVisitor that redirects all calls to ExpressionDefaultVisitor.defaultMethod(Expression).
ExpressionParserException	Deprecated. This exception is considered internal and has been erroneously placed in the *.api package.
ExpressionParserException	Exception for all errors occurring during expression parsing.
ExpressionUtils	Utility methods for working with Expressions.
ExpressionVisitor<R>	The visitor definition of Expression.
ExtractionUtils	Utilities for performing reflection tasks.
ExtractionUtils.AssigningConstructor	Result of the extraction in ExtractionUtils.extractAssigningConstructor(Class, List).
ExtractionVersion	Logical version that describes the expected behavior of the reflection-based data type extraction.
Factory	Base interface for all kind of factories that create object instances from a list of key-value pairs in Flink's Table & SQL API.
FactoryUtil	Utility for working with Factorys.
FactoryUtil.CatalogFactoryHelper	Helper utility for validating all options for a CatalogFactory.
FactoryUtil.CatalogStoreFactoryHelper	Helper utility for validating all options for a CatalogStoreFactory.
FactoryUtil.DefaultCatalogContext	Default implementation of CatalogFactory.Context.
FactoryUtil.DefaultCatalogStoreContext	Default implementation of CatalogStoreFactory.Context.
FactoryUtil.DefaultDynamicTableContext	Default implementation of DynamicTableFactory.Context.
FactoryUtil.DefaultModuleContext	Default implementation of ModuleFactory.Context.
FactoryUtil.FactoryHelper<F extends Factory>	Base helper utility for validating all options for a Factory.
FactoryUtil.ModuleFactoryHelper	Helper utility for validating all options for a ModuleFactory.
FactoryUtil.TableFactoryHelper	Helper utility for discovering formats and validating all options for a DynamicTableFactory.
FamilyArgumentTypeStrategy	Strategy for an argument that corresponds to a given LogicalTypeFamily and nullability.
FieldComputer<T>	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
FieldReferenceExpression	A reference to a field in an input.
FieldsDataType	A data type that contains field data types (i.e.
FileBasedStatisticsReportableInputFormat	Extension of input format which is able to report estimated statistics for file based connector.
FileSystemValidator	Deprecated. The legacy CSV connector has been replaced by FileSource / FileSink.
FilterableTableSource<T>	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
FirstTypeStrategy	Type strategy that returns the first type that could be inferred.
FloatColumnVector	Float column vector.
FloatType	Logical type of a 4-byte single precision floating point number.
ForceNullableTypeStrategy	Forces a given type strategy to be nullable.
Format	Base interface for connector formats.
FormatFactory	Base interface for DecodingFormatFactory and EncodingFormatFactory.
FullCachingLookupProvider	A LookupFunctionProvider that never lookup in external system on cache miss and provides a cache for holding all entries in the external system.
FunctionAlreadyExistException	Exception for trying to create a function that already exists.
FunctionContext	A FunctionContext allows to obtain global runtime information about the context in which the user-defined function is executed.
FunctionDefinition	Definition of a function.
FunctionDefinitionFactory	A factory to create FunctionDefinition.
FunctionDefinitionFactory.Context	Context provided when a function definition is created.
FunctionHint	A hint that influences the reflection-based extraction of input types, accumulator types, and output types for constructing the TypeInference logic of a UserDefinedFunction.
FunctionHints	Helper annotation for repeatable FunctionHints.
FunctionIdentifier	Identifies a system function with function name or a catalog function with a fully qualified identifier.
FunctionKind	Categorizes the semantics of a FunctionDefinition.
FunctionLanguage	Categorizes the language semantics of a CatalogFunction.
FunctionNotExistException	Exception for trying to operate on a function that doesn't exist.
FunctionRequirement	Characteristics that a FunctionDefinition requires.
GenericArrayData	An internal data structure representing data of ArrayType.
GenericMapData	An internal data structure representing data of MapType or MultisetType.
GenericRowData	An internal data structure representing data of RowType and other (possibly nested) structured types such as StructuredType.
HeapArrayVector	This class represents a nullable heap array column vector.
HeapBooleanVector	This class represents a nullable heap boolean column vector.
HeapBytesVector	This class supports string and binary data by value reference -- i.e.
HeapByteVector	This class represents a nullable byte column vector.
HeapDoubleVector	This class represents a nullable double precision floating point column vector.
HeapFloatVector	This class represents a nullable double precision floating point column vector.
HeapIntVector	This class represents a nullable int column vector.
HeapLongVector	This class represents a nullable long column vector.
HeapMapVector	This class represents a nullable heap map column vector.
HeapRowVector	This class represents a nullable heap row column vector.
HeapShortVector	This class represents a nullable short column vector.
HeapTimestampVector	This class represents a nullable byte column vector.
HintFlag	Three-valued flag for representing TRUE, FALSE, and UNKNOWN.
HiveAggDecimalPlusTypeStrategy	Type strategy that returns the result type of a decimal addition, used internally for implementing native SUM/AVG aggregations on a Decimal type.
ImperativeAggregateFunction<T,ACC>	Base class for user-defined AggregateFunction and TableAggregateFunction.
InputFormatProvider	Provider of an InputFormat instance as a runtime implementation for ScanTableSource.
InputGroup	A list of commonly used pre-defined groups of similar types for accepting more than just one data type as an input argument in DataTypeHints.
InputTypeStrategies	Strategies for inferring and validating input arguments in a function call.
InputTypeStrategy	Strategy for inferring and validating input arguments in a function call.
IntColumnVector	Int column vector.
IntType	Logical type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647.
JoinedRowData	An implementation of RowData which is backed by two concatenated RowData.
JsonExistsOnError	Behavior in case of errors for BuiltInFunctionDefinitions.JSON_EXISTS.
JsonOnNull	Behavior for entries with a null value for BuiltInFunctionDefinitions.JSON_OBJECT and BuiltInFunctionDefinitions.JSON_ARRAY.
JsonQueryOnEmptyOrError	Behavior of BuiltInFunctionDefinitions.JSON_QUERY in case a path expression is empty or raises an error.
JsonQueryWrapper	Defines whether and when to wrap the result of BuiltInFunctionDefinitions.JSON_QUERY into an array.
JsonType	Supported JSON types for BuiltInFunctionDefinitions.IS_JSON.
JsonValueOnEmptyOrError	Behavior for BuiltInFunctionDefinitions.JSON_VALUE.
KeyValueDataType	A data type that contains a key and value data type (e.g.
LazyBinaryFormat<T>	An abstract implementation fo BinaryFormat which is lazily serialized into binary or lazily deserialized into Java object.
LegacyRawTypeTransformation	This type transformation transforms the LEGACY('RAW', ...) type to the RAW(..., ?) type.
LegacyToNonLegacyTransformation	Transformation that applies TypeInfoDataTypeConverter on LegacyTypeInformationType.
LegacyTypeInfoDataTypeConverter	Deprecated. Use DataTypeFactory.createDataType(TypeInformation) instead.
LegacyTypeInformationType<T>	This type is a temporary solution to fully support the old type system stack through the new stack.
LimitableTableSource<T>	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
ListView<T>	A DataView that provides List-like functionality in the accumulator of an AggregateFunction or TableAggregateFunction when large amounts of data are expected.
ListViewSerializer<T>	Deprecated.
ListViewSerializerSnapshot<T>	Deprecated.
ListViewTypeInfo<T>	Deprecated.
ListViewTypeInfoFactory<T>	Deprecated.
LiteralArgumentTypeStrategy	Strategy that checks if an argument is a literal.
LocalZonedTimestampType	Logical 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.
LogicalType	A logical type that describes the data type of a value.
LogicalTypeCasts	Utilities for casting LogicalType.
LogicalTypeChecks	Utilities for checking LogicalType and avoiding a lot of type casting and repetitive work.
LogicalTypeDataTypeConverter	A converter between LogicalType and DataType.
LogicalTypeDefaultVisitor<R>	Implementation of LogicalTypeVisitor that redirects all calls to LogicalTypeDefaultVisitor.defaultMethod(LogicalType).
LogicalTypeDuplicator	Returns a deep copy of a LogicalType.
LogicalTypeFamily	An enumeration of logical type families for clustering LogicalTypeRoots into categories.
LogicalTypeMerging	Utilities for merging multiple LogicalType.
LogicalTypeParser	Parser for creating instances of LogicalType from a serialized string created with LogicalType.asSerializableString().
LogicalTypeRoot	An enumeration of logical type roots containing static information about logical data types.
LogicalTypeUtils	Utilities for handling LogicalTypes.
LogicalTypeVisitor<R>	The visitor definition of LogicalType.
LongColumnVector	Long column vector.
LookupableTableSource<T>	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
LookupCache	A semi-persistent mapping from keys to values for storing entries of lookup table.
LookupFunction	A wrapper class of TableFunction for synchronously lookup rows matching the lookup keys from external system.
LookupFunctionProvider	A provider for creating LookupFunction.
LookupOptions	Predefined options for lookup table.
LookupOptions.LookupCacheType	Types of the lookup cache.
LookupOptions.ReloadStrategy	Defines which CacheReloadTrigger to use.
LookupTableSource	A DynamicTableSource that looks up rows of an external storage system by one or more keys during runtime.
LookupTableSource.LookupContext	Context for creating runtime implementation via a LookupTableSource.LookupRuntimeProvider.
LookupTableSource.LookupRuntimeProvider	Provides actual runtime implementation for reading the data.
ManagedTableFactory	Deprecated. This interface will be removed soon.
MapColumnVector	Map column vector.
MapData	Base interface of an internal data structure representing data of MapType or MultisetType.
MappingTypeStrategy	Type strategy that maps an InputTypeStrategy to a TypeStrategy if the input strategy infers compatible types.
MapType	Logical type of an associative array that maps keys (including NULL) to values (including NULL).
MapView<K,V>	A DataView that provides Map-like functionality in the accumulator of an AggregateFunction or TableAggregateFunction when large amounts of data are expected.
MapViewSerializer<K,V>	Deprecated.
MapViewSerializerSnapshot<K,V>	Deprecated.
MapViewTypeInfo<K,V>	Deprecated.
MapViewTypeInfoFactory<K,V>	Deprecated.
MatchFamilyTypeStrategy	Type strategy that returns the given argument if it is of the same logical type family.
MissingTypeStrategy	Placeholder for a missing type strategy.
Module	Modules define a set of metadata, including functions, user defined types, operators, rules, etc.
ModuleException	Exception related to modules.
ModuleFactory	A factory to create configured module instances based on string-based properties.
ModuleFactory.Context	Context provided when a module is created.
MultisetType	Logical type of a multiset (=bag).
NestedFieldsProjectableTableSource<T>	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
NestedRowData	Its memory storage structure is exactly the same with BinaryRowData.
NoMatchingTableFactoryException	Deprecated. This exception is considered internal and has been erroneously placed in the *.api package.
NoMatchingTableFactoryException	Exception for not finding a TableFactory for the given properties.
NullableIfArgsTypeStrategy	A type strategy that can be used to make a result type nullable if any or all of the selected input arguments are nullable.
NullAwareGetters	Provides null related getters.
NullAwareMapSerializer<K,V>	Deprecated.
NullAwareMapSerializerSnapshot<K,V>	Deprecated.
NullSerializer	A serializer for null.
NullSerializer.NullSerializerSnapshot	Serializer configuration snapshot for compatibility and format evolution.
NullType	Logical type for representing untyped NULL values.
ObjectIdentifier	Identifies an object in a catalog.
ObjectPath	A database name and object (table/view/function) name combo in a catalog.
OrArgumentTypeStrategy	Strategy for inferring and validating an argument using a disjunction of multiple ArgumentTypeStrategys into one like f(NUMERIC || STRING).
OrInputTypeStrategy	Strategy for inferring and validating the input using a disjunction of multiple InputTypeStrategys into one like f(NUMERIC) || f(STRING).
OutputArgumentTypeStrategy	Strategy for inferring an unknown argument type from the function's output DataType if available.
OutputFormatProvider	Provider of an OutputFormat instance as a runtime implementation for DynamicTableSink.
OverwritableTableSink	Deprecated. This interface will not be supported in the new sink design around DynamicTableSink.
ParallelismProvider	Parallelism provider for other connector providers.
PartialCachingAsyncLookupProvider	Provider for creating AsyncLookupFunction and LookupCache for storing lookup entries.
PartialCachingLookupProvider	Provider for creating LookupFunction and LookupCache for storing lookup entries.
PartitionableTableSink	Deprecated. This interface will not be supported in the new sink design around DynamicTableSink.
PartitionableTableSource	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
PartitionAlreadyExistsException	Exception for trying to create a partition that already exists.
PartitionNotExistException	Exception for operation on a partition that doesn't exist.
PartitionPathUtils	Utils for file system.
PartitionSpecInvalidException	Exception for invalid PartitionSpec compared with partition key list of a partitioned Table.
PeriodicCacheReloadTrigger	A trigger that reloads cache entries periodically with specified interval and PeriodicCacheReloadTrigger.ScheduleMode.
PeriodicCacheReloadTrigger.ScheduleMode	Defines the mode how to schedule cache reloads.
PreserveWatermarks	A strategy which indicates the watermarks should be preserved from the underlying datastream.
PrintStyle	A PrintStyle defines style and formatting to print a collection of RowData.
Procedure	Base interface representing a stored procedure that can be executed by Flink.
ProcedureDefinition	Definition of a procedure.
ProcedureHint	A hint that influences the reflection-based extraction of input types and output types for constructing the TypeInference logic of a Procedure.
ProcedureHints	Helper annotation for repeatable ProcedureHints.
ProcedureNotExistException	Exception for trying to operate on a procedure that doesn't exist.
ProjectableDecodingFormat<I>	Extension of DecodingFormat which is able to produce projected rows.
ProjectableTableSource<T>	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
ProjectedRowData	An implementation of RowData which provides a projected view of the underlying RowData.
Projection	Projection represents a list of (possibly nested) indexes that can be used to project data types.
PythonAggregateFunction	The wrapper of user defined python aggregate function.
PythonAggregateFunctionInfo	PythonAggregateFunctionInfo contains the execution information of a Python aggregate function, such as: the actual Python aggregation function, the input arguments, the filter arg, the distinct flag, etc.
PythonEnv	Python execution environments.
PythonEnv.ExecType	The Execution type specifies how to execute the Python function.
PythonFunction	The base interface of a wrapper of a Python function.
PythonFunctionInfo	PythonFunctionInfo contains the execution information of a Python function, such as: the actual Python function, the input arguments, etc.
PythonFunctionKind	Categorizes the Python functions.
PythonFunctionUtils	Utilities for creating PythonFunction from the fully qualified name of a Python function.
PythonScalarFunction	The wrapper of user defined python scalar function.
PythonTableAggregateFunction	The wrapper of user defined python table aggregate function.
PythonTableFunction	The wrapper of user defined python table function.
RawContentStyle	Print only the result content as raw form.
RawType<T>	Logical type of an arbitrary serialized type.
RawValueData<T>	An internal data structure representing data of RawType.
RepeatingSequenceInputTypeStrategy	InputTypeStrategy composed of an arbitrarily often repeating list of ArgumentTypeStrategys.
RequireCatalogLock	Deprecated. This interface will be removed soon.
ResolvedCatalogBaseTable<T extends CatalogBaseTable>	A common parent that describes the resolved metadata of a table or view in a catalog.
ResolvedCatalogTable	A validated CatalogTable that is backed by the original metadata coming from the Catalog but resolved by the framework.
ResolvedCatalogView	A validated CatalogView that is backed by the original metadata coming from the Catalog but resolved by the framework.
ResolvedExpression	Expression that has been fully resolved and validated.
ResolvedFieldReference	A reference to a field in an input which has been resolved.
ResolvedSchema	Schema of a table or view consisting of columns, constraints, and watermark specifications.
ResourceType	An enum that represents the type of resource.
ResourceUri	Description of resource information.
RootArgumentTypeStrategy	Strategy for an argument that corresponds to a given LogicalTypeRoot and nullability.
RowColumnVector	Row column vector.
RowData	Base interface for an internal data structure representing data of RowType and other (possibly nested) structured types such as StructuredType in the table ecosystem.
RowData.FieldGetter	Accessor for getting the field of a row during runtime.
RowDataToStringConverter	Interface to convert RowData to String using the SQL casting rules.
RowLevelModificationScanContext	The context is intended to provide the relevant table scan information needed by the sink to perform row-level update/delete.
Rowtime	Deprecated. This class was used for legacy connectors using Descriptor.
RowtimeAttributeDescriptor	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
RowType	Logical type of a sequence of fields.
RowType.RowField	Describes a field of a RowType.
RuntimeConverter	Base interface for converting data during runtime.
RuntimeConverter.Context	Context for conversions during runtime.
ScalarFunction	Base class for a user-defined scalar function.
ScalarFunctionDefinition	Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
ScanTableSource	A DynamicTableSource that scans all rows from an external storage system during runtime.
ScanTableSource.ScanContext	Context for creating runtime implementation via a ScanTableSource.ScanRuntimeProvider.
ScanTableSource.ScanRuntimeProvider	Provides actual runtime implementation for reading the data.
Schema	Schema of a table or view.
Schema	Deprecated. This class was used for legacy connectors using Descriptor.
Schema.Builder	A builder for constructing an immutable but still unresolved Schema.
Schema.UnresolvedColumn	Super class for all kinds of columns in an unresolved schema.
Schema.UnresolvedComputedColumn	Declaration of a computed column that will be resolved to Column.ComputedColumn during schema resolution.
Schema.UnresolvedConstraint	Super class for all kinds of constraints in an unresolved schema.
Schema.UnresolvedMetadataColumn	Declaration of a metadata column that will be resolved to Column.MetadataColumn during schema resolution.
Schema.UnresolvedPhysicalColumn	Declaration of a physical column that will be resolved to Column.PhysicalColumn during schema resolution.
Schema.UnresolvedPrimaryKey	Declaration of a primary key that will be resolved to UniqueConstraint during schema resolution.
Schema.UnresolvedWatermarkSpec	Declaration of a watermark strategy that will be resolved to WatermarkSpec during schema resolution.
SchemaResolver	Resolves a Schema to a validated ResolvedSchema.
SequenceInputTypeStrategy	Strategy for inferring and validating a function signature like f(STRING, NUMERIC) or f(s STRING, n NUMERIC) using a sequence of ArgumentTypeStrategys.
SerializationFormatFactory	Factory for creating a EncodingFormat for SerializationSchema.
ShortColumnVector	Short column vector.
Signature	Describes the signature of a function.
Signature.Argument	Representation of a single argument in a signature.
SinkProvider	Deprecated. Please convert your sink to Sink and use SinkV2Provider.
SinkStagingContext	Implementation of SupportsStaging.StagingContext.
SinkV2Provider	Provider of a Sink instance as a runtime implementation for DynamicTableSink.
SmallIntType	Logical type of a 2-byte signed integer with values from -32,768 to 32,767.
SourceProvider	Provider of a Source instance as a runtime implementation for ScanTableSource.
SpecializedFunction	A FunctionDefinition that can provide a runtime implementation (i.e.
SpecializedFunction.ExpressionEvaluator	Serializable factory that can be passed into a UserDefinedFunction for evaluating previously defined expression during runtime.
SpecializedFunction.ExpressionEvaluatorFactory	Helper interface for creating SpecializedFunction.ExpressionEvaluators.
SpecializedFunction.SpecializedContext	Provides call and session information for the specialized function.
SpecificInputTypeStrategies	Entry point for specific input type strategies not covered in InputTypeStrategies.
SpecificTypeStrategies	Entry point for specific type strategies not covered in TypeStrategies.
SqlCallExpression	A call to a SQL expression.
StagedTable	The StagedTable is designed to implement Flink's atomic semantic for CTAS(CREATE TABLE AS SELECT) and RTAS([CREATE OR] REPLACE TABLE AS SELECT) statement using a two-phase commit protocol.
StringData	An internal data structure representing data of CharType and VarCharType.
StructuredType	Logical type of a user-defined object structured type.
StructuredType.Builder	A builder for a StructuredType.
StructuredType.StructuredAttribute	Defines an attribute of a StructuredType.
StructuredType.StructuredComparison	Defines equality properties for scalar evaluation.
SubsequenceInputTypeStrategy	An InputTypeStrategy that lets you apply other strategies for subsequences of the actual arguments.
SubsequenceInputTypeStrategy.SubsequenceStrategyBuilder	A Builder for SubsequenceInputTypeStrategy.
SupportsAggregatePushDown	Enables to push down the local aggregates into a ScanTableSource.
SupportsDeletePushDown	Enables to push down filters decomposed from the WHERE clause in delete statement to DynamicTableSink.
SupportsDynamicFiltering	Pushes dynamic filter into ScanTableSource, the table source can filter the partitions even the input data in runtime to reduce scan I/O.
SupportsFilterPushDown	Enables to push down filters into a ScanTableSource.
SupportsFilterPushDown.Result	Result of a filter push down.
SupportsLimitPushDown	Enables to push down a limit (the expected maximum number of produced records) into a ScanTableSource.
SupportsOverwrite	Enables to overwrite existing data in a DynamicTableSink.
SupportsPartitioning	Enables to write partitioned data in a DynamicTableSink.
SupportsPartitionPushDown	Enables to pass available partitions to the planner and push down partitions into a ScanTableSource.
SupportsProjectionPushDown	Enables to push down a (possibly nested) projection into a ScanTableSource.
SupportsReadingMetadata	Interface for ScanTableSources that support reading metadata columns.
SupportsRowLevelDelete	Interface for DynamicTableSinks that support delete existing data according to row-level changes.
SupportsRowLevelDelete.RowLevelDeleteInfo	The information that guides the planner on how to rewrite the delete statement.
SupportsRowLevelDelete.RowLevelDeleteMode	Type of delete modes that the sink expects for delete purpose.
SupportsRowLevelModificationScan	Interface for ScanTableSources that support the row-level modification.
SupportsRowLevelModificationScan.RowLevelModificationType	Type of the row-level modification for table.
SupportsRowLevelUpdate	Interface for DynamicTableSinks that support update existing data according to row-level changes.
SupportsRowLevelUpdate.RowLevelUpdateInfo	The information that guides the planner on how to rewrite the update statement.
SupportsRowLevelUpdate.RowLevelUpdateMode	Type of update modes that the sink expects for update purpose.
SupportsSourceWatermark	Enables to fully rely on the watermark strategy provided by the ScanTableSource itself.
SupportsStaging	Interface for DynamicTableSinks that support atomic semantic for CTAS(CREATE TABLE AS SELECT) or RTAS([CREATE OR] REPLACE TABLE AS SELECT) statement using a two-phase commit protocol.
SupportsStaging.StagingContext	The context is intended to tell DynamicTableSink the type of this operation.
SupportsStaging.StagingPurpose	The type of operation the staging sink is for.
SupportsStatisticReport	Enables to report the estimated statistics provided by the DynamicTableSource.
SupportsTruncate	Enables to delete all existing data in a DynamicTableSink table using TRUNCATE TABLE statement.
SupportsWatermarkPushDown	Enables to push down a watermark strategy into a ScanTableSource.
SupportsWritingMetadata	Interface for DynamicTableSinks that support writing metadata columns.
SymbolArgumentTypeStrategy<T extends Enum<? extends TableSymbol>>	Strategy for a symbol argument of a specific TableSymbol enum.
SymbolType<T extends TableSymbol>	Logical type for representing symbol values.
TableAggregateFunction<T,ACC>	Base class for a user-defined table aggregate function.
TableAggregateFunction.RetractableCollector<T>	Collects a record and forwards it.
TableAggregateFunctionDefinition	Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
TableAlreadyExistException	Exception for trying to create a table (or view) that already exists.
TableauStyle	Print the result and content as tableau form.
TableChange	TableChange represents the modification of the table.
TableChange.AddColumn	A table change to add a column.
TableChange.AddUniqueConstraint	A table change to add a unique constraint.
TableChange.AddWatermark	A table change to add a watermark.
TableChange.After	Column position AFTER means the specified column should be put after the given `column`.
TableChange.ColumnPosition	The position of the modified or added column.
TableChange.DropColumn	A table change to drop the column.
TableChange.DropConstraint	A table change to drop the constraints.
TableChange.DropWatermark	A table change to drop the watermark.
TableChange.First	Column position FIRST means the specified column should be the first column.
TableChange.ModifyColumn	A base schema change to modify a column.
TableChange.ModifyColumnComment	A table change to modify the column comment.
TableChange.ModifyColumnName	A table change to modify the column name.
TableChange.ModifyColumnPosition	A table change to modify the column position.
TableChange.ModifyPhysicalColumnType	A table change that modify the physical column data type.
TableChange.ModifyUniqueConstraint	A table change to modify a unique constraint.
TableChange.ModifyWatermark	A table change to modify the watermark.
TableChange.ResetOption	A table change to reset the table option.
TableChange.SetOption	A table change to set the table option.
TableColumn	Deprecated. See ResolvedSchema and Column.
TableColumn.ComputedColumn	Representation of a computed column.
TableColumn.MetadataColumn	Representation of a metadata column.
TableColumn.PhysicalColumn	Representation of a physical column.
TableConnectorUtils	Utilities for table sources and sinks.
TableException	General Exception for all errors during table handling.
TableFactory	Deprecated. This interface has been replaced by Factory.
TableFactoryService	Deprecated.
TableFunction<T>	Base class for a user-defined table function.
TableFunctionDefinition	Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
TableFunctionProvider<T>	Deprecated. Please use LookupFunctionProvider to implement synchronous lookup table.
TableNotExistException	Exception for an operation on a nonexistent table.
TableNotExistException	Exception for trying to operate on a table (or view) that doesn't exist.
TableNotPartitionedException	Exception for trying to operate partition on a non-partitioned table.
TablePartitionedException	Exception for trying to operate non-partitioned on a partitioned table.
TableSchema	Deprecated. This class has been deprecated as part of FLIP-164.
TableSchema.Builder	Builder for creating a TableSchema.
TableSchemaUtils	Utilities to TableSchema.
TableSink<T>	Deprecated. This interface has been replaced by DynamicTableSink.
TableSinkBase<T>	Deprecated. This class is implementing the deprecated TableSink interface.
TableSinkFactory<T>	Deprecated. This interface has been replaced by DynamicTableSinkFactory.
TableSinkFactory.Context	Context of table sink creation.
TableSinkFactoryContextImpl	Deprecated.
TableSource<T>	Deprecated. This interface has been replaced by DynamicTableSource.
TableSourceFactory<T>	Deprecated. This interface has been replaced by DynamicTableSourceFactory.
TableSourceFactory.Context	Context of table source creation.
TableSourceFactoryContextImpl	Deprecated.
TableSourceValidation	Logic to validate TableSource types.
TableStats	Table statistics.
TableSymbol	The base interface for all table symbols.
TemporalTableFunction	Class representing temporal table function over some history table.
TemporaryOperationListener	This interface is for a Catalog to listen on temporary object operations.
ThreadLocalCache<K,V>	Provides a thread local cache with a maximum cache size per thread.
TimedCacheReloadTrigger	A trigger that reloads at a specific time and repeats for the given interval in days.
TimeIndicatorTypeInfo	Deprecated. This class will be removed in future versions as it is used for the old type system.
TimeIntervalTypeInfo<T>	Deprecated. This class will be removed in future versions as it is used for the old type system.
TimeIntervalUnit	Units for working with time intervals.
TimePointUnit	Units for working with points in time.
TimestampColumnVector	Timestamp column vector.
TimestampData	An internal data structure representing data of TimestampType and LocalZonedTimestampType.
TimestampExtractor	Deprecated. This interface will not be supported in the new source design around DynamicTableSource.
TimestampExtractorUtils	Utility methods for dealing with TimestampExtractor.
TimestampKind	Internal timestamp kind for attaching time attribute metadata to timestamps with or without a time zone.
TimestampType	Logical 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.
TimeType	Logical 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.
TinyIntType	Logical type of a 1-byte signed integer with values from -128 to 127.
ToTimestampLtzTypeStrategy	Type strategy of TO_TIMESTAMP_LTZ.
TypeConversions	Conversion hub for interoperability of Class, TypeInformation, DataType, and LogicalType.
TypedSetters	Provide type specialized setters to reduce if/else and eliminate box and unbox.
TypeInference	Provides logic for the type inference of function calls.
TypeInference.Builder	Builder for configuring and creating instances of TypeInference.
TypeInferenceExtractor	Reflection-based utility for extracting a TypeInference from a supported subclass of UserDefinedFunction.
TypeInferenceUtil	Utility for performing type inference.
TypeInferenceUtil.Result	The result of a type inference run.
TypeInferenceUtil.SurroundingInfo	Information what the outer world (i.e.
TypeInfoDataTypeConverter	Converter from TypeInformation to DataType.
TypeInformationRawType<T>	Deprecated. Use RawType instead.
TypeLiteralArgumentTypeStrategy	Strategy that checks if an argument is a type literal.
TypeLiteralExpression	Expression that wraps DataType as a literal.
TypeMappingUtils	Utility methods for dealing with field types in TableSource and TableSink.
Types	Deprecated. This class will be removed in future versions as it uses the old type system.
TypeStrategies	Strategies for inferring an output or accumulator data type of a function call.
TypeStrategy	Strategy for inferring the data type of a function call.
TypeStringUtils	Deprecated. This utility is based on TypeInformation.
TypeTransformation	Transforms one data type to another.
TypeTransformations	Transformations for transforming one data type to another.
UniqueConstraint	Deprecated. See ResolvedSchema and UniqueConstraint.
UniqueConstraint	A unique key constraint.
UnknownCallContext	A CallContext with unknown data types.
UnresolvedDataType	Partially resolved data type that requires a lookup in a catalog or configuration before creating the corresponding LogicalType.
UnresolvedIdentifier	Identifier of an object, such as table, view, function or type in a catalog.
UnresolvedUserDefinedType	Placeholder type of an unresolved user-defined type that is identified by an UnresolvedIdentifier.
UserDefinedFunction	Base class for all user-defined functions.
UserDefinedFunctionHelper	Utility for dealing with subclasses of UserDefinedFunction.
UserDefinedType	Logical type of a user-defined representation for one or more built-in types.
ValidationException	Exception for all errors occurring during validation phase.
ValueDataTypeConverter	Value-based data type extractor that supports extraction of clearly identifiable data types for input conversion.
ValueLiteralExpression	Expression for constant literal values.
VarBinaryType	Logical type of a variable-length binary string (=a sequence of bytes).
VarCharType	Logical type of a variable-length character string.
VaryingSequenceInputTypeStrategy	Strategy for inferring and validating a varying function signature like f(INT, STRING, NUMERIC...) or f(i INT, str STRING, num NUMERIC...) using a sequence of ArgumentTypeStrategys.
VaryingStringTypeStrategy	A type strategy that ensures that the result type is either LogicalTypeRoot.VARCHAR or LogicalTypeRoot.VARBINARY from their corresponding non-varying roots.
VectorizedColumnBatch	A VectorizedColumnBatch is a set of rows, organized with each column as a vector.
WatermarkEmitStrategy	The strategy for emitting watermark.
WatermarkParams	Pojo class for watermark configs from table options or 'OPTIONS' hint.
WatermarkParams.WatermarkParamsBuilder	Builder of WatermarkHintParams.
WatermarkSpec	Deprecated. See ResolvedSchema and WatermarkSpec.
WatermarkSpec	Representation of a watermark specification in a ResolvedSchema.
WatermarkStrategy	Provides a strategy to generate watermarks for a rowtime attribute.
WildcardInputTypeStrategy	Strategy that does not perform any modification or validation of the input.
WritableBooleanVector	Writable BooleanColumnVector.
WritableBytesVector	Writable BytesColumnVector.
WritableByteVector	Writable ByteColumnVector.
WritableColumnVector	Writable ColumnVector.
WritableDoubleVector	Writable DoubleColumnVector.
WritableFloatVector	Writable FloatColumnVector.
WritableIntVector	Writable IntColumnVector.
WritableLongVector	Writable LongColumnVector.
WritableShortVector	Writable ShortColumnVector.
WritableTimestampVector	Writable TimestampColumnVector.
YearMonthIntervalType	Logical type for a group of year-month interval types.
YearMonthIntervalType.YearMonthResolution	Supported resolutions of this type.
ZonedTimestampType	Logical 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.