BoundedWindow (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Class BoundedWindow

  • java.lang.Object
  • Direct Known Subclasses:
    GlobalWindow, IntervalWindow

    public abstract class BoundedWindow
    extends Object
    A BoundedWindow represents a finite grouping of elements, with an upper bound (larger timestamps represent more recent data) on the timestamps of elements that can be placed in the window. This finiteness means that for every window, at some point in time, all data for that window will have arrived and can be processed together.

    Windows must also implement Object.equals(java.lang.Object) and Object.hashCode() such that windows that are logically equal will be treated as equal by equals() and hashCode().

    • Field Detail


        public static final Instant TIMESTAMP_MIN_VALUE

        public static final Instant TIMESTAMP_MAX_VALUE
    • Constructor Detail

      • BoundedWindow

        public BoundedWindow()
    • Method Detail

      • maxTimestamp

        public abstract Instant maxTimestamp()
        Returns the inclusive upper bound of timestamps for values in this window.

이 페이지가 도움이 되었나요? 평가를 부탁드립니다.

다음에 대한 의견 보내기...

Dataflow: Stream & Batch Processing
도움이 필요하시나요? 지원 페이지를 방문하세요.