9 .l Apache Beam
l Apache Samza ü
l Apache Apex ü
l Apache Flink ü
l Apache Strom ü SQL
l Apache Strom trident
l Apache Spark
10 . Native Micro-batching Micro-batching Native
At-least-once Exactly-once Exactly-once Exactly-once
ACKS RDD based Checkpointing Checkpointing
1 Lineage Chandy-Lamport
2 Checkpoint
Metadata
operator DStream operator
l mapWithState
l updateStateBykey l Keyed State
l Operator State
Process time
SQL Spark sql table api SQL
java Java/Scala Java/Scala
11 .Why Choose Flink?
Lambda Kappa
12 .Why Choose Flink?
Event Time
3
Ingestion Time
Kafka
Flink
Processing Time
eg: <<Flink >>
l === Event Time
l == Ingestion Time
l == Processing Time
热门城市
