public class CombineTranslation
extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
static class |
CombineTranslation.CombineGloballyPayloadTranslator
A
PTransformTranslation.TransformPayloadTranslator for Combine.Globally . |
static class |
CombineTranslation.CombineGroupedValuesPayloadTranslator
A
PTransformTranslation.TransformPayloadTranslator for Combine.GroupedValues . |
static class |
CombineTranslation.CombinePerKeyPayloadTranslator
A
PTransformTranslation.TransformPayloadTranslator for Combine.PerKey . |
static class |
CombineTranslation.Registrar
Registers
TransformPayloadTranslators
for Combines . |
Constructor and Description |
---|
CombineTranslation() |
Modifier and Type | Method and Description |
---|---|
static org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec |
toProto(CombineFnBase.GlobalCombineFn<?,?,?> combineFn,
SdkComponents components) |
public static org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec toProto(CombineFnBase.GlobalCombineFn<?,?,?> combineFn, SdkComponents components)