Interface Window<T>

Type Parameters:
T - the type of event that this window contains. E.g. Tuple
All Known Subinterfaces:
TupleWindow
All Known Implementing Classes:
TupleWindowImpl, TupleWindowIterImpl

public interface Window<T>
A view of events in a sliding window.
  • Method Summary

    Modifier and Type
    Method
    Description
    get()
    Gets the list of events in the window.
    If processing based on event time, returns the window end time based on watermark otherwise returns the window end time based on processing time.
    Get the list of events expired from the window since the last time the window was generated.
    default Iterator<T>
    Returns an iterator over the events in the window.
    Get the list of newly added events in the window since the last time the window was generated.
    Returns the window start timestamp.