org.apache.beam.sdk.extensions.sql.impl

Class JavaUdfLoader

java.lang.Object

org.apache.beam.sdk.extensions.sql.impl.JavaUdfLoader

public class JavaUdfLoader
extends java.lang.Object

Loads UdfProvider implementations from user-provided jars.

All UDFs are loaded and cached for each jar to mitigate IO costs.

Constructor Summary

Constructors

Constructor and Description
JavaUdfLoader()

Method Summary

Modifier and Type	Method and Description
java.lang.ClassLoader	createClassLoader(java.util.List<java.lang.String> inputJarPaths)
AggregateFn	loadAggregateFunction(java.util.List<java.lang.String> functionPath, java.lang.String jarPath) Load a user-defined aggregate function from the specified jar.
ScalarFn	loadScalarFunction(java.util.List<java.lang.String> functionPath, java.lang.String jarPath) Load a user-defined scalar function from the specified jar.

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaUdfLoader

public JavaUdfLoader()

Method Detail

loadScalarFunction

public ScalarFn loadScalarFunction(java.util.List<java.lang.String> functionPath,
                                   java.lang.String jarPath)

Load a user-defined scalar function from the specified jar.

loadAggregateFunction

public AggregateFn loadAggregateFunction(java.util.List<java.lang.String> functionPath,
                                         java.lang.String jarPath)

Load a user-defined aggregate function from the specified jar.

createClassLoader

public java.lang.ClassLoader createClassLoader(java.util.List<java.lang.String> inputJarPaths)
                                        throws java.io.IOException

Throws:

java.io.IOException