Apache Flink的过去、现在和未来Processing Continuous Processing & Streaming Analytics Event-driven Applications ✔ 现在 Flink 1.9 的架构变化 Runtime Distributed Streaming Dataflow Query Processor DAG & StreamOperator Local Single DataStream Physical 统一 Operator 抽象 Pull-based operator Push-based operator 算子可自定义读取顺序 Table API & SQL 1.9 新特性 全新的 SQL 类型系统 DDL 初步支持 Table API 增强 统一的 Catalog API Blink Planner What’s new in Blink0 码力 | 33 页 | 3.36 MB | 1 年前3
PyFlink 1.15 Documentationfollowing: total 144 -rw-r--r-- 1 duanchen staff 1.3K Oct 19 16:01 README.txt -rw-r--r-- 1 duanchen staff 1.9K Oct 19 16:01 __init__.py drwxr-xr-x 11 duanchen staff 352B Oct 19 16:03 __pycache__ drwxr-xr-x 250 码力 | 36 页 | 266.77 KB | 1 年前3
PyFlink 1.16 Documentationfollowing: total 144 -rw-r--r-- 1 duanchen staff 1.3K Oct 19 16:01 README.txt -rw-r--r-- 1 duanchen staff 1.9K Oct 19 16:01 __init__.py drwxr-xr-x 11 duanchen staff 352B Oct 19 16:03 __pycache__ drwxr-xr-x 250 码力 | 36 页 | 266.80 KB | 1 年前3
共 3 条
- 1













