你站在桥上看风景，看风景人在楼上看你。明月装饰了你的窗子，你装饰了别人的梦。
Calcite 简介
简介 Apache Calcite是一个动态数据管理框架。 它包含构成典型数据库管理系统的许多部分，但省略了一些关键功能:数据存储、处理数据的算法和存储元数
FlinkSQL - SQL解析过程
sqlQuery sql 进入sqlQuery后，首先就是获取Parser 解析sql语句 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 // TableEnvironmentImpl.java @Override public Table sqlQuery(String query) { List<Operation> operations = getParser().parse(query); if (operations.size() != 1)
FlinkSQL - 开始
flink 参数 参数 说明 flink 版本 1.17 java 版本 1.8 测试SQL 1 2 3 select * from tableA where amount > 2 运行环境 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 final StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment(); final StreamTableEnvironment tableEnv = StreamTableEnvironment.create(env); final DataStream<Order> orderA = env.fromCollection(
LSM树
LSM 树(Log-Structured-Merge-Tree) 不算是树，其实是一种存储结构 利用顺序追加写来提高写性能 内存-文件读取方式会降低读性
FlinkSQL - AggHandlerCodeGenerator
介绍 AggHandlerCodeGenerator 的代码在 flink planner 下，用来生成聚合函数的代码,是scala 代码 类定义 1 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35