1、基础知识 FlinkSQL分为Table API和SQL API，是架构于Flink Core之上用SQL予以方便快捷地进行结构化数据处理的上层库。 工作流程 SQL和Table在进入Flink以后转化成统一的数据结构表达形式，也就是逻辑计划(logic plan)，其中catalog提供元数据信息，用于后续的优化，逻辑计划是优化的入门，经过一系列规则后，Flink把初始的逻辑计划优化为物理计划(phy plan)，物理计划通过代码构造器翻译为Transformation，最后转换为工作图(job graph)。 整个过程没有单独的流处理和批处理，因为流处理和批处理优化过程和扩建都是共享的。 编程模型 创建Flink SQL运行环境。 将数据源定义成表。 执行SQL语义查询。 将查询结果输出到目标表中。 <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <maven.compiler.source>11</maven.compiler.source>...
