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

Interface UdfUdafProvider

@Experimental
public interface UdfUdafProvider

Provider for UDF and UDAF.

Method Summary

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

Method Detail

getBeamSqlUdfs

default java.util.Map<java.lang.String,java.lang.Class<? extends BeamSqlUdf>> getBeamSqlUdfs()

For UDFs implement BeamSqlUdf.

getSerializableFunctionUdfs

default java.util.Map<java.lang.String,SerializableFunction<?,?>> getSerializableFunctionUdfs()

For UDFs implement SerializableFunction.

getUdafs

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