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.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ImplementableFunction, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ScalarFunction

public class ScalarFunctionImpl
extends UdfImplReflectiveFunctionBase
implements org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ScalarFunction, org.apache.beam.vendor.calcite.v1_20_0.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.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function	create(java.lang.Class<?> clazz, java.lang.String methodName) Creates Function from given class.
static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function	create(java.lang.reflect.Method method) Creates Function from given method.
static org.apache.beam.vendor.calcite.v1_20_0.com.google.common.collect.ImmutableMultimap<java.lang.String,org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function>	createAll(java.lang.Class<?> clazz) Creates Function for each method in a given class.
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.CallImplementor	getImplementor()
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType	getReturnType(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)
org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType	getReturnType(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeFactory typeFactory, org.apache.beam.vendor.calcite.v1_20_0.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.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function

getParameters

Method Detail

createAll

public static org.apache.beam.vendor.calcite.v1_20_0.com.google.common.collect.ImmutableMultimap<java.lang.String,org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.Function> createAll(java.lang.Class<?> clazz)

Creates Function for each method in a given class.

create

public static org.apache.beam.vendor.calcite.v1_20_0.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.beam.vendor.calcite.v1_20_0.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.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataType getReturnType(org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.rel.type.RelDataTypeFactory typeFactory)

Specified by:

getReturnType in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ScalarFunction

getImplementor

public org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.CallImplementor getImplementor()

Specified by:

getImplementor in interface org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.schema.ImplementableFunction

getReturnType

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