Flink JOIN 执行计划

Flink JOIN 执行计划 代码：java val table1 = env.fromElements((1, "hello")).toTable(tEnv, 'a, 'b) val table2 = env.fromElements((1, "hello")).toTable(tEnv, 'c, 'd) val table = table1.join(table2).wher

>>阅读原文<<