Class UdfImplReflectiveFunctionBase

java.lang.Object
org.apache.beam.sdk.extensions.sql.impl.UdfImplReflectiveFunctionBase
All Implemented Interfaces:
org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Function
Direct Known Subclasses:
ScalarFunctionImpl

public abstract class UdfImplReflectiveFunctionBase extends Object implements org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Function
Beam-customized version from ReflectiveFunctionBase, to address BEAM-5921.
  • Field Details

    • method

      public final Method method
      Method that implements the function.
    • parameters

      public final List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.FunctionParameter> parameters
      Types of parameter for the function call.
  • Constructor Details

    • UdfImplReflectiveFunctionBase

      public UdfImplReflectiveFunctionBase(Method method)
      UdfImplReflectiveFunctionBase constructor.
      Parameters:
      method - method that is used to get type information from
  • Method Details

    • getParameters

      public List<org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.FunctionParameter> getParameters()
      Returns the parameters of this function.
      Specified by:
      getParameters in interface org.apache.beam.vendor.calcite.v1_28_0.org.apache.calcite.schema.Function
      Returns:
      Parameters; never null
    • builder

      Creates a ParameterListBuilder.