Package 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 accessContextful.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 inapply(InputT, org.apache.beam.sdk.transforms.Contextful.Fn.Context)
.
-
Method Summary
All Methods Instance Methods Abstract Methods 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 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 theContextful.getRequirements()
of the enclosingContextful
.- Throws:
java.lang.Exception
-
-