Package org.apache.beam.sdk.schemas.transforms.providers

Class JavaRowUdf

java.lang.Object

org.apache.beam.sdk.schemas.transforms.providers.JavaRowUdf

All Implemented Interfaces:

Serializable

public class JavaRowUdf
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JavaRowUdf.Configuration

Constructor Summary

Constructors

Constructor	Description
JavaRowUdf(JavaRowUdf.Configuration config, Schema inputSchema)

Method Summary

Modifier and Type	Method	Description
Function<Row,Object>	getFunction()
Schema.FieldType	getOutputType()

Methods inherited from class java.lang.Object

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

Constructor Details

JavaRowUdf

public JavaRowUdf(JavaRowUdf.Configuration config,
 Schema inputSchema)
           throws MalformedURLException,
ReflectiveOperationException,
StringCompiler.CompileException

Throws:

MalformedURLException

ReflectiveOperationException

StringCompiler.CompileException

Method Details

getOutputType

public Schema.FieldType getOutputType()

getFunction

public Function<Row,Object> getFunction()
                                 throws MalformedURLException,
ReflectiveOperationException,
StringCompiler.CompileException

Throws:

MalformedURLException

ReflectiveOperationException

StringCompiler.CompileException