org.apache.flink.statefun.sdk.java

Class StatefulFunctionSpec.Builder

java.lang.Object

org.apache.flink.statefun.sdk.java.StatefulFunctionSpec.Builder

Enclosing class:

StatefulFunctionSpec

public static final class StatefulFunctionSpec.Builder
extends java.lang.Object

Builder for a StatefulFunctionSpec.

Method Summary

Modifier and Type	Method and Description
StatefulFunctionSpec	build() Builds the StatefulFunctionSpec.
StatefulFunctionSpec.Builder	withSupplier(java.util.function.Supplier<? extends StatefulFunction> supplier) A Supplier used to create instances of a StatefulFunction for this StatefulFunctionSpec.
StatefulFunctionSpec.Builder	withValueSpec(ValueSpec<?> valueSpec) Registers a ValueSpec that will be used by this function.
StatefulFunctionSpec.Builder	withValueSpecs(ValueSpec<?>... valueSpecs) Registers multiple ValueSpecs that will be used by this function.

Methods inherited from class java.lang.Object

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

Method Detail

withValueSpec

public StatefulFunctionSpec.Builder withValueSpec(ValueSpec<?> valueSpec)

Registers a ValueSpec that will be used by this function. A function may only access values which have a registered ValueSpec.

Parameters:

valueSpec - the value spec to register.

Throws:

java.lang.IllegalArgumentException - if multiple ValueSpecs with the same name was registered.

withValueSpecs

public StatefulFunctionSpec.Builder withValueSpecs(ValueSpec<?>... valueSpecs)

Registers multiple ValueSpecs that will be used by this function. A function may only access values which have a registered ValueSpec.

Parameters:

valueSpecs - the value specs to register.

Throws:

java.lang.IllegalArgumentException - if multiple ValueSpecs with the same name was registered.

withSupplier

public StatefulFunctionSpec.Builder withSupplier(java.util.function.Supplier<? extends StatefulFunction> supplier)

A Supplier used to create instances of a StatefulFunction for this StatefulFunctionSpec.

Parameters:

supplier - the supplier.

build

public StatefulFunctionSpec build()

Builds the StatefulFunctionSpec.