Package org.apache.beam.sdk.fn.windowing
Class EncodedBoundedWindow
java.lang.Object
org.apache.beam.sdk.transforms.windowing.BoundedWindow
org.apache.beam.sdk.fn.windowing.EncodedBoundedWindow
An encoded
BoundedWindow
used within Runners to track window information without needing
to decode the window.
This allows for Runners to not need to know window format during execution.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
-
Field Summary
Fields inherited from class org.apache.beam.sdk.transforms.windowing.BoundedWindow
TIMESTAMP_MAX_VALUE, TIMESTAMP_MIN_VALUE
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic EncodedBoundedWindow
forEncoding
(org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString encodedWindow) abstract org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString
Returns the inclusive upper bound of timestamps for values in this window.Methods inherited from class org.apache.beam.sdk.transforms.windowing.BoundedWindow
formatTimestamp, validateTimestampBounds
-
Constructor Details
-
EncodedBoundedWindow
public EncodedBoundedWindow()
-
-
Method Details
-
forEncoding
public static EncodedBoundedWindow forEncoding(org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString encodedWindow) -
getEncodedWindow
public abstract org.apache.beam.vendor.grpc.v1p69p0.com.google.protobuf.ByteString getEncodedWindow() -
maxTimestamp
Description copied from class:BoundedWindow
Returns the inclusive upper bound of timestamps for values in this window.- Specified by:
maxTimestamp
in classBoundedWindow
-