Flink之Table API&SQL详解

1、Table API&SQL的算子操做  1.一、初始化查询 下面的示例显示如何在已注册和内联的表上指定SQL查询。html val env = StreamExecutionEnvironment.getExecutionEnvironment val tableEnv = StreamTableEnvironment.create(env) // read a DataStream fr
相关文章
相关标签/搜索