Package 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 Object

Information accessible to all methods in CombineFnWithContext and KeyedCombineFnWithContext.

Constructor Summary

Constructors

Constructor	Description
Context()

Method Summary

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

Context

public Context()

Method Details

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.