org.apache.beam.sdk.extensions.sql.impl

Class UdfImpl

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase

org.apache.beam.sdk.extensions.sql.impl.UdfImpl

All Implemented Interfaces:

org.apache.calcite.schema.Function, org.apache.calcite.schema.ImplementableFunction, org.apache.calcite.schema.ScalarFunction

public class UdfImpl
extends UdfImplReflectiveFunctionBase
implements org.apache.calcite.schema.ScalarFunction, org.apache.calcite.schema.ImplementableFunction

Beam-customized version from ScalarFunctionImpl, to address BEAM-5921.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase

UdfImplReflectiveFunctionBase.ParameterListBuilder

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase

method, parameters

Method Summary

Modifier and Type	Method and Description
static org.apache.calcite.schema.ScalarFunction	create(java.lang.Class<?> clazz, java.lang.String methodName) Creates ScalarFunction from given class.
static org.apache.calcite.schema.ScalarFunction	create(java.lang.reflect.Method method) Creates ScalarFunction from given method.
static ImmutableMultimap<java.lang.String,org.apache.calcite.schema.ScalarFunction>	createAll(java.lang.Class<?> clazz) Creates ScalarFunction for each method in a given class.
org.apache.calcite.adapter.enumerable.CallImplementor	getImplementor()
org.apache.calcite.rel.type.RelDataType	getReturnType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
org.apache.calcite.rel.type.RelDataType	getReturnType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.calcite.sql.SqlOperatorBinding opBinding)

Methods inherited from class org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase

builder, getParameters

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.calcite.schema.Function

getParameters

Method Detail

createAll

public static ImmutableMultimap<java.lang.String,org.apache.calcite.schema.ScalarFunction> createAll(java.lang.Class<?> clazz)

Creates ScalarFunction for each method in a given class.

create

public static org.apache.calcite.schema.ScalarFunction create(java.lang.Class<?> clazz,
                                                              java.lang.String methodName)

Creates ScalarFunction from given class.

If a method of the given name is not found or it does not suit, returns null.

Parameters:

clazz - class that is used to implement the function

methodName - Method name (typically "eval")

Returns:

created ScalarFunction or null

create

public static org.apache.calcite.schema.ScalarFunction create(java.lang.reflect.Method method)

Creates ScalarFunction from given method. When eval method does not suit, null is returned.

Parameters:

method - method that is used to implement the function

Returns:

created ScalarFunction or null

getReturnType

public org.apache.calcite.rel.type.RelDataType getReturnType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)

Specified by:

getReturnType in interface org.apache.calcite.schema.ScalarFunction

getImplementor

public org.apache.calcite.adapter.enumerable.CallImplementor getImplementor()

Specified by:

getImplementor in interface org.apache.calcite.schema.ImplementableFunction

getReturnType

public org.apache.calcite.rel.type.RelDataType getReturnType(org.apache.calcite.rel.type.RelDataTypeFactory typeFactory,
                                                             org.apache.calcite.sql.SqlOperatorBinding opBinding)