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(value=UdfProvider.class)
public class UdfTestProvider
extends java.lang.Object
implements UdfProvider

Defines Java UDFs for use in tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class and 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 and Description
UdfTestProvider()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,AggregateFn<?,?,?>>	userDefinedAggregateFunctions() Maps function names to aggregate function implementations.
java.util.Map<java.lang.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 Detail

UdfTestProvider

public UdfTestProvider()

Method Detail

userDefinedScalarFunctions

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

Description copied from interface: UdfProvider

Maps function names to scalar function implementations.

Specified by:

userDefinedScalarFunctions in interface UdfProvider

userDefinedAggregateFunctions

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

Description copied from interface: UdfProvider

Maps function names to aggregate function implementations.

Specified by:

userDefinedAggregateFunctions in interface UdfProvider