Uses of Interface
org.apache.flink.table.functions.FunctionDefinition

Packages that use FunctionDefinition

Package	Description
org.apache.flink.connectors.hive
org.apache.flink.python.tests.util
org.apache.flink.table.catalog
org.apache.flink.table.catalog.hive.factories
org.apache.flink.table.examples.java.basics
org.apache.flink.table.examples.java.functions
org.apache.flink.table.expressions
org.apache.flink.table.factories
org.apache.flink.table.functions
org.apache.flink.table.functions.hive
org.apache.flink.table.functions.python
org.apache.flink.table.gateway.api
org.apache.flink.table.gateway.service
org.apache.flink.table.gateway.service.operation
org.apache.flink.table.module
org.apache.flink.table.module.hive
org.apache.flink.table.operations.ddl
org.apache.flink.table.planner.delegation.hive.expressions
org.apache.flink.table.planner.expressions
org.apache.flink.table.planner.expressions.converter.converters
org.apache.flink.table.planner.functions.aggfunctions
org.apache.flink.table.planner.functions.bridging
org.apache.flink.table.planner.functions.inference
org.apache.flink.table.planner.utils
org.apache.flink.table.procedures
org.apache.flink.table.runtime.functions
org.apache.flink.table.runtime.functions.aggregate
org.apache.flink.table.runtime.functions.scalar
org.apache.flink.table.runtime.functions.table
org.apache.flink.table.runtime.functions.table.lookup
org.apache.flink.table.runtime.operators.join.lookup
org.apache.flink.table.sources
org.apache.flink.table.toolbox
org.apache.flink.table.types.inference
org.apache.flink.table.types.inference.strategies
org.apache.flink.table.types.inference.utils

Uses of FunctionDefinition in org.apache.flink.connectors.hive

Classes in org.apache.flink.connectors.hive that implement FunctionDefinition

Modifier and Type	Class and Description
class	FileSystemLookupFunction<P> Lookup function for filesystem connector tables.

Uses of FunctionDefinition in org.apache.flink.python.tests.util

Classes in org.apache.flink.python.tests.util that implement FunctionDefinition

Modifier and Type	Class and Description
class	AddOne Scala UDF for testing.

Uses of FunctionDefinition in org.apache.flink.table.catalog

Methods in org.apache.flink.table.catalog that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	ContextResolvedFunction.getDefinition()
FunctionDefinition	FunctionCatalog.InlineCatalogFunction.getDefinition()

Methods in org.apache.flink.table.catalog with parameters of type FunctionDefinition

Modifier and Type	Method and Description
static ContextResolvedFunction	ContextResolvedFunction.anonymous(FunctionDefinition functionDefinition)
static ContextResolvedFunction	ContextResolvedFunction.permanent(FunctionIdentifier functionIdentifier, FunctionDefinition functionDefinition)
void	FunctionCatalog.registerTemporaryCatalogFunction(UnresolvedIdentifier unresolvedIdentifier, FunctionDefinition definition, boolean ignoreIfExists) Registers a temporary catalog function.
void	FunctionCatalog.registerTemporarySystemFunction(String name, FunctionDefinition definition, boolean ignoreIfExists) Registers a temporary system function.
static ContextResolvedFunction	ContextResolvedFunction.temporary(FunctionIdentifier functionIdentifier, FunctionDefinition functionDefinition)

Constructors in org.apache.flink.table.catalog with parameters of type FunctionDefinition

Constructor and Description
InlineCatalogFunction(FunctionDefinition definition)

Uses of FunctionDefinition in org.apache.flink.table.catalog.hive.factories

Methods in org.apache.flink.table.catalog.hive.factories that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	HiveFunctionDefinitionFactory.createFunctionDefinition(String name, CatalogFunction catalogFunction, FunctionDefinitionFactory.Context context)
FunctionDefinition	HiveFunctionDefinitionFactory.createFunctionDefinitionFromFlinkFunction(String name, CatalogFunction catalogFunction, FunctionDefinitionFactory.Context context)
FunctionDefinition	HiveFunctionDefinitionFactory.createFunctionDefinitionFromHiveFunction(String name, String functionClassName, FunctionDefinitionFactory.Context context) Create a FunctionDefinition from a Hive function's class name.

Uses of FunctionDefinition in org.apache.flink.table.examples.java.basics

Classes in org.apache.flink.table.examples.java.basics that implement FunctionDefinition

Modifier and Type	Class and Description
static class	GettingStartedExample.AddressNormalizer We can put frequently used procedures in user-defined functions.

Uses of FunctionDefinition in org.apache.flink.table.examples.java.functions

Classes in org.apache.flink.table.examples.java.functions that implement FunctionDefinition

