Package org.apache.beam.sdk.transforms

Interface Contextful.Fn<InputT,OutputT>

All Superinterfaces:

Serializable

All Known Implementing Classes:

Watch.Growth.PollFn

Enclosing class:

Contextful<ClosureT>

public static interface Contextful.Fn<InputT,OutputT>
extends Serializable

A function from an input to an output that may additionally access Contextful.Fn.Context when computing the result.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	Contextful.Fn.Context	An accessor for additional capabilities available in apply(InputT, org.apache.beam.sdk.transforms.Contextful.Fn.Context).

Method Summary

Modifier and Type	Method	Description
OutputT	apply(InputT element, Contextful.Fn.Context c)	Invokes the function on the given input with the given context.

Method Details

apply

OutputT apply(InputT element,
 Contextful.Fn.Context c)
       throws Exception

Invokes the function on the given input with the given context. The function may use the context only for the capabilities declared in the Contextful.getRequirements() of the enclosing Contextful.

Throws:

Exception