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

Class UdfTestProvider

java.lang.Object

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

All Implemented Interfaces:

UdfProvider

@AutoService(UdfProvider.class)
public class UdfTestProvider
extends Object
implements UdfProvider

Defines Java UDFs for use in tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	UdfTestProvider.DateIncrementAllFn
static class	UdfTestProvider.HelloWorldFn
static class	UdfTestProvider.IncrementFn
static class	UdfTestProvider.IsNullFn
static class	UdfTestProvider.MatchFn
static class	UdfTestProvider.Sum
static class	UdfTestProvider.UnusedFn

Constructor Summary

Constructors

Constructor	Description
UdfTestProvider()

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

UdfTestProvider

public UdfTestProvider()

Method Details

userDefinedScalarFunctions

public Map<String,ScalarFn> userDefinedScalarFunctions()

Description copied from interface: UdfProvider

Maps function names to scalar function implementations.

Specified by:

userDefinedScalarFunctions in interface UdfProvider

userDefinedAggregateFunctions

public Map<String,AggregateFn<?,?,?>> userDefinedAggregateFunctions()

Description copied from interface: UdfProvider

Maps function names to aggregate function implementations.

Specified by:

userDefinedAggregateFunctions in interface UdfProvider