@Internal public class FunctionCatalog extends Object implements FunctionLookup
FunctionDefinition
s in catalogs.FunctionLookup.Result
Constructor and Description |
---|
FunctionCatalog(CatalogManager catalogManager) |
Modifier and Type | Method and Description |
---|---|
PlannerTypeInferenceUtil |
getPlannerTypeInferenceUtil()
Temporary utility until the new type inference is fully functional.
|
String[] |
getUserDefinedFunctions() |
Optional<FunctionLookup.Result> |
lookupFunction(String name)
Lookup a function by name.
|
<T,ACC> void |
registerAggregateFunction(String name,
UserDefinedAggregateFunction<T,ACC> function,
TypeInformation<T> resultType,
TypeInformation<ACC> accType) |
void |
registerScalarFunction(String name,
ScalarFunction function) |
<T> void |
registerTableFunction(String name,
TableFunction<T> function,
TypeInformation<T> resultType) |
void |
setPlannerTypeInferenceUtil(PlannerTypeInferenceUtil plannerTypeInferenceUtil) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
lookupBuiltInFunction
public FunctionCatalog(CatalogManager catalogManager)
public void setPlannerTypeInferenceUtil(PlannerTypeInferenceUtil plannerTypeInferenceUtil)
public void registerScalarFunction(String name, ScalarFunction function)
public <T> void registerTableFunction(String name, TableFunction<T> function, TypeInformation<T> resultType)
public <T,ACC> void registerAggregateFunction(String name, UserDefinedAggregateFunction<T,ACC> function, TypeInformation<T> resultType, TypeInformation<ACC> accType)
public String[] getUserDefinedFunctions()
public Optional<FunctionLookup.Result> lookupFunction(String name)
FunctionLookup
lookupFunction
in interface FunctionLookup
public PlannerTypeInferenceUtil getPlannerTypeInferenceUtil()
FunctionLookup
getPlannerTypeInferenceUtil
in interface FunctionLookup
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.