public class WindowingStrategyTranslation
extends java.lang.Object
implements java.io.Serializable
WindowingStrategies
.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
FIXED_WINDOWS_URN |
static java.lang.String |
GLOBAL_WINDOWS_URN |
static java.lang.String |
SERIALIZED_JAVA_WINDOWFN_URN |
static java.lang.String |
SESSION_WINDOWS_URN |
static java.lang.String |
SLIDING_WINDOWS_URN |
Constructor and Description |
---|
WindowingStrategyTranslation() |
Modifier and Type | Method and Description |
---|---|
static WindowingStrategy.AccumulationMode |
fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.AccumulationMode.Enum proto) |
static Window.ClosingBehavior |
fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.ClosingBehavior.Enum proto) |
static WindowingStrategy<?,?> |
fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.MessageWithComponents proto)
Converts from a
RunnerApi.WindowingStrategy accompanied by RunnerApi.Components to the
SDK's WindowingStrategy . |
static Window.OnTimeBehavior |
fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.OnTimeBehavior.Enum proto) |
static WindowingStrategy<?,?> |
fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.WindowingStrategy proto,
RehydratedComponents components)
Converts from
RunnerApi.WindowingStrategy to the SDK's WindowingStrategy using
the provided components to dereferences identifiers found in the proto. |
static TimestampCombiner |
timestampCombinerFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.OutputTime.Enum proto) |
static org.apache.beam.model.pipeline.v1.RunnerApi.MessageWithComponents |
toMessageProto(WindowingStrategy<?,?> windowingStrategy,
SdkComponents components)
Converts a
WindowingStrategy into a RunnerApi.MessageWithComponents where
RunnerApi.MessageWithComponents#getWindowingStrategy() ()} is a RunnerApi.WindowingStrategy (proto) for the input WindowingStrategy . |
static org.apache.beam.model.pipeline.v1.RunnerApi.OutputTime.Enum |
toProto(TimestampCombiner timestampCombiner) |
static org.apache.beam.model.pipeline.v1.RunnerApi.ClosingBehavior.Enum |
toProto(Window.ClosingBehavior closingBehavior) |
static org.apache.beam.model.pipeline.v1.RunnerApi.OnTimeBehavior.Enum |
toProto(Window.OnTimeBehavior onTimeBehavior) |
static org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec |
toProto(WindowFn<?,?> windowFn,
SdkComponents components)
|
static org.apache.beam.model.pipeline.v1.RunnerApi.AccumulationMode.Enum |
toProto(WindowingStrategy.AccumulationMode accumulationMode) |
static org.apache.beam.model.pipeline.v1.RunnerApi.WindowingStrategy |
toProto(WindowingStrategy<?,?> windowingStrategy,
SdkComponents components)
Converts a
WindowingStrategy into a RunnerApi.WindowingStrategy , registering
any components in the provided SdkComponents . |
static WindowFn<?,?> |
windowFnFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec windowFnSpec) |
public static final java.lang.String SERIALIZED_JAVA_WINDOWFN_URN
public static final java.lang.String GLOBAL_WINDOWS_URN
public static final java.lang.String FIXED_WINDOWS_URN
public static final java.lang.String SLIDING_WINDOWS_URN
public static final java.lang.String SESSION_WINDOWS_URN
public static WindowingStrategy.AccumulationMode fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.AccumulationMode.Enum proto)
public static org.apache.beam.model.pipeline.v1.RunnerApi.AccumulationMode.Enum toProto(WindowingStrategy.AccumulationMode accumulationMode)
public static org.apache.beam.model.pipeline.v1.RunnerApi.ClosingBehavior.Enum toProto(Window.ClosingBehavior closingBehavior)
public static Window.ClosingBehavior fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.ClosingBehavior.Enum proto)
public static org.apache.beam.model.pipeline.v1.RunnerApi.OnTimeBehavior.Enum toProto(Window.OnTimeBehavior onTimeBehavior)
public static Window.OnTimeBehavior fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.OnTimeBehavior.Enum proto)
public static org.apache.beam.model.pipeline.v1.RunnerApi.OutputTime.Enum toProto(TimestampCombiner timestampCombiner)
public static TimestampCombiner timestampCombinerFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.OutputTime.Enum proto)
public static org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec toProto(WindowFn<?,?> windowFn, SdkComponents components)
public static org.apache.beam.model.pipeline.v1.RunnerApi.MessageWithComponents toMessageProto(WindowingStrategy<?,?> windowingStrategy, SdkComponents components) throws java.io.IOException
WindowingStrategy
into a RunnerApi.MessageWithComponents
where
RunnerApi.MessageWithComponents#getWindowingStrategy()
()} is a RunnerApi.WindowingStrategy (proto)
for the input WindowingStrategy
.java.io.IOException
public static org.apache.beam.model.pipeline.v1.RunnerApi.WindowingStrategy toProto(WindowingStrategy<?,?> windowingStrategy, SdkComponents components) throws java.io.IOException
WindowingStrategy
into a RunnerApi.WindowingStrategy
, registering
any components in the provided SdkComponents
.java.io.IOException
public static WindowingStrategy<?,?> fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.MessageWithComponents proto) throws org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException
RunnerApi.WindowingStrategy
accompanied by RunnerApi.Components
to the
SDK's WindowingStrategy
.org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException
public static WindowingStrategy<?,?> fromProto(org.apache.beam.model.pipeline.v1.RunnerApi.WindowingStrategy proto, RehydratedComponents components) throws org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException
RunnerApi.WindowingStrategy
to the SDK's WindowingStrategy
using
the provided components to dereferences identifiers found in the proto.org.apache.beam.vendor.grpc.v1p60p1.com.google.protobuf.InvalidProtocolBufferException
public static WindowFn<?,?> windowFnFromProto(org.apache.beam.model.pipeline.v1.RunnerApi.FunctionSpec windowFnSpec)