Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.transforms
Class CombineWithContext
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.transforms.CombineWithContext
-
public class CombineWithContext extends Object
This class contains combine functions that have access toPipelineOptions
and side inputs throughCombineWithContext.Context
.CombineWithContext.CombineFnWithContext
andCombineWithContext.KeyedCombineFnWithContext
are for users to extend.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class and 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 class
CombineWithContext.KeyedCombineFnWithContext<K,InputT,AccumT,OutputT>
A keyed combine function that has access toPipelineOptions
and side inputs throughCombineWithContext.Context
.static interface
CombineWithContext.RequiresContextInternal
An internal interface for signaling that aGloballyCombineFn
or aPerKeyCombineFn
needs to accessCombineWithContext.Context
.
-
Constructor Summary
Constructors Constructor and Description CombineWithContext()
-