Modifier and Type	Class and Description
class	InternalRowMergerFunction Merges two rows into a single row with unique field names.
class	LastDatedValueFunction<T> Implementation of an AggregateFunction that returns a row containing the latest non-null value with its corresponding date.

Uses of FunctionDefinition in org.apache.flink.table.expressions

Methods in org.apache.flink.table.expressions that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	UnresolvedCallExpression.getFunctionDefinition()
FunctionDefinition	AggregateExpression.getFunctionDefinition()
FunctionDefinition	CallExpression.getFunctionDefinition()

Methods in org.apache.flink.table.expressions with parameters of type FunctionDefinition

Modifier and Type	Method and Description
static CallExpression	CallExpression.anonymous(FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType) Creates a CallExpression to an anonymous function that has been declared inline without a FunctionIdentifier.
static CallExpression	CallExpression.permanent(FunctionIdentifier functionIdentifier, FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType) Creates a CallExpression to a permanent function (persisted in a Catalog or provided by a Module).
static CallExpression	CallExpression.temporary(FunctionIdentifier functionIdentifier, FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType) Creates a CallExpression to a temporary function (potentially shadowing a Catalog function or providing a system function).
static UnresolvedCallExpression	ApiExpressionUtils.unresolvedCall(FunctionDefinition functionDefinition, Expression... args)
static UnresolvedCallExpression	ApiExpressionUtils.unresolvedCall(FunctionDefinition functionDefinition, List<Expression> args)

Constructors in org.apache.flink.table.expressions with parameters of type FunctionDefinition

Constructor and Description
AggregateExpression(FunctionDefinition functionDefinition, List<FieldReferenceExpression> args, CallExpression filterExpression, DataType resultType, boolean distinct, boolean approximate, boolean ignoreNulls)
CallExpression(boolean isTemporary, FunctionIdentifier functionIdentifier, FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType)
CallExpression(FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType) Deprecated. Use CallExpression.anonymous(FunctionDefinition, List, DataType) instead.
CallExpression(FunctionIdentifier functionIdentifier, FunctionDefinition functionDefinition, List<ResolvedExpression> args, DataType dataType) Deprecated. Use CallExpression.permanent(FunctionIdentifier, FunctionDefinition, List, DataType) or CallExpression.temporary(FunctionIdentifier, FunctionDefinition, List, DataType) instead.

Uses of FunctionDefinition in org.apache.flink.table.factories

Methods in org.apache.flink.table.factories that return FunctionDefinition

Modifier and Type	Method and Description
default FunctionDefinition	FunctionDefinitionFactory.createFunctionDefinition(String name, CatalogFunction catalogFunction) Deprecated. Please implement FunctionDefinitionFactory.createFunctionDefinition(String, CatalogFunction, Context) instead.
default FunctionDefinition	FunctionDefinitionFactory.createFunctionDefinition(String name, CatalogFunction catalogFunction, FunctionDefinitionFactory.Context context) Creates a FunctionDefinition from given CatalogFunction with the given FunctionDefinitionFactory.Context containing the class loader of the current session, which is useful when it's needed to load class from class name.

Uses of FunctionDefinition in org.apache.flink.table.functions

Subinterfaces of FunctionDefinition in org.apache.flink.table.functions

