Flink Core 笔记

Runtime, Streaming

StreamGraph

JobGraph

Chain StreamNode(OP)

ExecutionGraph

Physical Plan

? Elastic Scaling

Architect

Conceptions

Time

Watermark

Window

Union & Connect

State

Checkpoint & Savepoint

Backpressure

CEP Lib

Gelly Lib

Chandy-Lamport Global Snapshot vs. Async. Barrier Snapshort