org.apache.beam.sdk.extensions.sql.udf

Interface UdfProvider

All Known Implementing Classes:

UdfTestProvider

public interface UdfProvider

Provider for user-defined functions written in Java. Implementations should be annotated with AutoService.

Method Summary

Modifier and Type	Method and Description
default java.util.Map<java.lang.String,AggregateFn<?,?,?>>	userDefinedAggregateFunctions() Maps function names to aggregate function implementations.
default java.util.Map<java.lang.String,ScalarFn>	userDefinedScalarFunctions() Maps function names to scalar function implementations.

Method Detail

userDefinedScalarFunctions

default java.util.Map<java.lang.String,ScalarFn> userDefinedScalarFunctions()

Maps function names to scalar function implementations.

userDefinedAggregateFunctions

default java.util.Map<java.lang.String,AggregateFn<?,?,?>> userDefinedAggregateFunctions()

Maps function names to aggregate function implementations.