Introduction
Real-time processing and analytics
()
1. Apache Flink
What is Apache Flink?
()
Streaming with Apache Flink
()
DataStream API
()
Related prerequisite courses
()
Setting up exercise files
()
2. DataStream API
Setting up the Flink environment
()
Reading from a stream source
()
Processing streaming data
()
Writing to a stream sink
()
Using keyed streams
()
ProcessFunction
()
Splitting a stream
()
Merging multiple streams
()
3. Windowing
Windowing concepts
()
Using a Kafka streaming source
()
Using sliding windows
()
Using session windows
()
Window joins
()
4. Event Time Processing
Time attributes in Flink
()
Watermarks
()
Setting up event time
()
Processing with event time
()
Writing to a Kafka sink
()
5. State Management
State management in Flink
()
Defining states
()
Using states
()
Advanced state management
()
6. Use Case Project
Problem definition
()
Computing summary counts
()
Computing activity durations
()
Ex_Files_Apache_Fink_Real_Time_Data.zip
(131 KB)