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

Class JavaRowUdf.Configuration

java.lang.Object

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

All Implemented Interfaces:

Serializable

Enclosing class:

JavaRowUdf

@DefaultSchema(AutoValueSchema.class)
public abstract static class JavaRowUdf.Configuration
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	JavaRowUdf.Configuration.Builder

Constructor Summary

Constructors

Constructor	Description
Configuration()

Method Summary

Modifier and Type	Method	Description
static JavaRowUdf.Configuration.Builder	builder()
abstract String	getCallable()
abstract String	getExpression()
abstract String	getName()
abstract String	getPath()
void	validate()

Methods inherited from class java.lang.Object

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

Constructor Details

Configuration

public Configuration()

Method Details

getExpression

@SchemaFieldDescription("Source code of a java expression in terms of the schema fields.")
@Nullable
public abstract String getExpression()

getCallable

@SchemaFieldDescription("Source code of a public class implementing Function<Row, T> for some schema-compatible T.")
@Nullable
public abstract String getCallable()

getPath

@SchemaFieldDescription("Path to a jar file implementing the function referenced in name.")
@Nullable
public abstract String getPath()

getName

@SchemaFieldDescription("Fully qualified name of either a class implementing Function<Row, T> (e.g. com.pkg.MyFunction), or a method taking a single Row argument (e.g. com.pkg.MyClass::methodName). If a method is passed, it must either be static or belong to a class with a public nullary constructor.")
@Nullable
public abstract String getName()

validate

public void validate()

builder

public static JavaRowUdf.Configuration.Builder builder()