Package au.csiro.pathling.sql.udf

Class AbstractUDFRegistrar

java.lang.Object

au.csiro.pathling.sql.udf.AbstractUDFRegistrar

All Implemented Interfaces:

SparkConfigurer

public abstract class AbstractUDFRegistrar
extends Object
implements SparkConfigurer

A base spark configurer that registers user defined functions in the sessions.

Author:

Piotr Szul

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	AbstractUDFRegistrar.UDFRegistrar

Constructor Summary

Constructors

Constructor	Description
AbstractUDFRegistrar()

Method Summary

Modifier and Type	Method	Description
void	configure(SparkSession spark)	Configure some aspect of SparkSession
protected abstract void	registerUDFs(AbstractUDFRegistrar.UDFRegistrar udfRegistrar)	Override to perform the actual registration of SqlFunctionXXX instances.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractUDFRegistrar

public AbstractUDFRegistrar()

Method Detail

configure

public void configure(@Nonnull
                      SparkSession spark)

Description copied from interface: SparkConfigurer

Configure some aspect of SparkSession

Specified by:

configure in interface SparkConfigurer

Parameters:

spark - the SparkSession to configure.

registerUDFs

protected abstract void registerUDFs(@Nonnull
                                     AbstractUDFRegistrar.UDFRegistrar udfRegistrar)

Override to perform the actual registration of SqlFunctionXXX instances.

Parameters:

udfRegistrar - the helper to use to register the UDFs.