Random Thoughts on Coding
A technical blog on whatever comes to mind
-
Mastering Stream Processing - Viewing and analyzing results
This is the sixth blog in a series on windowing in event stream processing. Here’s a list of the previous posts: Introduction to windowing Hopping and Tumbling windows Sliding windows and OVER aggregation Session windows Cumulating windows Window time semantics In this post, we’ll move on from covering the specific...
-
Mastering Stream Processing - Time semantics
In the previous blog in this series, we wrapped up coverage of the different windowing types. Here is the list of earlier installments in this series: Introduction to windowing Hopping and Tumbling windows Sliding windows and OVER aggregation Session windows Cumulating windows In this post, we’ll move on from specific...
-
Mastering Stream Processing - Session and Cumulating windows
In the third installment of this windowing blog series, you’ll learn about cumulating and session windows. In previous posts, we’ve covered hopping and tumbling windows and sliding windows and the Flink SQL equivalent - OVER aggregations. The cumulate window is unique to Flink SQL. The session window has been available...
-
Mastering Stream Processing - Sliding windows and OVER aggregations
In the third installment of this windowing blog series, you’ll learn about sliding windows and a bit of SQL. In the previous post, we covered hopping and tumbling windows, both of which Kafka Streams and Flink SQL provide. In this installment, we will discuss sliding windows, supported by Kafka Streams...
-
Mastering Stream Processing - Hoppping and Tumbling windows
In the first post of this series, we discussed what event streaming windowing is, and we examined in detail the structure of a windowed aggregate in Kafka Streams and Flink SQL. In this post, we’ll dive into two specific windowing implementations: hopping and tumbling windows. Hopping windows A hopping window...