All Classes and Interfaces

Class	Description
AbstractDataType<T extends AbstractDataType<T>>	Highest abstraction that describes the data type of a value in the table ecosystem.
ActionCompletedException	Exception thrown when an action (e.g., stop or delete) completes.
AggregatedTable	A table that has been performed on the aggregate function.
AggregatePhaseStrategy	Aggregate phase strategy which could be specified in OptimizerConfigOptions.TABLE_OPTIMIZER_AGG_PHASE_STRATEGY.
ApiExpression	Java API class that gives access to expression operations.
ArgumentTrait	Declares traits for ArgumentHint.
ArrayType	Logical type of an array of elements with same subtype.
AuthMode	Authentication mode for the Confluent Cloud.
BaseExpressions<InType,OutType>	These are Java and Scala common operations that can be used to construct an Expression AST for expression operations.
BuiltInFunctionDefinitions	Dictionary of function definitions for all built-in functions.
Catalog	This interface is responsible for reading and writing metadata such as database/table/views/UDFs from a registered catalog.
CatalogDescriptor	Describes a Catalog with the catalog name and configuration.
CatalogFunction	Interface for a function in a catalog.
CatalogModel	Interface for a model in a catalog.
CatalogStore	Represents the storage where persists all Catalogs.
CatalogTable	Represents the unresolved metadata of a table in a Catalog.
CatalogTable.Builder	Builder for configuring and creating instances of CatalogTable.
ChangelogMode	The set of changes contained in a changelog.
ChangelogMode.Builder	Builder for configuring and creating instances of ChangelogMode.
CloseableIterator<T>	This interface represents an Iterator that is also AutoCloseable.
CloseableIterator.IteratorAdapter<E>	Adapter from Iterator to CloseableIterator.
Collector<T>	Collects a record and forwards it.
ColumnList	Represents a list of columns.
ConfigOption<T>	A ConfigOption describes a configuration parameter.
ConfigOptions	ConfigOptions are used to build a ConfigOption.
ConfigOptions.ListConfigOptionBuilder<E>	Builder for ConfigOption of list of type ConfigOptions.ListConfigOptionBuilder.
ConfigOptions.OptionBuilder	The option builder is used to create a ConfigOption.
ConfigOptions.TypedConfigOptionBuilder<T>	Builder for ConfigOption with a defined atomic type.
Configuration	Lightweight configuration object which stores key/value pairs.
ConfluentFlinkException	General exception for errors originating from the Confluent Flink plugin.
ConfluentMLExpressions	Entry point of the ML Function Expression DSL for Confluent Flink ML functions.
ConfluentPluginOptions	List of client-specific options.
ConfluentSettings	Entrypoint for Confluent-specific EnvironmentSettings.
ConfluentSettings.Builder	Builder pattern for a fluent definition of Confluent-specific EnvironmentSettings.
ConfluentTableDescriptor	A TableDescriptor for creating tables located in Confluent Cloud programmatically.
ConfluentTableDescriptor.Builder	Builder for ConfluentTableDescriptor.
ConfluentTools	Various tools that help developing and testing Table API programs on Confluent Cloud.
DataType	Describes the data type of a value in the table ecosystem.
DataTypeFactory	Factory for creating fully resolved data types that can be used for planning.
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.
DescribedEnum	Describe enum constants used in ConfigOptions.
Description	Description for ConfigOption.
Description.DescriptionBuilder	Builder for Description.
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.
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.
EnvironmentSettings	Defines all parameters that initialize a table environment.
EnvironmentSettings.Builder	A builder for EnvironmentSettings.
Executable	Represents an artifact that can be executed.
ExecutionConfigOptions	This class holds configuration constants used by Flink's table module.
ExecutionConfigOptions.AsyncOutputMode	Output mode for asynchronous operations, equivalent to .
ExecutionConfigOptions.LegacyCastBehaviour	Deprecated.
ExecutionConfigOptions.NestedEnforcer	The enforcer to check the constraints on nested types.
ExecutionConfigOptions.NotNullEnforcer	The enforcer to guarantee NOT NULL column constraint when writing data into sink.
ExecutionConfigOptions.RetryStrategy	Retry strategy in the case of failure.
ExecutionConfigOptions.RowtimeInserter	Rowtime attribute insertion strategy for the sink.
ExecutionConfigOptions.SinkKeyedShuffle	Shuffle by primary key before sink.
ExecutionConfigOptions.SinkUpsertMaterializeStrategy	SinkUpsertMaterializer strategy.
ExecutionConfigOptions.TypeLengthEnforcer	The enforcer to guarantee that length of CHAR/VARCHAR/BINARY/VARBINARY columns is respected when writing data into a sink.
ExecutionConfigOptions.UidGeneration	Strategy for generating transformation UIDs for remapping state to operators during restore.
ExecutionConfigOptions.UpsertMaterialize	Upsert materialize strategy before sink.
Experimental	Annotation to mark classes for experimental use.
Explainable<SELF extends Explainable<SELF>>	Represents an artifact that can be explained using a summary string.
ExplainDetail	ExplainDetail defines the types of details for explain result.
ExplainFormat	Explain format categorizes the output format of explain result.
Expression	General interface for all kinds of expressions.
Expressions	Entry point of the Table API Expression DSL such as: $("myField").plus(10).abs()
ExpressionVisitor<R>	The visitor definition of Expression.
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.DefaultModelProviderContext	Default implementation of ModelProviderFactory.Context.
FactoryUtil.DefaultModuleContext	Default implementation of ModuleFactory.Context.
FactoryUtil.DefaultSecretStoreContext	Default implementation of SecretStoreFactory.Context.
FactoryUtil.FactoryHelper<F extends org.apache.flink.table.factories.Factory>	Base helper utility for validating all options for a Factory.
FactoryUtil.ModelProviderFactoryHelper	Helper utility for validating all options for a ModelProviderFactory.
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.
FieldsDataType	A data type that contains field data types (i.e. row and structured type).
FlatAggregateTable	A table that performs flatAggregate on a Table, a GroupedTable or a WindowGroupedTable.
Format	Base interface for connector formats.
FormatDescriptor	Describes a format and its options for use with TableDescriptor.
FormatDescriptor.Builder	Builder for FormatDescriptor.
Formatter	Allows providing multiple formatters for the description.
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.
FunctionDescriptor	Describes a CatalogFunction.
FunctionDescriptor.Builder	Builder for FunctionDescriptor.
FunctionKind	Categorizes the semantics of a FunctionDefinition.
FunctionLanguage	Categorizes the language semantics of a CatalogFunction.
GroupedTable	A table that has been grouped on a set of grouping keys.
GroupWindow	A group window specification.
GroupWindowedTable	A table that has been windowed for GroupWindows.
InlineElement	Part of description that represents an element inside a block e.g. a link.
InsertConflictStrategy	Defines the conflict resolution strategies for INSERT INTO statements when the query's upsert key differs from the target table's primary key.
InsertConflictStrategy.Builder	Builder for creating InsertConflictStrategy instances.
InsertConflictStrategy.ConflictBehavior	Defines the basic conflict resolution behaviors.
Internal	Annotation to mark methods within stable, public APIs as an internal developer API.
JobClient	A client that is scoped to a specific job.
JsonExistsOnError	Behavior in case of errors for BuiltInFunctionDefinitions.JSON_EXISTS.
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.
ListView<T>	A DataView that provides List-like functionality in state entries.
LogicalType	A logical type that describes the data type of a value.
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 state entries.
MemorySize	MemorySize is a representation of a number of bytes, viewable in different units.
MemorySize.MemoryUnit	Enum which defines memory unit, mostly used to parse value from configuration file.
MLPredictRuntimeConfigOptions	This class holds option name definitions for ML_PREDICT runtime config based on ConfigOption.
Model	The Model object is the core abstraction for ML model resources in the Table API.
ModelDescriptor	Describes a CatalogModel representing a model.
ModelDescriptor.Builder	Builder for ModelDescriptor.
Module	Modules define a set of metadata, including functions, user defined types, operators, rules, etc.
ModuleEntry	A POJO to represent a module's name and use status.
OAuthToken	An OAuth bearer token returned by an OAuthTokenProvider.
OAuthTokenProvider	Supplies OAuth bearer tokens to the plugin on demand.
ObjectIdentifier	Identifies an object in a catalog.
OnConflictMode	Behavior when updating a statement fails.
Operation	Covers all sort of Table operations such as queries(DQL), modifications(DML), definitions(DDL), or control actions(DCL).
OptimizerConfigOptions	This class holds configuration constants used by Flink's table planner module.
OptimizerConfigOptions.AdaptiveBroadcastJoinStrategy	Strategies used for OptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_BROADCAST_JOIN_STRATEGY.
OptimizerConfigOptions.AdaptiveSkewedJoinOptimizationStrategy	Strategies used for OptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_STRATEGY.
OptimizerConfigOptions.DeltaJoinStrategy	Strategy for delta join.
OptimizerConfigOptions.NonDeterministicUpdateStrategy	Strategy for handling non-deterministic updates.
Over	Helper class for creating an over window.
OverWindow	An over window specification.
OverWindowedTable	A table that has been windowed for OverWindows.
OverWindowPartitioned	Partially defined over window with partitioning.
OverWindowPartitionedOrdered	Partially defined over window with (optional) partitioning and order.
OverWindowPartitionedOrderedPreceding	Partially defined over window with (optional) partitioning, order, and preceding.
PartitionedTable	A table that has been partitioned by a set of partition keys.
PipelineOptions	The configuration options for job execution.
PipelineOptions.VertexDescriptionMode	The mode how we organize description of a vertex.
PlannerConfig	The PlannerConfig holds parameters to configure the behavior of queries.
PluginAction	Lifecycle actions for CI/CD integration.
ProcessTableFunction<T>	Base class for a user-defined process table function (PTF).
ProcessTableFunction.Context	Context that can be added as a first argument to the eval() method for additional information about the input tables and other services provided by the framework.
ProcessTableFunction.OnTimerContext	Special ProcessTableFunction.Context that is available when the onTimer() method is called.
ProcessTableFunction.TimeContext<TimeType>	A context that gives access to Flink's concepts of time and timers.
ProcessTableFunctionTestHarness<OUT>	Test harness for ProcessTableFunction.
ProcessTableFunctionTestHarness.Builder<OUT>	Builder for ProcessTableFunctionTestHarness.
PublicEvolving	Annotation to mark classes and methods for public use, but with evolving interfaces.
QueryOperation	Base class for representing an operation structure behind a user-facing Table API.
ReadableConfig	Read access to a configuration object.
ResolvedExpression	Expression that has been fully resolved and validated.
ResolvedSchema	Schema of a table or view consisting of columns, constraints, and watermark specifications.
ResourceUri	Description of resource information.
ResultKind	ResultKind defines the types of the result.
Row	A row is a fixed-length, null-aware composite type for storing multiple values in a deterministic field order.
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.
RowKind	Lists all kinds of changes that a row can describe in a changelog.
RowType	Logical type of a sequence of fields.
RowType.RowField	Describes a field of a RowType.
ScalarFunction	Base class for a user-defined scalar function.
Schema	Schema of a table or view.
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.UnresolvedImmutableColumns	Declaration of a list of immutable columns that will be resolved to ImmutableColumnsConstraint during schema resolution.
Schema.UnresolvedIndex	Declaration of an index that will be resolved to Index during schema resolution.
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.
SecretStore	Base marker interface for secret store implementations.
Session	Helper class for creating a session window.
SessionWithGap	Session window.
SessionWithGapOnTime	Session window on time.
SessionWithGapOnTimeWithAlias	Session window on time with alias.
Slide	Helper class for creating a sliding window.
SlideWithSize	Partially specified sliding window.
SlideWithSizeAndSlide	Sliding window.
SlideWithSizeAndSlideOnTime	Sliding window on time.
SlideWithSizeAndSlideOnTimeWithAlias	Sliding window on time with alias.
SqlCallExpression	A call to a SQL expression.
SqlDialect	Enumeration of valid SQL compatibility modes.
SqlFactory	Factory for serializing ResolvedExpression to a string.
SqlTimeTypeInfo<T>	Type information for Java SQL Date/Time/Timestamp.
StatementHandle	A handle to manage a Flink SQL statement on Confluent Cloud.
StatementSet	A StatementSet accepts pipelines defined by DML statements or Table objects.
StatementWarning	Represents a non-fatal issue encountered during statement processing.
StatementWarning.Severity	Warning severity levels.
StateTypeStrategy	Strategy for inferring a function call's intermediate result data type (i.e. state entry).
StaticArgument	Describes an argument in a static signature that is not overloaded and does not support varargs.
StaticArgumentTrait	Declares traits for StaticArgument.
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.
SupportsSourceWatermark	Enables to fully rely on the watermark strategy provided by the ScanTableSource itself.
Table	The Table object is the core abstraction of the Table API.
TableConfig	Configuration for the current TableEnvironment session to adjust Table & SQL API programs.
TableConfigOptions	This class holds ConfigOptions used by table planner.
TableConfigOptions.CatalogPlanCompilation	Strategy to compile Catalog objects into a plan.
TableConfigOptions.CatalogPlanRestore	Strategy to restore Catalog objects using the plan and lookups if necessary.
TableConfigOptions.ColumnExpansionStrategy	Strategy to expand columns in SELECT * queries.
TableDescriptor	Describes a CatalogTable representing a source or sink.
TableDescriptor.Builder	Builder for TableDescriptor.
TableDistribution	Defines whether the given table is distributed across buckets using a specified algorithm and given columns.
TableDistribution.Kind	Distribution kind.
TableEnvironment	A table environment is the base class, entry point, and central context for creating Table and SQL API programs.
TableFunction<T>	Base class for a user-defined table function.
TablePipeline	Describes a complete pipeline from one or more source tables to a sink table.
TableResult	A TableResult is the representation of the statement execution result.
TableSemantics	Provides call information about the table that has been passed to a table argument.
TableSemantics.SortDirection	The sort direction for ORDER BY columns in table arguments with set semantics.
TemporalTableFunction	Class representing temporal table function over some history table.
TextElement	Represents a text block in the Description.
TextElement.TextStyle	Styles that can be applied to TextElement e.g. code, bold etc.
TimeIntervalUnit	Units for working with time intervals.
TimePointUnit	Units for working with points in time.
Timer	A timer registered by a ProcessTableFunction during testing.
Tumble	Helper class for creating a tumbling window.
TumbleWithSize	Tumbling window.
TumbleWithSizeOnTime	Tumbling window on time.
TumbleWithSizeOnTimeWithAlias	Tumbling window on time with alias.
TypeInference	Provides logic for the type inference of function calls.
TypeInference.Builder	Builder for configuring and creating instances of TypeInference.
TypeInformation<T>	TypeInformation is the core class of Flink's type system.
TypeStrategy	Strategy for inferring a function call's result data type.
UnresolvedDataType	Partially resolved data type that requires a lookup in a catalog or configuration before creating the corresponding LogicalType.
UserDefinedFunction	Base class for all user-defined functions.
WindowGroupedTable	A table that has been windowed and grouped for GroupWindows.
WritableConfig	Write access to a configuration object.