~/talk

Stream Processing with Apache Flink

TalkinFrenchat DevFest Toulouse 2017 · on Thursday, 2017-09-28· [kubernetes, databases]
slides:none on file

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

  1. 0:00Start
  2. 0:47Apache Flink
  3. 0:58Big data
  4. 7:03Batch processing
  5. 7:22Apache Kafka
  6. 8:22Database
  7. 10:50Hadoop
  8. 14:08Apache Spark
  9. 18:53Machine learning
  10. 21:34Complex Event Processing
~/search
type to search 6,249 conferences, 138,987 speakers and 185,172 talks
~/help
cmdctrl k
search every conference, speaker and series
/
focus the filter search
h
home
c
conferences
s
speakers
e
series
t
light / dark — the status bar button does the same
?
this help
esc
close this, then clear every filter — or just the search, while you are typing in it

Ignored while you are typing. Pages without a filter rail have no search to focus.