@Internal public class UserDefinedFunctionHelper extends Object
FunctionCatalog
.Modifier and Type | Method and Description |
---|---|
static <T,ACC> TypeInformation<ACC> |
getAccumulatorTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<ACC> |
getAccumulatorTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<ACC> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<T> |
getReturnTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T,ACC> TypeInformation<T> |
getReturnTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction,
TypeInformation<T> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T> TypeInformation<T> |
getReturnTypeOfTableFunction(TableFunction<T> tableFunction)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static <T> TypeInformation<T> |
getReturnTypeOfTableFunction(TableFunction<T> tableFunction,
TypeInformation<T> scalaType)
Tries to infer the TypeInformation of an AggregateFunction's accumulator type.
|
static void |
prepareFunction(TableConfig config,
UserDefinedFunction function)
Prepares a
UserDefinedFunction for usage in the API. |
public static <T,ACC> TypeInformation<T> getReturnTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction)
aggregateFunction
- The AggregateFunction for which the accumulator type is inferred.public static <T,ACC> TypeInformation<T> getReturnTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction, TypeInformation<T> scalaType)
aggregateFunction
- The AggregateFunction for which the accumulator type is inferred.scalaType
- The implicitly inferred type of the accumulator type.public static <T,ACC> TypeInformation<ACC> getAccumulatorTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction)
aggregateFunction
- The AggregateFunction for which the accumulator type is inferred.public static <T,ACC> TypeInformation<ACC> getAccumulatorTypeOfAggregateFunction(UserDefinedAggregateFunction<T,ACC> aggregateFunction, TypeInformation<ACC> scalaType)
aggregateFunction
- The AggregateFunction for which the accumulator type is inferred.scalaType
- The implicitly inferred type of the accumulator type.public static <T> TypeInformation<T> getReturnTypeOfTableFunction(TableFunction<T> tableFunction)
tableFunction
- The TableFunction for which the accumulator type is inferred.public static <T> TypeInformation<T> getReturnTypeOfTableFunction(TableFunction<T> tableFunction, TypeInformation<T> scalaType)
tableFunction
- The TableFunction for which the accumulator type is inferred.scalaType
- The implicitly inferred type of the accumulator type.public static void prepareFunction(TableConfig config, UserDefinedFunction function)
UserDefinedFunction
for usage in the API.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.