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