Flink之Table API&SQL詳解

1、Table API&SQL的算子操做  1.一、初始化查詢 下面的示例顯示如何在已註冊和內聯的表上指定SQL查詢。html val env = StreamExecutionEnvironment.getExecutionEnvironment val tableEnv = StreamTableEnvironment.create(env) // read a DataStream fr

>>阅读原文<<