org.apache.beam.runners.core.construction

Class WindowingStrategies

java.lang.Object

org.apache.beam.runners.core.construction.WindowingStrategies

All Implemented Interfaces:

Serializable

public class WindowingStrategies
extends Object
implements Serializable

Utilities for working with WindowingStrategies.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	CUSTOM_WINDOWFN_URN

Constructor Summary

Constructors

Constructor and Description
WindowingStrategies()

Method Summary

Modifier and Type	Method and Description
static WindowingStrategy.AccumulationMode	fromProto(RunnerApi.AccumulationMode proto)
static Window.ClosingBehavior	fromProto(RunnerApi.ClosingBehavior proto)
static WindowingStrategy<?,?>	fromProto(RunnerApi.MessageWithComponents proto) Converts from a RunnerApi.WindowingStrategy accompanied by RunnerApi.Components to the SDK's WindowingStrategy.
static WindowingStrategy<?,?>	fromProto(RunnerApi.WindowingStrategy proto, RunnerApi.Components components) Converts from RunnerApi.WindowingStrategy to the SDK's WindowingStrategy using the provided components to dereferences identifiers found in the proto.
static TimestampCombiner	timestampCombinerFromProto(RunnerApi.OutputTime proto)
static RunnerApi.OutputTime	toProto(TimestampCombiner timestampCombiner)
static RunnerApi.ClosingBehavior	toProto(Window.ClosingBehavior closingBehavior)
static RunnerApi.SdkFunctionSpec	toProto(WindowFn<?,?> windowFn, org.apache.beam.runners.core.construction.SdkComponents components) Converts a WindowFn into a RunnerApi.MessageWithComponents where RunnerApi.MessageWithComponents#getFunctionSpec() is a RunnerApi.FunctionSpec for the input WindowFn.
static RunnerApi.AccumulationMode	toProto(WindowingStrategy.AccumulationMode accumulationMode)
static RunnerApi.MessageWithComponents	toProto(WindowingStrategy<?,?> windowingStrategy) Converts a WindowingStrategy into a RunnerApi.MessageWithComponents where RunnerApi.MessageWithComponents#getWindowingStrategy() ()} is a RunnerApi.WindowingStrategy (proto) for the input WindowingStrategy.
static RunnerApi.WindowingStrategy	toProto(WindowingStrategy<?,?> windowingStrategy, org.apache.beam.runners.core.construction.SdkComponents components) Converts a WindowingStrategy into a RunnerApi.WindowingStrategy, registering any components in the provided SdkComponents.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CUSTOM_WINDOWFN_URN

public static final String CUSTOM_WINDOWFN_URN

See Also:

Constant Field Values

Constructor Detail

WindowingStrategies

public WindowingStrategies()

Method Detail

fromProto

public static WindowingStrategy.AccumulationMode fromProto(RunnerApi.AccumulationMode proto)

toProto

public static RunnerApi.AccumulationMode toProto(WindowingStrategy.AccumulationMode accumulationMode)

toProto

public static RunnerApi.ClosingBehavior toProto(Window.ClosingBehavior closingBehavior)

fromProto

public static Window.ClosingBehavior fromProto(RunnerApi.ClosingBehavior proto)

toProto

public static RunnerApi.OutputTime toProto(TimestampCombiner timestampCombiner)

timestampCombinerFromProto

public static TimestampCombiner timestampCombinerFromProto(RunnerApi.OutputTime proto)

toProto

public static RunnerApi.SdkFunctionSpec toProto(WindowFn<?,?> windowFn,
                                                org.apache.beam.runners.core.construction.SdkComponents components)
                                         throws IOException

Converts a WindowFn into a RunnerApi.MessageWithComponents where RunnerApi.MessageWithComponents#getFunctionSpec() is a RunnerApi.FunctionSpec for the input WindowFn.

Throws:

IOException

toProto

public static RunnerApi.MessageWithComponents toProto(WindowingStrategy<?,?> windowingStrategy)
                                               throws IOException

Converts a WindowingStrategy into a RunnerApi.MessageWithComponents where RunnerApi.MessageWithComponents#getWindowingStrategy() ()} is a RunnerApi.WindowingStrategy (proto) for the input WindowingStrategy.

Throws:

IOException

toProto

public static RunnerApi.WindowingStrategy toProto(WindowingStrategy<?,?> windowingStrategy,
                                                  org.apache.beam.runners.core.construction.SdkComponents components)
                                           throws IOException

Converts a WindowingStrategy into a RunnerApi.WindowingStrategy, registering any components in the provided SdkComponents.

Throws:

IOException

fromProto

public static WindowingStrategy<?,?> fromProto(RunnerApi.MessageWithComponents proto)
                                        throws com.google.protobuf.InvalidProtocolBufferException

Converts from a RunnerApi.WindowingStrategy accompanied by RunnerApi.Components to the SDK's WindowingStrategy.

Throws:

com.google.protobuf.InvalidProtocolBufferException

fromProto

public static WindowingStrategy<?,?> fromProto(RunnerApi.WindowingStrategy proto,
                                               RunnerApi.Components components)
                                        throws com.google.protobuf.InvalidProtocolBufferException

Converts from RunnerApi.WindowingStrategy to the SDK's WindowingStrategy using the provided components to dereferences identifiers found in the proto.

Throws:

com.google.protobuf.InvalidProtocolBufferException