Package org.apache.beam.sdk.transforms
Class Contextful.Fn.Context
- java.lang.Object
-
- org.apache.beam.sdk.transforms.Contextful.Fn.Context
-
- Enclosing interface:
- Contextful.Fn<InputT,OutputT>
public abstract static class Contextful.Fn.Context extends java.lang.Object
An accessor for additional capabilities available inContextful.Fn.apply(InputT, org.apache.beam.sdk.transforms.Contextful.Fn.Context)
.
-
-
Constructor Summary
Constructors Constructor Description Context()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> T
sideInput(PCollectionView<T> view)
Accesses the given side input.static <InputT> Contextful.Fn.Context
wrapProcessContext(DoFn.ProcessContext c)
Convenience wrapper for creating aContextful.Fn.Context
from aDoFn.ProcessContext
, to support the common case when aPTransform
is invoking theclosure
from inside aDoFn
.
-
-
-
Method Detail
-
sideInput
public <T> T sideInput(PCollectionView<T> view)
Accesses the given side input. The window in which it is accessed is unspecified, depends on usage by the enclosingPTransform
, and must be documented by that transform.
-
wrapProcessContext
public static <InputT> Contextful.Fn.Context wrapProcessContext(DoFn.ProcessContext c)
Convenience wrapper for creating aContextful.Fn.Context
from aDoFn.ProcessContext
, to support the common case when aPTransform
is invoking theclosure
from inside aDoFn
.
-
-