Global Snapshot, Chandy Lamport Algorithm & Consistent Cut

Apache Flink Specifying Keys

KeyBy is one of the mostly used transformation operator for data streams. It is used to partition the data…

Flink Architecture — Job manager, Task manager and Job client

Windowing in Apache Flink

Windowing is a key feature in stream processing systems such as Apache Flink. Windowing splits the continuous…

Lamport Timestamps

The Clock is an important building block in cloud computing systems and distributed systems. Clock is important to maintain…

Twitter Streaming using Flink

Flink is an open source stream-processing framework. It does provide stateful computation over data…

Windowing in Flink

Windowing is a crucial concept in stream processing frameworks or when we are dealing with an infinite amount of data. In…

Data Streams Types

In simple words, data streams are dynamic data that is generated on a continual basis. This allows you to analyse data in real-time and gain insights on a wide range of scenarios. Few example use cases of data streams are :

• Sensor readings from machines