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 Object

An accessor for additional capabilities available in Contextful.Fn.apply(InputT, org.apache.beam.sdk.transforms.Contextful.Fn.Context).

Constructor Summary

Constructors

Constructor	Description
Context()

Method Summary

Modifier and Type	Method	Description
<T> T	sideInput(PCollectionView<T> view)	Accesses the given side input.
static <InputT> Contextful.Fn.Context	wrapProcessContext(DoFn<InputT,?>.ProcessContext c)	Convenience wrapper for creating a Contextful.Fn.Context from a DoFn.ProcessContext, to support the common case when a PTransform is invoking the closure from inside a DoFn.

Methods inherited from class java.lang.Object

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

Constructor Details

Context

public Context()

Method Details

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 enclosing PTransform, and must be documented by that transform.

wrapProcessContext

public static <InputT> Contextful.Fn.Context wrapProcessContext(DoFn<InputT,?>.ProcessContext c)

Convenience wrapper for creating a Contextful.Fn.Context from a DoFn.ProcessContext, to support the common case when a PTransform is invoking the closure from inside a DoFn.