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:

java.io.Serializable

Enclosing class:

JavaRowUdf

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class JavaRowUdf.Configuration
extends java.lang.Object
implements java.io.Serializable

See Also:

Serialized Form

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
Configuration()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

Configuration

public Configuration()

Method Detail

getExpression

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

getCallable

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

getPath

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

getName

@SchemaFieldDescription(value="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 java.lang.String getName()

validate

public void validate()

builder

public static JavaRowUdf.Configuration.Builder builder()