Uses of Annotation Type
org.apache.flink.annotation.PublicEvolving
Packages that use PublicEvolving
Package
Description
-
Uses of PublicEvolving in io.confluent.flink.plugin
Classes in io.confluent.flink.plugin with annotations of type PublicEvolvingModifier and TypeClassDescriptionfinal classEntry point of the ML Function Expression DSL for Confluent Flink ML functions. -
Uses of PublicEvolving in org.apache.flink.api.common.typeinfo
Classes in org.apache.flink.api.common.typeinfo with annotations of type PublicEvolvingModifier and TypeClassDescriptionclassType information for Java SQL Date/Time/Timestamp.Methods in org.apache.flink.api.common.typeinfo with annotations of type PublicEvolvingModifier and TypeMethodDescriptionabstract org.apache.flink.api.common.typeutils.TypeSerializer<T>TypeInformation.createSerializer(org.apache.flink.api.common.serialization.SerializerConfig config) Creates a serializer for the type.abstract intTypeInformation.getArity()Gets the arity of this type - the number of fields without nesting.Map<String,TypeInformation<?>> TypeInformation.getGenericParameters()Optional method for giving Flink's type extraction system information about the mapping of a generic type parameter to the type information of a subtype.abstract intTypeInformation.getTotalFields()Gets the number of logical fields in this type.TypeInformation.getTypeClass()Gets the class of the type represented by this type information.abstract booleanTypeInformation.isBasicType()Checks if this type information represents a basic type.abstract booleanTypeInformation.isKeyType()Checks whether this type can be used as a key.booleanTypeInformation.isSortKeyType()Checks whether this type can be used as a key for sorting.abstract booleanTypeInformation.isTupleType()Checks if this type information represents a Tuple type. -
Uses of PublicEvolving in org.apache.flink.configuration
Classes in org.apache.flink.configuration with annotations of type PublicEvolvingModifier and TypeClassDescriptionclassConfigOption<T>AConfigOptiondescribes a configuration parameter.classConfigOptionsare used to build aConfigOption.interfaceDescribe enum constants used inConfigOptions.classMemorySize is a representation of a number of bytes, viewable in different units.classTheconfiguration optionsfor job execution.static enumThe mode how we organize description of a vertex.interfaceRead access to a configuration object.interfaceWrite access to a configuration object.Methods in org.apache.flink.configuration with annotations of type PublicEvolvingModifier and TypeMethodDescriptionbooleanConfiguration.contains(ConfigOption<?> configOption) Checks whether there is an entry for the given config option.<T> TConfiguration.get(ConfigOption<T> configOption, T overrideDefault) Returns the value associated with the given config option as a T.<T extends Enum<T>>
TConfiguration.getEnum(Class<T> enumClass, ConfigOption<String> configOption) Returns the value associated with the given config option as an enum.Configuration.getValue(ConfigOption<?> configOption) Returns the value associated with the given config option as a string. -
Uses of PublicEvolving in org.apache.flink.configuration.description
Classes in org.apache.flink.configuration.description with annotations of type PublicEvolvingModifier and TypeClassDescriptionclassDescription forConfigOption.static classBuilder forDescription.classAllows providing multiple formatters for the description.interfacePart of description that represents an element inside a block e.g. a link.classRepresents a text block in theDescription.static enumStyles that can be applied toTextElemente.g. code, bold etc. -
Uses of PublicEvolving in org.apache.flink.core.execution
Classes in org.apache.flink.core.execution with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceA client that is scoped to a specific job. -
Uses of PublicEvolving in org.apache.flink.table.annotation
Classes in org.apache.flink.table.annotation with annotations of type PublicEvolving -
Uses of PublicEvolving in org.apache.flink.table.api
Classes in org.apache.flink.table.api with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceA table that has been performed on the aggregate function.final classJava API class that gives access to expression operations.final classADataTypecan be used to declare input and/or output types of operations.static classCommon helper class for resolved and unresolved fields of a row or structured type.static final classHelper class for defining the field of a row or structured type.static final classHelper class for defining the resolution of an interval.static final classHelper class for defining the unresolved field of a row or structured type.classDefines all parameters that initialize a table environment.static classA builder forEnvironmentSettings.interfaceRepresents an artifact that can be executed.interfaceExplainable<SELF extends Explainable<SELF>>Represents an artifact that can be explained using a summary string.enumExplainDetail defines the types of details for explain result.enumExplain format categorizes the output format of explain result.final classEntry point of the Table API Expression DSL such as:$("myField").plus(10).abs()interfacefinal classDescribes aformatand its options for use withTableDescriptor.static classBuilder forFormatDescriptor.classDescribes aCatalogFunction.static final classBuilder forFunctionDescriptor.interfaceA table that has been grouped on a set of grouping keys.classA group window specification.interfaceA table that has been windowed forGroupWindows.final classDefines the conflict resolution strategies for INSERT INTO statements when the query's upsert key differs from the target table's primary key.static final classBuilder for creatingInsertConflictStrategyinstances.static enumDefines the basic conflict resolution behaviors.enumBehavior in case of errors forBuiltInFunctionDefinitions.JSON_EXISTS.enumBehavior ofBuiltInFunctionDefinitions.JSON_QUERYin case a path expression is empty or raises an error.enumDefines whether and when to wrap the result ofBuiltInFunctionDefinitions.JSON_QUERYinto an array.enumSupported JSON types forBuiltInFunctionDefinitions.IS_JSON.enumBehavior forBuiltInFunctionDefinitions.JSON_VALUE.interfaceTheModelobject is the core abstraction for ML model resources in the Table API.classDescribes aCatalogModelrepresenting a model.static classBuilder forModelDescriptor.final classHelper class for creating an over window.final classAn over window specification.interfaceA table that has been windowed forOverWindows.final classPartially defined over window with partitioning.final classPartially defined over window with (optional) partitioning and order.final classPartially defined over window with (optional) partitioning, order, and preceding.interfaceA table that has been partitioned by a set of partition keys.interfaceThePlannerConfigholds parameters to configure the behavior of queries.enumResultKind defines the types of the result.final classSchema of a table or view.static final classA builder for constructing an immutable but still unresolvedSchema.static classSuper class for all kinds of columns in an unresolved schema.static final classDeclaration of a computed column that will be resolved toColumn.ComputedColumnduring schema resolution.static classSuper class for all kinds of constraints in an unresolved schema.static final classDeclaration of a list of immutable columns that will be resolved toImmutableColumnsConstraintduring schema resolution.static final classDeclaration of an index that will be resolved toIndexduring schema resolution.static final classDeclaration of a metadata column that will be resolved toColumn.MetadataColumnduring schema resolution.static final classDeclaration of a physical column that will be resolved toColumn.PhysicalColumnduring schema resolution.static final classDeclaration of a primary key that will be resolved toUniqueConstraintduring schema resolution.static final classDeclaration of a watermark strategy that will be resolved toWatermarkSpecduring schema resolution.final classHelper class for creating a session window.final classSession window.final classSession window on time.final classSession window on time with alias.final classHelper class for creating a sliding window.final classPartially specified sliding window.final classSliding window.final classSliding window on time.final classSliding window on time with alias.enumEnumeration of valid SQL compatibility modes.interfaceAStatementSetaccepts pipelines defined by DML statements orTableobjects.interfaceTheTableobject is the core abstraction of the Table API.final classConfiguration for the currentTableEnvironmentsession to adjust Table & SQL API programs.classDescribes aCatalogTablerepresenting a source or sink.static classBuilder forTableDescriptor.interfaceA table environment is the base class, entry point, and central context for creating Table and SQL API programs.interfaceDescribes a complete pipeline from one or more source tables to a sink table.interfaceA TableResult is the representation of the statement execution result.final classHelper class for creating a tumbling window.final classTumbling window.final classTumbling window on time.final classTumbling window on time with alias.interfaceA table that has been windowed and grouped forGroupWindows. -
Uses of PublicEvolving in org.apache.flink.table.api.config
Classes in org.apache.flink.table.api.config with annotations of type PublicEvolvingModifier and TypeClassDescriptionenumAggregate phase strategy which could be specified inOptimizerConfigOptions.TABLE_OPTIMIZER_AGG_PHASE_STRATEGY.classThis class holds configuration constants used by Flink's table module.static enumOutput mode for asynchronous operations, equivalent to .static enumThe enforcer to check the constraints on nested types.static enumThe enforcer to guarantee NOT NULL column constraint when writing data into sink.static enumRetry strategy in the case of failure.static enumRowtime attribute insertion strategy for the sink.static enumShuffle by primary key before sink.static enumSinkUpsertMaterializer strategy.static enumThe enforcer to guarantee that length of CHAR/VARCHAR/BINARY/VARBINARY columns is respected when writing data into a sink.static enumStrategy for generating transformation UIDs for remapping state to operators during restore.static enumUpsert materialize strategy before sink.classThis class holds option name definitions for ML_PREDICT runtime config based onConfigOption.classThis class holds configuration constants used by Flink's table planner module.static enumStrategies used forOptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_BROADCAST_JOIN_STRATEGY.static enumStrategies used forOptimizerConfigOptions.TABLE_OPTIMIZER_ADAPTIVE_SKEWED_JOIN_OPTIMIZATION_STRATEGY.static enumStrategy for delta join.static enumStrategy for handling non-deterministic updates.classThis class holdsConfigOptions used by table planner.static enumStrategy to compileCatalogobjects into a plan.static enumStrategy to restoreCatalogobjects using the plan and lookups if necessary.static enumStrategy to expand columns inSELECT *queries. -
Uses of PublicEvolving in org.apache.flink.table.api.dataview
Classes in org.apache.flink.table.api.dataview with annotations of type PublicEvolving -
Uses of PublicEvolving in org.apache.flink.table.api.internal
Classes in org.apache.flink.table.api.internal with annotations of type PublicEvolvingModifier and TypeClassDescriptionclassBaseExpressions<InType,OutType> These are Java and Scala common operations that can be used to construct anExpressionAST for expression operations. -
Uses of PublicEvolving in org.apache.flink.table.catalog
Classes in org.apache.flink.table.catalog with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceThis interface is responsible for reading and writing metadata such as database/table/views/UDFs from a registered catalog.classDescribes aCatalogwith the catalog name and configuration.interfaceInterface for a function in a catalog.interfaceInterface for a model in a catalog.interfaceRepresents the storage where persists allCatalogs.interfaceRepresents the unresolved metadata of a table in aCatalog.static classBuilder for configuring and creating instances ofCatalogTable.interfaceFactory for creating fully resolved data types that can be used for planning.enumCategorizes the language semantics of aCatalogFunction.final classIdentifies an object in a catalog.final classSchema of a table or view consisting of columns, constraints, and watermark specifications.classDefines whether the given table is distributed across buckets using a specified algorithm and given columns.static enumDistribution kind.Methods in org.apache.flink.table.catalog with annotations of type PublicEvolvingModifier and TypeMethodDescriptionstatic CatalogTable.BuilderCatalogTable.newBuilder()Builder for configuring and creating instances ofCatalogTable. -
Uses of PublicEvolving in org.apache.flink.table.connector
Classes in org.apache.flink.table.connector with annotations of type PublicEvolvingModifier and TypeClassDescriptionfinal classThe set of changes contained in a changelog.static classBuilder for configuring and creating instances ofChangelogMode. -
Uses of PublicEvolving in org.apache.flink.table.connector.format
Classes in org.apache.flink.table.connector.format with annotations of type PublicEvolving -
Uses of PublicEvolving in org.apache.flink.table.connector.sink
Classes in org.apache.flink.table.connector.sink with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceSink of a dynamic table to an external storage system.static interfaceContext for creating runtime implementation via aDynamicTableSink.SinkRuntimeProvider.static interfaceConverter for mapping between Flink's internal data structures and objects specified by the givenDataTypethat can be passed into a runtime implementation.static interfaceProvides actual runtime implementation for writing the data. -
Uses of PublicEvolving in org.apache.flink.table.connector.source
Classes in org.apache.flink.table.connector.source with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceSource of a dynamic table from an external storage system.static interfaceBase context for creating runtime implementation via aScanTableSource.ScanRuntimeProviderandLookupTableSource.LookupRuntimeProvider.static interfaceConverter for mapping between objects and Flink's internal data structures during runtime. -
Uses of PublicEvolving in org.apache.flink.table.connector.source.abilities
Classes in org.apache.flink.table.connector.source.abilities with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceEnables to fully rely on the watermark strategy provided by theScanTableSourceitself. -
Uses of PublicEvolving in org.apache.flink.table.data
Classes in org.apache.flink.table.data with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceBase interface for an internal data structure representing data ofRowTypeand other (possibly nested) structured types such asStructuredTypein the table ecosystem.static interfaceAccessor for getting the field of a row during runtime. -
Uses of PublicEvolving in org.apache.flink.table.expressions
Classes in org.apache.flink.table.expressions with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceGeneral interface for all kinds of expressions.interfaceThe visitor definition ofExpression.interfaceExpression that has been fully resolved and validated.final classA call to a SQL expression.interfaceFactory for serializingResolvedExpressionto a string.enumUnits for working with time intervals.enumUnits for working with points in time. -
Uses of PublicEvolving in org.apache.flink.table.factories
Classes in org.apache.flink.table.factories with annotations of type PublicEvolvingModifier and TypeClassDescriptionfinal classUtility for working withFactorys.static classHelper utility for validating all options for aCatalogFactory.static classHelper utility for validating all options for aCatalogStoreFactory.static classFactoryUtil.FactoryHelper<F extends org.apache.flink.table.factories.Factory>Base helper utility for validating all options for aFactory.static classHelper utility for validating all options for aModelProviderFactory.static classHelper utility for validating all options for aModuleFactory.static classHelper utility for discovering formats and validating all options for aDynamicTableFactory. -
Uses of PublicEvolving in org.apache.flink.table.functions
Classes in org.apache.flink.table.functions with annotations of type PublicEvolvingModifier and TypeClassDescriptionfinal classDictionary of function definitions for all built-in functions.classAFunctionContextallows to obtain global runtime information about the context in which the user-defined function is executed.interfaceDefinition of a function.enumCategorizes the semantics of aFunctionDefinition.classBase class for a user-defined process table function (PTF).static interfaceContext 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.static interfaceSpecialProcessTableFunction.Contextthat is available when theonTimer()method is called.static interfaceProcessTableFunction.TimeContext<TimeType>A context that gives access to Flink's concepts of time and timers.classBase class for a user-defined scalar function.classBase class for a user-defined table function.interfaceProvides call information about the table that has been passed to a table argument.static enumThe sort direction for ORDER BY columns in table arguments with set semantics.classClass representing temporal table function over some history table.classBase class for all user-defined functions. -
Uses of PublicEvolving in org.apache.flink.table.module
Classes in org.apache.flink.table.module with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceModules define a set of metadata, including functions, user defined types, operators, rules, etc.classA POJO to represent a module's name and use status. -
Uses of PublicEvolving in org.apache.flink.table.operations
Classes in org.apache.flink.table.operations with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceCovers all sort of Table operations such as queries(DQL), modifications(DML), definitions(DDL), or control actions(DCL).interfaceBase class for representing an operation structure behind a user-facingTableAPI. -
Uses of PublicEvolving in org.apache.flink.table.resource
Classes in org.apache.flink.table.resource with annotations of type PublicEvolving -
Uses of PublicEvolving in org.apache.flink.table.runtime.functions
Classes in org.apache.flink.table.runtime.functions with annotations of type PublicEvolvingModifier and TypeClassDescriptionclassTest harness forProcessTableFunction.static classBuilder forProcessTableFunctionTestHarness.classA timer registered by aProcessTableFunctionduring testing. -
Uses of PublicEvolving in org.apache.flink.table.secret
Classes in org.apache.flink.table.secret with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceBase marker interface for secret store implementations. -
Uses of PublicEvolving in org.apache.flink.table.types
Classes in org.apache.flink.table.types with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceAbstractDataType<T extends AbstractDataType<T>>Highest abstraction that describes the data type of a value in the table ecosystem.classDescribes the data type of a value in the table ecosystem.final classA data type that contains field data types (i.e. row and structured type).final classPartially resolved data type that requires a lookup in a catalog or configuration before creating the correspondingLogicalType. -
Uses of PublicEvolving in org.apache.flink.table.types.inference
Classes in org.apache.flink.table.types.inference with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceStrategy for inferring a function call's intermediate result data type (i.e. state entry).classDescribes an argument in a static signature that is not overloaded and does not support varargs.enumDeclares traits forStaticArgument.final classProvides logic for the type inference of function calls.static classBuilder for configuring and creating instances ofTypeInference.interfaceStrategy for inferring a function call's result data type. -
Uses of PublicEvolving in org.apache.flink.table.types.logical
Classes in org.apache.flink.table.types.logical with annotations of type PublicEvolvingModifier and TypeClassDescriptionfinal classLogical type of an array of elements with same subtype.classA logical type that describes the data type of a value.final classLogical type of an associative array that maps keys (includingNULL) to values (includingNULL).final classLogical type of a sequence of fields.static final classDescribes a field of aRowType.final classLogical type of a user-defined object structured type.static final classA builder for aStructuredType.static final classDefines an attribute of aStructuredType.static enumDefines equality properties for scalar evaluation. -
Uses of PublicEvolving in org.apache.flink.types
Classes in org.apache.flink.types with annotations of type PublicEvolvingModifier and TypeClassDescriptionfinal classRepresents a list of columns.final classA row is a fixed-length, null-aware composite type for storing multiple values in a deterministic field order.enumLists all kinds of changes that a row can describe in a changelog. -
Uses of PublicEvolving in org.apache.flink.util
Classes in org.apache.flink.util with annotations of type PublicEvolvingModifier and TypeInterfaceDescriptioninterfaceThis interface represents anIteratorthat is alsoAutoCloseable.