实时计算(流计算) Flink SQL开发指南 / ⽬录
7.3 AutoConf⾃动配置调优..............................................................................63
7.4 AutoScale⾃动配置调优............................................................................. 72
7.5 ⼿动配置调优............................................................................................ 78
7.6 典型的反压场景及优化思路...........................................................................86
8 Flink SQL..........................................................................92
8.1 Flink SQL概述.........................................................................................92
8.2 关键字..................................................................................................... 93
8.3 基本概念.................................................................................................. 95
8.3.1 时区.............................................................................................95
8.3.2 时间属性.......................................................................................97
8.3.3 Watermark................................................................................100
8.3.4 计算列........................................................................................ 101
8.4 数据类型................................................................................................ 102
8.4.1 类型转换..................................................................................... 102
8.4.2 数学和逻辑运算............................................................................ 104
8.5 创建数据视图.......................................................................................... 105
8.6 DDL语句................................................................................................107
8.6.1 DDL概述.....................................................................................107
8.6.2 创建数据源表............................................................................... 110
8.6.2.1 数据源表概述.............................................................................110
8.6.2.2 创建数据总线DataHub源表......................................................... 112
8.6.2.3 创建⽇志服务LOG源表................................................................ 117
8.6.2.4 创建消息队列MQ源表................................................................. 120
8.6.2.5 创建消息队列Kafka源表..............................................................125
8.6.2.6 创建表格存储TableStore源表...................................................... 139
8.6.2.7 创建全量MaxCompute源表........................................................ 141
8.6.2.8 创建增量MaxCompute源表........................................................ 147
8.6.3 创建数据结果表............................................................................ 152
8.6.3.1 数据结果表概述..........................................................................152
8.6.3.2 创建分析型数据库MySQL版2.0结果表............................................153
8.6.3.3 创建数据总线DataHub结果表...................................................... 155
8.6.3.4 创建⽇志服务LOG结果表............................................................. 158
8.6.3.5 创建消息队列MQ结果表.............................................................. 160
8.6.3.6 创建表格存储 TableStore结果表.................................................. 163
8.6.3.7 创建云数据库RDS版结果表.......................................................... 165
8.6.3.8 创建MaxCompute结果表........................................................... 169
8.6.3.9 创建云数据库HBase版结果表....................................................... 173
8.6.3.10 创建Elasticsearch结果表......................................................... 178
8.6.3.11 创建时序时空数据库结果表......................................................... 181
8.6.3.12 创建消息队列Kafka结果表......................................................... 184
8.6.3.13 创建云数据库HybridDB for MySQL结果表.................................. 187
8.6.3.14 创建云数据库RDS SQL Server版结果表.......................................189
8.6.3.15 创建云数据库Redis版结果表.......................................................193
8.6.3.16 创建云数据库MongoDB版结果表................................................ 196
8.6.3.17 创建分析型数据库MySQL版 3.0结果表......................................... 197
⽂档版本:20200327 III