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

Direct Known Subclasses:

ZetaSqlScalarFunctionImpl

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

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	ScalarFunctionImpl(java.lang.reflect.Method method, org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.CallImplementor implementor)

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.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.
protected static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.CallImplementor	createImplementor(java.lang.reflect.Method method)
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)
protected static void	validateMethod(java.lang.reflect.Method method)

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

Constructor Detail

ScalarFunctionImpl

protected ScalarFunctionImpl(java.lang.reflect.Method method,
                             org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.CallImplementor implementor)

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.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

validateMethod

protected static void validateMethod(java.lang.reflect.Method method)

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

createImplementor

protected static org.apache.beam.vendor.calcite.v1_20_0.org.apache.calcite.adapter.enumerable.CallImplementor createImplementor(java.lang.reflect.Method method)

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)