Package au.csiro.pathling.sql.udf

Class AbstractUdfRegistrar.UdfRegistrar

java.lang.Object
au.csiro.pathling.sql.udf.AbstractUdfRegistrar.UdfRegistrar
Enclosing class:
AbstractUdfRegistrar
protected static class AbstractUdfRegistrar.UdfRegistrar extends Object
A helper class for registering user-defined functions with a Spark session.

This class provides convenient methods for registering different types of SQL functions and maintains a fluent interface for chaining multiple registrations.

  • Constructor Details

    • UdfRegistrar

      public UdfRegistrar(@Nonnull SparkSession spark)
      Creates a new UDF registrar for the given Spark session.
      Parameters:
      spark - the Spark session to register functions with

  • Method Details

    • register

      public AbstractUdfRegistrar.UdfRegistrar register(@Nonnull SqlFunction1<?,?> udf1)
      Registers a single-argument SQL function with the Spark session.
      Parameters:
      udf1 - the function to register
      Returns:
      this registrar for method chaining

    • register

      public AbstractUdfRegistrar.UdfRegistrar register(@Nonnull SqlFunction2<?,?,?> udf2)
      Registers a two-argument SQL function with the Spark session.
      Parameters:
      udf2 - the function to register
      Returns:
      this registrar for method chaining