Package 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 Details

    • userDefinedScalarFunctions

      default Map<String,ScalarFn> userDefinedScalarFunctions()
      Maps function names to scalar function implementations.

    • userDefinedAggregateFunctions

      default Map<String,AggregateFn<?,?,?>> userDefinedAggregateFunctions()
      Maps function names to aggregate function implementations.