Package org.apache.beam.sdk.transforms

Class Contextful<ClosureT>

java.lang.Object

org.apache.beam.sdk.transforms.Contextful<ClosureT>

All Implemented Interfaces:

Serializable

public final class Contextful<ClosureT>
extends Object
implements Serializable

Pair of a bit of user code (a "closure") and the Requirements needed to run it.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Contextful.Fn<InputT,OutputT>	A function from an input to an output that may additionally access Contextful.Fn.Context when computing the result.

Method Summary

Modifier and Type	Method	Description
static <InputT, OutputT> Contextful<Contextful.Fn<InputT,OutputT>>	fn(Contextful.Fn<InputT,OutputT> fn, Requirements requirements)	Same with of(ClosureT, org.apache.beam.sdk.transforms.Requirements) but with better type inference behavior for the case of Contextful.Fn.
static <InputT, OutputT> Contextful<Contextful.Fn<InputT,OutputT>>	fn(ProcessFunction<InputT,OutputT> fn)	Wraps a ProcessFunction as a Contextful of Contextful.Fn with empty Requirements.
static <InputT, OutputT> Contextful<Contextful.Fn<InputT,OutputT>>	fn(SerializableFunction<InputT,OutputT> fn)	Binary compatibility adapter for fn(ProcessFunction).
ClosureT	getClosure()	Returns the closure.
Requirements	getRequirements()	Returns the requirements needed to run the closure.
static <ClosureT> Contextful<ClosureT>	of(ClosureT closure, Requirements requirements)	Constructs a pair of the given closure and its requirements.
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

getClosure

public ClosureT getClosure()

Returns the closure.

getRequirements

public Requirements getRequirements()

Returns the requirements needed to run the closure.

of

public static <ClosureT> Contextful<ClosureT> of(ClosureT closure,
 Requirements requirements)

Constructs a pair of the given closure and its requirements.

toString

public String toString()

Overrides:

toString in class Object

fn

public static <InputT,
OutputT>
Contextful<Contextful.Fn<InputT,OutputT>> fn(ProcessFunction<InputT,OutputT> fn)

Wraps a ProcessFunction as a Contextful of Contextful.Fn with empty Requirements.

fn

public static <InputT,
OutputT>
Contextful<Contextful.Fn<InputT,OutputT>> fn(SerializableFunction<InputT,OutputT> fn)

Binary compatibility adapter for fn(ProcessFunction).

fn

public static <InputT,
OutputT>
Contextful<Contextful.Fn<InputT,OutputT>> fn(Contextful.Fn<InputT,OutputT> fn,
 Requirements requirements)

Same with of(ClosureT, org.apache.beam.sdk.transforms.Requirements) but with better type inference behavior for the case of Contextful.Fn.