Package org.apache.beam.sdk.extensions.sql.meta.provider

Interface UdfUdafProvider

public interface UdfUdafProvider

Provider for UDF and UDAF.

Method Summary

Modifier and Type	Method	Description
default Map<String,Class<? extends BeamSqlUdf>>	getBeamSqlUdfs()	For UDFs implement BeamSqlUdf.
default Map<String,SerializableFunction<?,?>>	getSerializableFunctionUdfs()	For UDFs implement SerializableFunction.
default Map<String,Combine.CombineFn>	getUdafs()

Method Details

getBeamSqlUdfs

default Map<String,Class<? extends BeamSqlUdf>> getBeamSqlUdfs()

For UDFs implement BeamSqlUdf.

getSerializableFunctionUdfs

default Map<String,SerializableFunction<?,?>> getSerializableFunctionUdfs()

For UDFs implement SerializableFunction.

getUdafs

default Map<String,Combine.CombineFn> getUdafs()