Modifier and Type	Interface and Description
interface	SpecializedFunction A FunctionDefinition that can provide a runtime implementation (i.e. the function's body) that is specialized for the given call and session.

Classes in org.apache.flink.table.functions that implement FunctionDefinition

Modifier and Type	Class and Description
class	AggregateFunction<T,ACC> Base class for a user-defined aggregate function.
class	AggregateFunctionDefinition Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
class	AsyncLookupFunction A wrapper class of AsyncTableFunction for asynchronously lookup rows matching the lookup keys from external system.
class	AsyncTableFunction<T> Base class for a user-defined asynchronous table function.
class	BuiltInFunctionDefinition Definition of a built-in function.
class	DeclarativeAggregateFunction API for aggregation functions that are expressed in terms of expressions.
class	ImperativeAggregateFunction<T,ACC> Base class for user-defined AggregateFunction and TableAggregateFunction.
class	LookupFunction A wrapper class of TableFunction for synchronously lookup rows matching the lookup keys from external system.
class	ScalarFunction Base class for a user-defined scalar function.
class	ScalarFunctionDefinition Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
class	TableAggregateFunction<T,ACC> Base class for a user-defined table aggregate function.
class	TableAggregateFunctionDefinition Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
class	TableFunction<T> Base class for a user-defined table function.
class	TableFunctionDefinition Deprecated. Non-legacy functions can simply omit this wrapper for declarations.
class	TemporalTableFunction Class representing temporal table function over some history table.
class	TemporalTableFunctionImpl Class representing temporal table function over some history table.
class	UserDefinedFunction Base class for all user-defined functions.

Fields in org.apache.flink.table.functions with type parameters of type FunctionDefinition

Modifier and Type	Field and Description
static List<FunctionDefinition>	BuiltInFunctionDefinitions.ORDERING
static Set<FunctionDefinition>	BuiltInFunctionDefinitions.TIME_ATTRIBUTES
static Set<FunctionDefinition>	BuiltInFunctionDefinitions.WINDOW_PROPERTIES

Methods in org.apache.flink.table.functions with parameters of type FunctionDefinition

Modifier and Type	Method and Description
static UserDefinedFunction	UserDefinedFunctionHelper.createSpecializedFunction(String functionName, FunctionDefinition definition, CallContext callContext, ClassLoader builtInClassLoader, ReadableConfig configuration, SpecializedFunction.ExpressionEvaluatorFactory evaluatorFactory) Creates the runtime implementation of a FunctionDefinition as an instance of UserDefinedFunction.

Uses of FunctionDefinition in org.apache.flink.table.functions.hive

Classes in org.apache.flink.table.functions.hive that implement FunctionDefinition

Modifier and Type	Class and Description
class	HiveAverageAggFunction built-in hive average aggregate function.
class	HiveCountAggFunction built-in hive count aggregate function.
class	HiveDeclarativeAggregateFunction API for hive aggregation functions that are expressed in terms of expressions.
class	HiveGenericUDAF An AggregateFunction implementation that calls Hive's UDAF or GenericUDAFEvaluator.
class	HiveGenericUDF A ScalarFunction implementation that calls Hive's GenericUDF.
class	HiveGenericUDTF A TableFunction implementation that calls Hive's GenericUDTF.
class	HiveMaxAggFunction built-in hive max aggregate function.
class	HiveMinAggFunction built-in hive min aggregate function.
class	HiveScalarFunction<UDFType> Abstract class to provide more information for Hive UDF and GenericUDF functions.
class	HiveSimpleUDF A ScalarFunction implementation that calls Hive's UDF.
class	HiveSumAggFunction built-in hive sum aggregate function.

Methods in org.apache.flink.table.functions.hive with parameters of type FunctionDefinition

Modifier and Type	Method and Description
List<Signature>	HiveFunction.HiveFunctionInputStrategy.getExpectedSignatures(FunctionDefinition definition)

Uses of FunctionDefinition in org.apache.flink.table.functions.python

Classes in org.apache.flink.table.functions.python that implement FunctionDefinition

Modifier and Type	Class and Description
class	PythonAggregateFunction The wrapper of user defined python aggregate function.
class	PythonScalarFunction The wrapper of user defined python scalar function.
class	PythonTableAggregateFunction The wrapper of user defined python table aggregate function.
class	PythonTableFunction The wrapper of user defined python table function.

Uses of FunctionDefinition in org.apache.flink.table.gateway.api

Methods in org.apache.flink.table.gateway.api that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	SqlGatewayService.getFunctionDefinition(SessionHandle sessionHandle, UnresolvedIdentifier functionIdentifier) Get the specific definition of the function.

Uses of FunctionDefinition in org.apache.flink.table.gateway.service

Methods in org.apache.flink.table.gateway.service that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	SqlGatewayServiceImpl.getFunctionDefinition(SessionHandle sessionHandle, UnresolvedIdentifier functionIdentifier)

Uses of FunctionDefinition in org.apache.flink.table.gateway.service.operation

Methods in org.apache.flink.table.gateway.service.operation that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	OperationExecutor.getFunctionDefinition(UnresolvedIdentifier identifier)

Uses of FunctionDefinition in org.apache.flink.table.module

Methods in org.apache.flink.table.module that return types with arguments of type FunctionDefinition

Modifier and Type	Method and Description
Optional<FunctionDefinition>	ModuleManager.getFunctionDefinition(String name) Get an optional of FunctionDefinition by a given name.
default Optional<FunctionDefinition>	Module.getFunctionDefinition(String name) Get an optional of FunctionDefinition by a given name.
Optional<FunctionDefinition>	CoreModule.getFunctionDefinition(String name)

Uses of FunctionDefinition in org.apache.flink.table.module.hive

Methods in org.apache.flink.table.module.hive that return types with arguments of type FunctionDefinition

Modifier and Type	Method and Description
Optional<FunctionDefinition>	HiveModule.getFunctionDefinition(String name)

Uses of FunctionDefinition in org.apache.flink.table.operations.ddl

Constructors in org.apache.flink.table.operations.ddl with parameters of type FunctionDefinition

Constructor and Description
CreateTempSystemFunctionOperation(String functionName, boolean ignoreIfExists, FunctionDefinition functionDefinition)

Uses of FunctionDefinition in org.apache.flink.table.planner.delegation.hive.expressions

Methods in org.apache.flink.table.planner.delegation.hive.expressions with parameters of type FunctionDefinition

Modifier and Type	Method and Description
static UnresolvedCallExpression	ExpressionBuilder.call(FunctionDefinition functionDefinition, Expression... args)
static UnresolvedCallExpression	ExpressionBuilder.call(FunctionDefinition functionDefinition, List<Expression> args)

Uses of FunctionDefinition in org.apache.flink.table.planner.expressions

Methods in org.apache.flink.table.planner.expressions with parameters of type FunctionDefinition

Modifier and Type	Method and Description
static UnresolvedCallExpression	ExpressionBuilder.call(FunctionDefinition functionDefinition, Expression... args)
static UnresolvedCallExpression	ExpressionBuilder.call(FunctionDefinition functionDefinition, List<Expression> args)

Uses of FunctionDefinition in org.apache.flink.table.planner.expressions.converter.converters

Methods in org.apache.flink.table.planner.expressions.converter.converters with parameters of type FunctionDefinition

Modifier and Type	Method and Description
Optional<CustomizedConverter>	CustomizedConverters.getConverter(FunctionDefinition functionDefinition)

Uses of FunctionDefinition in org.apache.flink.table.planner.functions.aggfunctions

Classes in org.apache.flink.table.planner.functions.aggfunctions that implement FunctionDefinition

Modifier and Type	Class and Description
class	AvgAggFunction built-in avg aggregate function.
static class	AvgAggFunction.ByteAvgAggFunction Built-in Byte Avg aggregate function.
static class	AvgAggFunction.DecimalAvgAggFunction Built-in Decimal Avg aggregate function.
static class	AvgAggFunction.DoubleAvgAggFunction Built-in Double Avg aggregate function.
static class	AvgAggFunction.FloatAvgAggFunction Built-in Float Avg aggregate function.
static class	AvgAggFunction.IntAvgAggFunction Built-in Integer Avg aggregate function.
static class	AvgAggFunction.LongAvgAggFunction Built-in Long Avg aggregate function.
static class	AvgAggFunction.ShortAvgAggFunction Built-in Short Avg aggregate function.
class	Count1AggFunction This count1 aggregate function returns the count1 of values which go into it like [[CountAggFunction]].
class	CumeDistAggFunction built-in CUME_DIST agg function.
class	DenseRankAggFunction built-in dense_rank aggregate function.
class	LeadLagAggFunction LEAD and LAG aggregate functions return the value of given expression evaluated at given offset.
static class	LeadLagAggFunction.BooleanLeadLagAggFunction BooleanLeadLagAggFunction.
static class	LeadLagAggFunction.ByteLeadLagAggFunction ByteLeadLagAggFunction.
static class	LeadLagAggFunction.CharLeadLagAggFunction CharLeadLagAggFunction.
static class	LeadLagAggFunction.DateLeadLagAggFunction DateLeadLagAggFunction.
static class	LeadLagAggFunction.DecimalLeadLagAggFunction DecimalLeadLagAggFunction.
static class	LeadLagAggFunction.DoubleLeadLagAggFunction DoubleLeadLagAggFunction.
static class	LeadLagAggFunction.FloatLeadLagAggFunction FloatLeadLagAggFunction.
static class	LeadLagAggFunction.IntLeadLagAggFunction IntLeadLagAggFunction.
static class	LeadLagAggFunction.LongLeadLagAggFunction LongLeadLagAggFunction.
static class	LeadLagAggFunction.ShortLeadLagAggFunction ShortLeadLagAggFunction.
static class	LeadLagAggFunction.StringLeadLagAggFunction StringLeadLagAggFunction.
static class	LeadLagAggFunction.TimeLeadLagAggFunction TimeLeadLagAggFunction.
static class	LeadLagAggFunction.TimestampLeadLagAggFunction TimestampLeadLagAggFunction.
class	ListAggFunction built-in listagg aggregate function.
class	MaxAggFunction built-in max aggregate function.
static class	MaxAggFunction.BooleanMaxAggFunction Built-in Boolean Max aggregate function.
static class	MaxAggFunction.ByteMaxAggFunction Built-in Byte Max aggregate function.
static class	MaxAggFunction.DateMaxAggFunction Built-in Date Max aggregate function.
static class	MaxAggFunction.DecimalMaxAggFunction Built-in Decimal Max aggregate function.
static class	MaxAggFunction.DoubleMaxAggFunction Built-in Double Max aggregate function.
static class	MaxAggFunction.FloatMaxAggFunction Built-in Float Max aggregate function.
static class	MaxAggFunction.IntMaxAggFunction Built-in Int Max aggregate function.
static class	MaxAggFunction.LongMaxAggFunction Built-in Long Max aggregate function.
static class	MaxAggFunction.ShortMaxAggFunction Built-in Short Max aggregate function.
static class	MaxAggFunction.StringMaxAggFunction Built-in String Max aggregate function.
static class	MaxAggFunction.TimeMaxAggFunction Built-in Time Max aggregate function.
static class	MaxAggFunction.TimestampLtzMaxAggFunction Built-in TimestampLtz Max aggregate function.
static class	MaxAggFunction.TimestampMaxAggFunction Built-in Timestamp Max aggregate function.
class	MinAggFunction built-in min aggregate function.
static class	MinAggFunction.BooleanMinAggFunction Built-in Boolean Min aggregate function.
static class	MinAggFunction.ByteMinAggFunction Built-in Byte Min aggregate function.
static class	MinAggFunction.DateMinAggFunction Built-in Date Min aggregate function.
static class	MinAggFunction.DecimalMinAggFunction Built-in Decimal Min aggregate function.
static class	MinAggFunction.DoubleMinAggFunction Built-in Double Min aggregate function.
static class	MinAggFunction.FloatMinAggFunction Built-in Float Min aggregate function.
static class	MinAggFunction.IntMinAggFunction Built-in Int Min aggregate function.
static class	MinAggFunction.LongMinAggFunction Built-in Long Min aggregate function.
static class	MinAggFunction.ShortMinAggFunction Built-in Short Min aggregate function.
static class	MinAggFunction.StringMinAggFunction Built-in String Min aggregate function.
static class	MinAggFunction.TimeMinAggFunction Built-in Time Min aggregate function.
static class	MinAggFunction.TimestampLtzMinAggFunction Built-in TimestampLtz Min aggregate function.
static class	MinAggFunction.TimestampMinAggFunction Built-in Timestamp Min aggregate function.
class	NTILEAggFunction built-in NTILE agg function.
class	PercentRankAggFunction built-in percent_rank aggregate function.
class	RankAggFunction built-in rank aggregate function.
class	RankLikeAggFunctionBase built-in rank like aggregate function, e.g. rank, dense_rank
class	RowNumberAggFunction built-in row_number aggregate function.
class	SingleValueAggFunction Base class for built-in single value aggregate function.
static class	SingleValueAggFunction.BooleanSingleValueAggFunction Built-in boolean single value aggregate function.
static class	SingleValueAggFunction.ByteSingleValueAggFunction Built-in byte single value aggregate function.
static class	SingleValueAggFunction.CharSingleValueAggFunction Built-in char single value aggregate function.
static class	SingleValueAggFunction.DateSingleValueAggFunction Built-in date single value aggregate function.
static class	SingleValueAggFunction.DecimalSingleValueAggFunction Built-in decimal single value aggregate function.
static class	SingleValueAggFunction.DoubleSingleValueAggFunction Built-in double single value aggregate function.
static class	SingleValueAggFunction.FloatSingleValueAggFunction Built-in float single value aggregate function.
static class	SingleValueAggFunction.IntSingleValueAggFunction Built-in int single value aggregate function.
static class	SingleValueAggFunction.LongSingleValueAggFunction Built-in long single value aggregate function.
static class	SingleValueAggFunction.ShortSingleValueAggFunction Built-in short single value aggregate function.
static class	SingleValueAggFunction.StringSingleValueAggFunction Built-in string single value aggregate function.
static class	SingleValueAggFunction.TimeSingleValueAggFunction Built-in time single value aggregate function.
static class	SingleValueAggFunction.TimestampLtzSingleValueAggFunction Built-in timestampLtz single value aggregate function.
static class	SingleValueAggFunction.TimestampSingleValueAggFunction Built-in timestamp single value aggregate function.
class	Sum0AggFunction built-in sum0 aggregate function.
static class	Sum0AggFunction.ByteSum0AggFunction Built-in Byte Sum0 aggregate function.
static class	Sum0AggFunction.DecimalSum0AggFunction Built-in Decimal Sum0 aggregate function.
static class	Sum0AggFunction.DoubleSum0AggFunction Built-in Double Sum0 aggregate function.
static class	Sum0AggFunction.FloatSum0AggFunction Built-in Float Sum0 aggregate function.
static class	Sum0AggFunction.IntSum0AggFunction Built-in Int Sum0 aggregate function.
static class	Sum0AggFunction.LongSum0AggFunction Built-in Long Sum0 aggregate function.
static class	Sum0AggFunction.ShortSum0AggFunction Built-in Short Sum0 aggregate function.
class	SumAggFunction built-in sum aggregate function.
static class	SumAggFunction.ByteSumAggFunction Built-in Byte Sum aggregate function.
static class	SumAggFunction.DecimalSumAggFunction Built-in Decimal Sum aggregate function.
static class	SumAggFunction.DoubleSumAggFunction Built-in Double Sum aggregate function.
static class	SumAggFunction.FloatSumAggFunction Built-in Float Sum aggregate function.
static class	SumAggFunction.IntSumAggFunction Built-in Int Sum aggregate function.
static class	SumAggFunction.LongSumAggFunction Built-in Long Sum aggregate function.
static class	SumAggFunction.ShortSumAggFunction Built-in Short Sum aggregate function.
class	SumWithRetractAggFunction built-in sum aggregate function with retraction.
static class	SumWithRetractAggFunction.ByteSumWithRetractAggFunction Built-in Byte Sum with retract aggregate function.
static class	SumWithRetractAggFunction.DecimalSumWithRetractAggFunction Built-in Decimal Sum with retract aggregate function.
static class	SumWithRetractAggFunction.DoubleSumWithRetractAggFunction Built-in Double Sum with retract aggregate function.
static class	SumWithRetractAggFunction.FloatSumWithRetractAggFunction Built-in Float Sum with retract aggregate function.
static class	SumWithRetractAggFunction.IntSumWithRetractAggFunction Built-in Int Sum with retract aggregate function.
static class	SumWithRetractAggFunction.LongSumWithRetractAggFunction Built-in Long Sum with retract aggregate function.
static class	SumWithRetractAggFunction.ShortSumWithRetractAggFunction Built-in Short Sum with retract aggregate function.

Uses of FunctionDefinition in org.apache.flink.table.planner.functions.bridging

Methods in org.apache.flink.table.planner.functions.bridging that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	BridgingSqlAggFunction.getDefinition()
FunctionDefinition	BridgingSqlFunction.getDefinition()

Uses of FunctionDefinition in org.apache.flink.table.planner.functions.inference

Methods in org.apache.flink.table.planner.functions.inference that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	AbstractSqlCallContext.getFunctionDefinition()

Constructors in org.apache.flink.table.planner.functions.inference with parameters of type FunctionDefinition

Constructor and Description
AbstractSqlCallContext(DataTypeFactory dataTypeFactory, FunctionDefinition definition, String name, boolean isGroupedAggregation)
CallBindingCallContext(DataTypeFactory dataTypeFactory, FunctionDefinition definition, org.apache.calcite.sql.SqlCallBinding binding, org.apache.calcite.rel.type.RelDataType outputType)
OperatorBindingCallContext(DataTypeFactory dataTypeFactory, FunctionDefinition definition, org.apache.calcite.sql.SqlOperatorBinding binding, org.apache.calcite.rel.type.RelDataType returnRelDataType)
TypeInferenceOperandChecker(DataTypeFactory dataTypeFactory, FunctionDefinition definition, TypeInference typeInference)
TypeInferenceOperandInference(DataTypeFactory dataTypeFactory, FunctionDefinition definition, TypeInference typeInference)
TypeInferenceReturnInference(DataTypeFactory dataTypeFactory, FunctionDefinition definition, TypeInference typeInference)

Uses of FunctionDefinition in org.apache.flink.table.planner.utils

Methods in org.apache.flink.table.planner.utils that return FunctionDefinition

Modifier and Type	Method and Description
static FunctionDefinition	ShortcutUtils.unwrapFunctionDefinition(ResolvedExpression expression)
static FunctionDefinition	ShortcutUtils.unwrapFunctionDefinition(org.apache.calcite.rex.RexNode rexNode)

Uses of FunctionDefinition in org.apache.flink.table.procedures

Classes in org.apache.flink.table.procedures that implement FunctionDefinition

Modifier and Type	Class and Description
class	ProcedureDefinition Definition of a procedure.

Uses of FunctionDefinition in org.apache.flink.table.runtime.functions

Classes in org.apache.flink.table.runtime.functions that implement FunctionDefinition

Modifier and Type	Class and Description
class	BuiltInSpecializedFunction Base class for built-in functions that need another level of specialization via SpecializedFunction.specialize(SpecializedContext).

Uses of FunctionDefinition in org.apache.flink.table.runtime.functions.aggregate

Classes in org.apache.flink.table.runtime.functions.aggregate that implement FunctionDefinition

Modifier and Type	Class and Description
static class	BatchApproxCountDistinctAggFunctions.ApproxCountDistinctAggFunction<T> Base function for APPROX_COUNT_DISTINCT aggregate.
static class	BatchApproxCountDistinctAggFunctions.ByteApproxCountDistinctAggFunction Built-in byte APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.DateApproxCountDistinctAggFunction Built-in Date APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.DecimalApproxCountDistinctAggFunction Built-in decimal APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.DoubleApproxCountDistinctAggFunction Built-in double APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.FloatApproxCountDistinctAggFunction Built-in float APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.IntApproxCountDistinctAggFunction Built-in int APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.LongApproxCountDistinctAggFunction Built-in long APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.ShortApproxCountDistinctAggFunction Built-in Short APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.StringApproxCountDistinctAggFunction Built-in string APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.TimeApproxCountDistinctAggFunction Built-in Time APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.TimestampApproxCountDistinctAggFunction Built-in Timestamp APPROX_COUNT_DISTINCT aggregate function.
static class	BatchApproxCountDistinctAggFunctions.TimestampLtzApproxCountDistinctAggFunction Built-in TimestampLtz APPROX_COUNT_DISTINCT aggregate function.
class	BuiltInAggregateFunction<T,ACC> Base class for runtime implementation represented as AggregateFunction that is constructed from SpecializedFunction.specialize(SpecializedContext).
class	CollectAggFunction<T> Built-in COLLECT aggregate function.
class	FirstValueAggFunction<T> Built-in FIRST_VALUE aggregate function.
class	FirstValueWithRetractAggFunction<T> Built-in FIRST_VALUE with retraction aggregate function.
class	JsonArrayAggFunction Implementation for BuiltInFunctionDefinitions.JSON_ARRAYAGG_ABSENT_ON_NULL / BuiltInFunctionDefinitions.JSON_ARRAYAGG_NULL_ON_NULL.
class	JsonObjectAggFunction Implementation for BuiltInFunctionDefinitions.JSON_OBJECTAGG_NULL_ON_NULL / BuiltInFunctionDefinitions.JSON_OBJECTAGG_ABSENT_ON_NULL.
class	LagAggFunction<T> Lag AggregateFunction.
class	LastValueAggFunction<T> Built-in LAST_VALUE aggregate function.
class	LastValueWithRetractAggFunction<T> Built-in LAST_VALUE with retraction aggregate function.
class	ListAggWithRetractAggFunction Built-in LISTAGG with retraction aggregate function.
class	ListAggWsWithRetractAggFunction Built-in LISTAGGWS with retraction aggregate function.
class	MaxWithRetractAggFunction<T extends Comparable<T>> Built-in MAX with retraction aggregate function.
class	MinWithRetractAggFunction<T extends Comparable<T>> Built-in MIN with retraction aggregate function.

Uses of FunctionDefinition in org.apache.flink.table.runtime.functions.scalar

Classes in org.apache.flink.table.runtime.functions.scalar that implement FunctionDefinition

Modifier and Type	Class and Description
class	ArrayConcatFunction Implementation of BuiltInFunctionDefinitions.ARRAY_CONCAT.
class	ArrayContainsFunction Implementation of BuiltInFunctionDefinitions.ARRAY_CONTAINS.
class	ArrayDistinctFunction Implementation of BuiltInFunctionDefinitions.ARRAY_DISTINCT.
class	ArrayJoinFunction Implementation of BuiltInFunctionDefinitions.ARRAY_JOIN.
class	ArrayMaxFunction Implementation of BuiltInFunctionDefinitions.ARRAY_MAX.
class	ArrayPositionFunction Implementation of BuiltInFunctionDefinitions.ARRAY_POSITION.
class	ArrayRemoveFunction Implementation of BuiltInFunctionDefinitions.ARRAY_REMOVE.
class	ArrayReverseFunction Implementation of BuiltInFunctionDefinitions.ARRAY_REVERSE.
class	ArraySliceFunction Implementation of BuiltInFunctionDefinitions.ARRAY_SLICE.
class	ArrayUnionFunction Implementation of BuiltInFunctionDefinitions.ARRAY_UNION.
class	BuiltInScalarFunction Base class for runtime implementation represented as ScalarFunction that is constructed from SpecializedFunction.specialize(SpecializedContext).
class	CoalesceFunction Implementation of BuiltInFunctionDefinitions.COALESCE.
class	IfNullFunction Implementation of BuiltInFunctionDefinitions.IF_NULL.
class	MapEntriesFunction Implementation of BuiltInFunctionDefinitions.MAP_ENTRIES.
class	MapFromArraysFunction Implementation of BuiltInFunctionDefinitions.MAP_FROM_ARRAYS.
class	MapKeysFunction Implementation of BuiltInFunctionDefinitions.MAP_KEYS.
class	MapValuesFunction Implementation of BuiltInFunctionDefinitions.MAP_VALUES.
class	SourceWatermarkFunction Implementation of BuiltInFunctionDefinitions.SOURCE_WATERMARK.
class	TypeOfFunction Implementation of BuiltInFunctionDefinitions.TYPE_OF.

Uses of FunctionDefinition in org.apache.flink.table.runtime.functions.table

Classes in org.apache.flink.table.runtime.functions.table that implement FunctionDefinition

Modifier and Type	Class and Description
class	BuiltInTableFunction<T> Base class for runtime implementation represented as TableFunction that is constructed from SpecializedFunction.specialize(SpecializedContext).
class	ReplicateRowsFunction Replicate the row N times.
class	UnnestRowsFunction Flattens ARRAY, MAP, and MULTISET using a table function.
static class	UnnestRowsFunction.CollectionUnnestTableFunction Table function that unwraps the elements of a collection (array or multiset).
static class	UnnestRowsFunction.MapUnnestTableFunction Table function that unwraps the elements of a map.

Uses of FunctionDefinition in org.apache.flink.table.runtime.functions.table.lookup

Classes in org.apache.flink.table.runtime.functions.table.lookup that implement FunctionDefinition

Modifier and Type	Class and Description
class	CachingAsyncLookupFunction A wrapper function around user-provided async lookup function with a cache layer.
class	CachingLookupFunction A wrapper function around user-provided lookup function with a cache layer.

Uses of FunctionDefinition in org.apache.flink.table.runtime.operators.join.lookup

Classes in org.apache.flink.table.runtime.operators.join.lookup that implement FunctionDefinition

Modifier and Type	Class and Description
class	RetryableAsyncLookupFunctionDelegator A delegator holds user's AsyncLookupFunction to handle retries.
class	RetryableLookupFunctionDelegator A delegator holds user's LookupFunction to handle retries.

Uses of FunctionDefinition in org.apache.flink.table.sources

Classes in org.apache.flink.table.sources that implement FunctionDefinition

Modifier and Type	Class and Description
static class	CsvTableSource.CsvLookupFunction Deprecated. LookupFunction to support lookup in CsvTableSource.

Uses of FunctionDefinition in org.apache.flink.table.toolbox

Classes in org.apache.flink.table.toolbox that implement FunctionDefinition

Modifier and Type	Class and Description
class	CountAggFunction Count agg aggregate.
class	StringRegexReplaceFunction Scalar function for replacing all occurrences of a regular expression with a replacement string.

Uses of FunctionDefinition in org.apache.flink.table.types.inference

Methods in org.apache.flink.table.types.inference that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	CallContext.getFunctionDefinition() Returns the function definition that defines the function currently being called.

Methods in org.apache.flink.table.types.inference with parameters of type FunctionDefinition

Modifier and Type	Method and Description
static String	TypeInferenceUtil.generateSignature(TypeInference typeInference, String name, FunctionDefinition definition) Generates a signature of the given FunctionDefinition.
Signature.Argument	ArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos) Returns a summary of the function's expected argument at argumentPos.
List<Signature>	InputTypeStrategy.getExpectedSignatures(FunctionDefinition definition) Returns a summary of the function's expected signatures.
static TypeInferenceUtil.SurroundingInfo	TypeInferenceUtil.SurroundingInfo.of(String name, FunctionDefinition functionDefinition, TypeInference typeInference, int argumentCount, int innerCallPosition, boolean isGroupedAggregation)

