Apache Flink的过去、现在和未来Operator 抽象 Pull-based operator Push-based operator 算子可自定义读取顺序 Table API & SQL 1.9 新特性 全新的 SQL 类型系统 DDL 初步支持 Table API 增强 统一的 Catalog API Blink Planner What’s new in Blink Planner 数据结构 二进制化 更丰富的0 码力 | 33 页 | 3.36 MB | 1 年前3- PyFlink 1.15 DocumentationRecordBatch.from_arrays(arrays, schema) [5]: root |-- id: BIGINT |-- data: STRING Create a Table from DDL statements [6]: table_env.execute_sql(""" CREATE TABLE random_source ( id TINYINT, data STRING0 码力 | 36 页 | 266.77 KB | 1 年前3
- PyFlink 1.16 DocumentationRecordBatch.from_arrays(arrays, schema) [5]: root |-- id: BIGINT |-- data: STRING Create a Table from DDL statements [6]: table_env.execute_sql(""" CREATE TABLE random_source ( id TINYINT, data STRING0 码力 | 36 页 | 266.80 KB | 1 年前3
共 3 条
- 1