Stream - Windows

Event Centric Thinking


SQL Function - Window Aggregate (Analytics function) in Stream


Two type:

  • streaming aggregation (tumbling windows).
  • windowed analytics (sliding windows).


Example: find the minimum and maximum each minute


windowed analytics (sliding windows) (same as SQL Function - Window Aggregate (Analytics function) ?)

  • an output record (or row) is produced for each new input record.
  • an output record for each and every new input record for the specific PARTITION
  • Each field (or column) in the output record may be calculated using a different window or partition.
  • Windows definition can be time or row-based.

Example: find the minimum and maximum in the 60 second period prior to any given reading

Discover More
Event Centric Thinking
(Stream|Pipe|Message Queue|Event Processing)

From an abstract point of view, a stream is a sequence of aninfinite cardinality (size) delivered at unknown time intervals. list Streams: are inputs and outputs of operations may be also buffers...
Stream Vs Batch
Stream vs Batch

This article talks Stream Processing vs Batch Processing. The most important difference is that: in batch processing the size (cardinality) of the data to process is known whereas in a stream processing,...
Event Centric Thinking
Streaming - SQL

continuous SQL query on an infinite data stream A streaming sql can not be ANSI SQL compliant because the streaming functions are not part of those database standards. A streaming query is a query that...

Share this page:
Follow us:
Task Runner