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.
The Window processor accumulates records that can be later aggregated and used to make corresponding business decisions.