public abstract class EncodedBoundedWindow extends BoundedWindow
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.
Modifier and Type | Class and Description |
---|---|
static class |
EncodedBoundedWindow.Coder
|
TIMESTAMP_MAX_VALUE, TIMESTAMP_MIN_VALUE
Constructor and Description |
---|
EncodedBoundedWindow() |
Modifier and Type | Method and Description |
---|---|
static EncodedBoundedWindow |
forEncoding(org.apache.beam.vendor.grpc.v1p43p2.com.google.protobuf.ByteString encodedWindow) |
abstract org.apache.beam.vendor.grpc.v1p43p2.com.google.protobuf.ByteString |
getEncodedWindow() |
Instant |
maxTimestamp()
Returns the inclusive upper bound of timestamps for values in this window.
|
formatTimestamp, validateTimestampBounds
public static EncodedBoundedWindow forEncoding(org.apache.beam.vendor.grpc.v1p43p2.com.google.protobuf.ByteString encodedWindow)
public abstract org.apache.beam.vendor.grpc.v1p43p2.com.google.protobuf.ByteString getEncodedWindow()
public Instant maxTimestamp()
BoundedWindow
maxTimestamp
in class BoundedWindow