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

public abstract class EncodedBoundedWindow
extends BoundedWindow

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 Classes

Modifier and Type	Class and Description
static class	EncodedBoundedWindow.Coder An EncodedBoundedWindow.Coder for EncodedBoundedWindows.

Field Summary

Fields inherited from class org.apache.beam.sdk.transforms.windowing.BoundedWindow

TIMESTAMP_MAX_VALUE, TIMESTAMP_MIN_VALUE

Constructor Summary

Constructors

Constructor and Description
EncodedBoundedWindow()

Method Summary

Modifier and Type	Method and Description
static EncodedBoundedWindow	forEncoding(com.google.protobuf.ByteString encodedWindow)
abstract com.google.protobuf.ByteString	getEncodedWindow()
Instant	maxTimestamp() Returns the inclusive upper bound of timestamps for values in this window.

Methods inherited from class org.apache.beam.sdk.transforms.windowing.BoundedWindow

formatTimestamp

Methods inherited from class java.lang.Object

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

Constructor Detail

EncodedBoundedWindow

public EncodedBoundedWindow()

Method Detail

forEncoding

public static EncodedBoundedWindow forEncoding(com.google.protobuf.ByteString encodedWindow)

getEncodedWindow

public abstract com.google.protobuf.ByteString getEncodedWindow()

maxTimestamp

public Instant maxTimestamp()

Description copied from class: BoundedWindow

Returns the inclusive upper bound of timestamps for values in this window.

Specified by:

maxTimestamp in class BoundedWindow