Uses of FunctionDefinition in org.apache.flink.table.types.inference.strategies

Methods in org.apache.flink.table.types.inference.strategies with parameters of type FunctionDefinition

Modifier and Type	Method and Description
Signature.Argument	SymbolArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	TypeLiteralArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	AndArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	AnyArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	RootArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	OrArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	CommonArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	ExplicitArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	LiteralArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	CompositeArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	OutputArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	FamilyArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	ArrayOfStringArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
Signature.Argument	ConstraintArgumentTypeStrategy.getExpectedArgument(FunctionDefinition functionDefinition, int argumentPos)
List<Signature>	OrInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	VaryingSequenceInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	CommonInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	CommonArrayInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	ComparableTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	SequenceInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	RepeatingSequenceInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	ArrayComparableElementTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	SubsequenceInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)
List<Signature>	WildcardInputTypeStrategy.getExpectedSignatures(FunctionDefinition definition)

Uses of FunctionDefinition in org.apache.flink.table.types.inference.utils

Methods in org.apache.flink.table.types.inference.utils that return FunctionDefinition

Modifier and Type	Method and Description
FunctionDefinition	UnknownCallContext.getFunctionDefinition()
FunctionDefinition	AdaptedCallContext.getFunctionDefinition()

Constructors in org.apache.flink.table.types.inference.utils with parameters of type FunctionDefinition

Constructor and Description
UnknownCallContext(DataTypeFactory typeFactory, String name, FunctionDefinition functionDefinition, int argumentCount, boolean isGroupedAggregation)