Package org.apache.beam.sdk.transforms

Class Contextful<ClosureT>

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

@Experimental(CONTEXTFUL)
public final class Contextful<ClosureT>
extends java.lang.Object
implements java.io.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.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

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 java.lang.String toString()

Overrides:

toString in class java.lang.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.