org.apache.beam.sdk.transforms

Interface Contextful.Fn<InputT,OutputT>

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

Watch.Growth.PollFn

Enclosing class:

Contextful<ClosureT>

public static interface Contextful.Fn<InputT,OutputT>
extends java.io.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 and 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 and Description
OutputT	apply(InputT element, Contextful.Fn.Context c) Invokes the function on the given input with the given context.

Method Detail

apply

OutputT apply(InputT element,
              Contextful.Fn.Context c)
       throws java.lang.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:

java.lang.Exception