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 in Contextful.Fn.apply(InputT, org.apache.beam.sdk.transforms.Contextful.Fn.Context).

Constructor Summary

Constructors

Constructor and Description
Context()

Method Summary

Modifier and Type	Method and 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 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 Detail

Context

public Context()

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

wrapProcessContext

public static <InputT> Contextful.Fn.Context wrapProcessContext(DoFn.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.