From the course: Apache Flink: Real-Time Data Engineering
Join today to access over 22,500 courses taught by industry experts or purchase this course individually.
Window joins - Flink Tutorial
From the course: Apache Flink: Real-Time Data Engineering
Window joins
- [Instructor] Flink allows to perform SQL-like horizontal joins on two data streams in the same window. Within a given window, the two data streams act like SQL tables. Join conditions can be specified, and it results in a Cartesian product of the matching rows. The example code is available, in the windows joins class under Chapter Three. In this example we will use two audit trial streams. The five streams, as well as the Kafka streams simultaneously. We will then join both the streams based on the user, with a window of five seconds. For each matching record, we will output the username and the count. Let's explore the code now. We will set up and consume the CSV file stream into the file trial 'obj' object. Then we set up and consume a Kafka topic stream, into the Kafka trial 'obj' object. We have reviewed the sets of code in our previous examples. Now let's get to the join function. We use the join function on…
Practice while you learn with exercise files
Download the files the instructor uses to teach the course. Follow along and learn by watching, listening and practicing.
Download courses and learn on the go
Watch courses on your mobile device without an internet connection. Download courses using your iOS or Android LinkedIn Learning app.