public class WindowIntoTranslation
extends java.lang.Object
Window.Assign
to and from RunnerApi
representations.Modifier and Type | Class and Description |
---|---|
static class |
WindowIntoTranslation.Registrar
|
static class |
WindowIntoTranslation.WindowIntoPayloadTranslator
|
Constructor and Description |
---|
WindowIntoTranslation() |
Modifier and Type | Method and Description |
---|---|
static @Nullable WindowFn<?,?> |
getWindowFn(AppliedPTransform<?,?,?> application) |
static org.apache.beam.model.pipeline.v1.RunnerApi.WindowIntoPayload |
getWindowIntoPayload(AppliedPTransform<?,?,?> application) |
static org.apache.beam.model.pipeline.v1.RunnerApi.WindowIntoPayload |
toProto(Window.Assign<?> transform,
SdkComponents components) |
public static org.apache.beam.model.pipeline.v1.RunnerApi.WindowIntoPayload toProto(Window.Assign<?> transform, SdkComponents components)
public static org.apache.beam.model.pipeline.v1.RunnerApi.WindowIntoPayload getWindowIntoPayload(AppliedPTransform<?,?,?> application)
public static @Nullable WindowFn<?,?> getWindowFn(AppliedPTransform<?,?,?> application)