org.apache.beam.sdk.extensions.sql.zetasql.translation

Class ZetaSqlScalarFunctionImpl

java.lang.Object

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

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

org.apache.beam.sdk.extensions.sql.zetasql.translation.ZetaSqlScalarFunctionImpl

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 ZetaSqlScalarFunctionImpl
extends ScalarFunctionImpl

ZetaSQL-specific extension to ScalarFunctionImpl.

Nested Class Summary

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

UdfImplReflectiveFunctionBase.ParameterListBuilder

Field Summary

Fields

Modifier and Type	Field and Description
java.lang.String	functionGroup ZetaSQL function group identifier.

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, java.lang.String functionGroup, java.lang.String jarPath) 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, java.lang.String functionGroup, java.lang.String jarPath) Creates Function from given method.

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

create, createAll, createImplementor, getImplementor, getJarPath, getReturnType, getReturnType, validateMethod

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

Field Detail

functionGroup

public final java.lang.String functionGroup

ZetaSQL function group identifier. Different function groups may have divergent translation paths.

Method Detail

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,
                                                                                               java.lang.String functionGroup,
                                                                                               java.lang.String jarPath)

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")

functionGroup - ZetaSQL function group identifier. Different function groups may have divergent translation paths.

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,
                                                                                               java.lang.String functionGroup,
                                                                                               java.lang.String jarPath)

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

Parameters:

method - method that is used to implement the function

functionGroup - ZetaSQL function group identifier. Different function groups may have divergent translation paths.

Returns:

created Function or null