Stream Processing with Apache Flink
summary
Apache Flink’s streaming‑first Java/Scala API for distributed deployment (standalone, YARN, Mesos, cloud) and integrations with Kafka, HDFS and HBase is presented, with state persisted to distributed filesystems or RocksDB. A live socket word‑count demo illustrates sliding windows and stateful aggregation; production use cases include Bouygues Telecom processing 10 billion messages/day and CEP rules (e.g. order→shipment within one hour) with event‑time windows and exactly‑once state management to trigger alerts.
AI-written summary · about
chapters (10)
- 0:00Start
- 0:47Apache Flink
- 0:58Big data
- 7:03Batch processing
- 7:22Apache Kafka
- 8:22Database
- 10:50Hadoop
- 14:08Apache Spark
- 18:53Machine learning
- 21:34Complex Event Processing
related talks
51mStream Processing Smackdown: Kafka Streams vs. Apache Flink
37mStateful Stream Processing with Apache Flink 1.5 and beyond
21mStream Processing and SQL
43mUnified stream and batch processing with Apache Flink’s relational APIs
41mStream Processor as a Database: Building Online Applications
23mBetter, Faster, Stronger Streaming: Your First Dive into Flink SQL
29mApache Kafka and the Next 700 Stream Processing Systems
40mThe Seven Deadly Sins of Streaming
