Window
Stores in memory subsets of streaming data and sends the windowing results as micro-batches to the output flow.
The Window processor accumulates records that can be later aggregated and used to make corresponding business decisions.