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

Class ScalarFunctionImpl

java.lang.Object

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

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

All Implemented Interfaces:

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

public class ScalarFunctionImpl
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.Function	create(java.lang.Class<?> clazz, java.lang.String methodName) Creates Function from given class.
static org.apache.calcite.schema.Function	create(java.lang.reflect.Method method) Creates Function from given method.
static org.apache.beam.vendor.guava.v20_0.com.google.common.collect.ImmutableMultimap<java.lang.String,org.apache.calcite.schema.Function>	createAll(java.lang.Class<?> clazz) Creates Function 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 org.apache.beam.vendor.guava.v20_0.com.google.common.collect.ImmutableMultimap<java.lang.String,org.apache.calcite.schema.Function> createAll(java.lang.Class<?> clazz)

Creates Function for each method in a given class.

create

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

Creates Function 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.Function create(java.lang.reflect.Method method)

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

Parameters:

method - method that is used to implement the function

Returns:

created Function 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)