Package org.apache.beam.sdk.transforms
Class CombineWithContext
- java.lang.Object
-
- org.apache.beam.sdk.transforms.CombineWithContext
-
public class CombineWithContext extends java.lang.Object
This class contains combine functions that have access toPipelineOptions
and side inputs throughCombineWithContext.Context
.CombineWithContext.CombineFnWithContext
is for users to extend.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT>
A combine function that has access toPipelineOptions
and side inputs throughCombineWithContext.Context
.static class
CombineWithContext.Context
Information accessible to all methods inCombineFnWithContext
andKeyedCombineFnWithContext
.static interface
CombineWithContext.RequiresContextInternal
An internal interface for signaling that aGloballyCombineFn
or aPerKeyCombineFn
needs to accessCombineWithContext.Context
.
-
Constructor Summary
Constructors Constructor Description CombineWithContext()
-