Package 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_28_0.org.apache.calcite.schema.Function, org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.ImplementableFunction, org.apache.beam.vendor.calcite.v1_28_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	Description
final 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	Description
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Function	create(Class<?> clazz, String methodName, String functionGroup, String jarPath)	Creates Function from given class.
static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Function	create(Method method, String functionGroup, String jarPath)	Creates Function from given method.

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

create, 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_28_0.org.apache.calcite.schema.Function

getParameters

Field Details

functionGroup

public final String functionGroup

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

Method Details

create

public static org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Function create(Class<?> clazz,
 String methodName,
 String functionGroup,
 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_28_0.org.apache.calcite.schema.Function create(Method method,
 String functionGroup,
 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