public class CombineWithContext
extends java.lang.Object
PipelineOptions
and side inputs
through CombineWithContext.Context
.
CombineWithContext.CombineFnWithContext
is for users to extend.
Modifier and Type | Class and Description |
---|---|
static class |
CombineWithContext.CombineFnWithContext<InputT,AccumT,OutputT>
A combine function that has access to
PipelineOptions and side inputs through CombineWithContext.Context . |
static class |
CombineWithContext.Context
Information accessible to all methods in
CombineFnWithContext and KeyedCombineFnWithContext . |
static interface |
CombineWithContext.RequiresContextInternal
An internal interface for signaling that a
GloballyCombineFn or a PerKeyCombineFn needs to access CombineWithContext.Context . |
Constructor and Description |
---|
CombineWithContext() |