ApacheFlink有两种关系型API来做流批统一处理：TableAPI和SQLTableAPI是用于Scala和Java语言的查询API，它可以用一种非常直观的方式来组合使用选取、过滤、join等关系型算子。 FlinkSQL是基于 ApacheCalcite 来实现的标准SQL。无论输入是连续的（流式）还是有界的（批处理），在两个接口中指定的查询都具有相同的语义，并指定相同的结果。基本程序结构importorg.apache.flink.table.api.*;importorg.apache.flink.connector.datagen.table.DataGenOptions;//

一、报错内容“Couldnotinstantiatetheexecutor.Makesureaplannermoduleisontheclasspath”Exceptioninthread"main"org.apache.flink.table.api.TableException:Couldnotinstantiatetheexecutor.Makesureaplannermoduleisontheclasspath atorg.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.lookupExecu

一、FlinkSql的概念核心概念Flink的TableAPI和SQL是流批统一的API。这意味着TableAPI&SQL在无论有限的批式输入还是无限的流式输入下，都具有相同的语义。因为传统的关系代数以及SQL最开始都是为了批式处理而设计的，关系型查询在流式场景下不如在批式场景下容易理解.动态表和连续查询动态表(DynamicTables)是Flink的支持流数据的TableAPI和SQL的核心概念。与表示批处理数据的静态表不同，动态表是随时间变化的。可以像查询静态批处理表一样查询它们。查询动态表将生成一个连续查询(ContinuousQuery)。一个连续查询永远不会终止，结果会生成一个动态

一、FlinkSql的概念核心概念Flink的TableAPI和SQL是流批统一的API。这意味着TableAPI&SQL在无论有限的批式输入还是无限的流式输入下，都具有相同的语义。因为传统的关系代数以及SQL最开始都是为了批式处理而设计的，关系型查询在流式场景下不如在批式场景下容易理解.动态表和连续查询动态表(DynamicTables)是Flink的支持流数据的TableAPI和SQL的核心概念。与表示批处理数据的静态表不同，动态表是随时间变化的。可以像查询静态批处理表一样查询它们。查询动态表将生成一个连续查询(ContinuousQuery)。一个连续查询永远不会终止，结果会生成一个动态