第 10 章 DataStream API、原生客户端与 Gateway
章节定位:第三篇的收官章,也是"SQL 之外的第二条入口"。第 7–9 章把 Flink SQL / Table API 这条路走透了;本章回答四个 SQL 回答不了的问题——Java 程序怎么直连 Fluss(原生客户端)、一个作业怎么同时读写多张表(Multi-Table API)、Python/Agent 怎么在无 JVM 环境查实时特征、以及一个不写 Java 的业务系统怎么用 HTTP 把数据塞进 Fluss(Gateway)。最后正面拆一个绕不开的语义问题:Flink Checkpoint 与 Fluss 写入的 Exactly-Once 边界到底在哪。
版本基线:Fluss 1.0.0 + Flink 2.3(connector
fluss-flink-2.3-1.0.0)+ Paimon 2.0/1.4 + Doris 4.1 + Flink CDC 3.6.x + Kafka 3.x + MySQL 8.0/8.4 + DolphinScheduler 3.x + ZooKeeper 3.6+(Fluss 协调依赖)+ JDK 17前置知识:第 2 章(五条访问路径、bucket 路由、tablet leader)、