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.

  • 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

      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