Class AggregateFunctionDefinition
- java.lang.Object
-
- org.apache.flink.table.functions.AggregateFunctionDefinition
-
- All Implemented Interfaces:
FunctionDefinition
@Deprecated public final class AggregateFunctionDefinition extends Object implements FunctionDefinition
Deprecated.Non-legacy functions can simply omit this wrapper for declarations.A "marker" function definition of an user-defined aggregate function that uses the old type system stack.This class can be dropped once we introduce a new type inference.
-
-
Constructor Summary
Constructors Constructor Description AggregateFunctionDefinition(String name, AggregateFunction<?,?> aggregateFunction, TypeInformation<?> resultTypeInfo, TypeInformation<?> accTypeInfo)
Deprecated.
-
Method Summary
All Methods Instance Methods Concrete Methods Deprecated Methods Modifier and Type Method Description boolean
equals(Object o)
Deprecated.TypeInformation<?>
getAccumulatorTypeInfo()
Deprecated.AggregateFunction<?,?>
getAggregateFunction()
Deprecated.FunctionKind
getKind()
Deprecated.Returns the kind of function this definition describes.String
getName()
Deprecated.Set<FunctionRequirement>
getRequirements()
Deprecated.Returns the set of requirements this definition demands.TypeInformation<?>
getResultTypeInfo()
Deprecated.TypeInference
getTypeInference(DataTypeFactory typeFactory)
Deprecated.Returns the logic for performing type inference of a call to this function definition.int
hashCode()
Deprecated.boolean
isDeterministic()
Deprecated.Returns information about the determinism of the function's results.String
toString()
Deprecated.-
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.flink.table.functions.FunctionDefinition
supportsConstantFolding
-
-
-
-
Constructor Detail
-
AggregateFunctionDefinition
public AggregateFunctionDefinition(String name, AggregateFunction<?,?> aggregateFunction, TypeInformation<?> resultTypeInfo, TypeInformation<?> accTypeInfo)
Deprecated.
-
-
Method Detail
-
getName
public String getName()
Deprecated.
-
getAggregateFunction
public AggregateFunction<?,?> getAggregateFunction()
Deprecated.
-
getResultTypeInfo
public TypeInformation<?> getResultTypeInfo()
Deprecated.
-
getAccumulatorTypeInfo
public TypeInformation<?> getAccumulatorTypeInfo()
Deprecated.
-
getKind
public FunctionKind getKind()
Deprecated.Description copied from interface:FunctionDefinition
Returns the kind of function this definition describes.- Specified by:
getKind
in interfaceFunctionDefinition
-
getTypeInference
public TypeInference getTypeInference(DataTypeFactory typeFactory)
Deprecated.Description copied from interface:FunctionDefinition
Returns the logic for performing type inference of a call to this function definition.The type inference process is responsible for inferring unknown types of input arguments, validating input arguments, and producing result types. The type inference process happens independent of a function body. The output of the type inference is used to search for a corresponding runtime implementation.
Instances of type inference can be created by using
TypeInference.newBuilder()
.See
BuiltInFunctionDefinitions
for concrete usage examples.- Specified by:
getTypeInference
in interfaceFunctionDefinition
-
getRequirements
public Set<FunctionRequirement> getRequirements()
Deprecated.Description copied from interface:FunctionDefinition
Returns the set of requirements this definition demands.- Specified by:
getRequirements
in interfaceFunctionDefinition
-
isDeterministic
public boolean isDeterministic()
Deprecated.Description copied from interface:FunctionDefinition
Returns information about the determinism of the function's results.It returns
true
if and only if a call to this function is guaranteed to always return the same result given the same parameters.true
is assumed by default. If the function is not purely functional likerandom(), date(), now(), ...
this method must returnfalse
.Furthermore, return
false
if the planner should always execute this function on the cluster side. In other words: the planner should not perform constant expression reduction during planning for constant calls to this function.- Specified by:
isDeterministic
in interfaceFunctionDefinition
-
-