org.apache.beam.sdk.transforms

Class CombineWithContext.Context

java.lang.Object

org.apache.beam.sdk.transforms.CombineWithContext.Context

Enclosing class:

CombineWithContext

public abstract static class CombineWithContext.Context
extends java.lang.Object

Information accessible to all methods in CombineFnWithContext and KeyedCombineFnWithContext.

Constructor Summary

Constructors

Constructor and Description
Context()

Method Summary

Modifier and Type	Method and Description
abstract PipelineOptions	getPipelineOptions() Returns the PipelineOptions specified with the PipelineRunner invoking this KeyedCombineFn.
abstract <T> T	sideInput(PCollectionView<T> view) Returns the value of the side input for the window corresponding to the main input's window in which values are being combined.

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

getPipelineOptions

public abstract PipelineOptions getPipelineOptions()

Returns the PipelineOptions specified with the PipelineRunner invoking this KeyedCombineFn.

sideInput

public abstract <T> T sideInput(PCollectionView<T> view)

Returns the value of the side input for the window corresponding to the main input's window in which values are being combined.