Uses of Class
org.apache.flink.table.functions.ScalarFunction

Packages that use ScalarFunction

Package	Description
org.apache.flink.python.tests.util
org.apache.flink.table.api
org.apache.flink.table.api.internal
org.apache.flink.table.catalog
org.apache.flink.table.examples.java.basics
org.apache.flink.table.examples.java.functions
org.apache.flink.table.functions
org.apache.flink.table.functions.hive
org.apache.flink.table.functions.python
org.apache.flink.table.runtime.functions.scalar
org.apache.flink.table.toolbox
org.apache.flink.table.types.extraction

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

Subclasses of ScalarFunction in org.apache.flink.python.tests.util

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

Uses of ScalarFunction in org.apache.flink.table.api

Methods in org.apache.flink.table.api with parameters of type ScalarFunction

Modifier and Type

Method and Description

void

TableEnvironment.registerFunction(String name, ScalarFunction function) Deprecated. Use TableEnvironment.createTemporarySystemFunction(String, UserDefinedFunction) instead. Please note that the new method also uses the new type system and reflective extraction logic. It might be necessary to update the function implementation as well. See the documentation of ScalarFunction for more information on the new function design.

Uses of ScalarFunction in org.apache.flink.table.api.internal

Methods in org.apache.flink.table.api.internal with parameters of type ScalarFunction

Modifier and Type	Method and Description
void	TableEnvironmentImpl.registerFunction(String name, ScalarFunction function)

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

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

Modifier and Type	Method and Description
void	FunctionCatalog.registerTempCatalogScalarFunction(ObjectIdentifier oi, ScalarFunction function) Deprecated. Use FunctionCatalog.registerTemporaryCatalogFunction(UnresolvedIdentifier, FunctionDefinition, boolean) instead.
void	FunctionCatalog.registerTempSystemScalarFunction(String name, ScalarFunction function) Deprecated. Use FunctionCatalog.registerTemporarySystemFunction(String, FunctionDefinition, boolean) instead.

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

Subclasses of ScalarFunction in org.apache.flink.table.examples.java.basics

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

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

Subclasses of ScalarFunction in org.apache.flink.table.examples.java.functions

Modifier and Type	Class and Description
class	InternalRowMergerFunction Merges two rows into a single row with unique field names.

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

Methods in org.apache.flink.table.functions that return ScalarFunction

Modifier and Type	Method and Description
ScalarFunction	ScalarFunctionDefinition.getScalarFunction() Deprecated.

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

Modifier and Type	Method and Description
static InputTypeStrategy	LegacyUserDefinedFunctionInference.getInputTypeStrategy(ScalarFunction func) Deprecated.
static TypeStrategy	LegacyUserDefinedFunctionInference.getOutputTypeStrategy(ScalarFunction func) Deprecated.

Constructors in org.apache.flink.table.functions with parameters of type ScalarFunction

Constructor and Description
ScalarFunctionDefinition(String name, ScalarFunction scalarFunction) Deprecated.

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

Subclasses of ScalarFunction in org.apache.flink.table.functions.hive

Modifier and Type	Class and Description
class	HiveGenericUDF A ScalarFunction implementation that calls Hive's GenericUDF.
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.

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

Subclasses of ScalarFunction in org.apache.flink.table.functions.python

Modifier and Type	Class and Description
class	PythonScalarFunction The wrapper of user defined python scalar function.

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

Subclasses of ScalarFunction in org.apache.flink.table.runtime.functions.scalar

Modifier and Type	Class and Description
class	ArrayAppendFunction Implementation of BuiltInFunctionDefinitions.ARRAY_APPEND.
class	ArrayConcatFunction Implementation of BuiltInFunctionDefinitions.ARRAY_CONCAT.
class	ArrayContainsFunction Implementation of BuiltInFunctionDefinitions.ARRAY_CONTAINS.
class	ArrayDistinctFunction Implementation of BuiltInFunctionDefinitions.ARRAY_DISTINCT.
class	ArrayExceptFunction Implementation of BuiltInFunctionDefinitions.ARRAY_EXCEPT.
class	ArrayIntersectFunction Implementation of BuiltInFunctionDefinitions.ARRAY_INTERSECT.
class	ArrayJoinFunction Implementation of BuiltInFunctionDefinitions.ARRAY_JOIN.
class	ArrayMaxFunction Implementation of BuiltInFunctionDefinitions.ARRAY_MAX.
class	ArrayMinFunction Implementation of BuiltInFunctionDefinitions.ARRAY_MIN.
class	ArrayPositionFunction Implementation of BuiltInFunctionDefinitions.ARRAY_POSITION.
class	ArrayPrependFunction Implementation of BuiltInFunctionDefinitions.ARRAY_PREPEND.
class	ArrayRemoveFunction Implementation of BuiltInFunctionDefinitions.ARRAY_REMOVE.
class	ArrayReverseFunction Implementation of BuiltInFunctionDefinitions.ARRAY_REVERSE.
class	ArraySliceFunction Implementation of BuiltInFunctionDefinitions.ARRAY_SLICE.
class	ArraySortFunction Implementation of ARRAY_SORT function.
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	MapUnionFunction Implementation of BuiltInFunctionDefinitions.MAP_UNION.
class	MapValuesFunction Implementation of BuiltInFunctionDefinitions.MAP_VALUES.
class	SourceWatermarkFunction Implementation of BuiltInFunctionDefinitions.SOURCE_WATERMARK.
class	SplitFunction Implementation of BuiltInFunctionDefinitions.SPLIT.
class	TypeOfFunction Implementation of BuiltInFunctionDefinitions.TYPE_OF.

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

Subclasses of ScalarFunction in org.apache.flink.table.toolbox

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

Uses of ScalarFunction in org.apache.flink.table.types.extraction

Method parameters in org.apache.flink.table.types.extraction with type arguments of type ScalarFunction

Modifier and Type	Method and Description
static TypeInference	TypeInferenceExtractor.forScalarFunction(DataTypeFactory typeFactory, Class<? extends ScalarFunction> function) Extracts a type inference from a ScalarFunction.