Versions Compared

Old Version 29

changes.mady.by.user Leah Thomas

Saved on

compared with

New Version 30

changes.mady.by.user Leah Thomas

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Figure 2: Windows with HoppingWindow with a 1ms advance: Window size 10ms, 10 windows for 4 records.


Usage

Sliding window aggregation:

Code Block
stream.groupByKey().windowedBy(SlidingWindows.of(twentySeconds).grace(fiftySeconds).toStream()


Processing Windows

To process a new record, there are three major steps.

...