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

Class JavaUdfLoader

java.lang.Object

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

public class JavaUdfLoader
extends 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	Description
JavaUdfLoader()

Method Summary

Modifier and Type	Method	Description
ClassLoader	createClassLoader(List<String> inputJarPaths)
AggregateFn	loadAggregateFunction(List<String> functionPath, String jarPath)	Load a user-defined aggregate function from the specified jar.
ScalarFn	loadScalarFunction(List<String> functionPath, 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 Details

JavaUdfLoader

public JavaUdfLoader()

Method Details

loadScalarFunction

public ScalarFn loadScalarFunction(List<String> functionPath,
 String jarPath)

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

loadAggregateFunction

public AggregateFn loadAggregateFunction(List<String> functionPath,
 String jarPath)

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

createClassLoader

public ClassLoader createClassLoader(List<String> inputJarPaths)
                              throws IOException

Throws:

IOException