使用Table&SQL API怎么构造多个sink

Hi, 个人在分析RelNodeBlock逻辑，多个SINK才会拆分并重用公共子树，怎么构造多个sink呢， 文件RelNodeBlock.scala源码里的writeToSink()已经找不到了

// 源码里的多sink例子 val sourceTable = tEnv.scan("test_table").select('a, 'b, 'c) val leftTable = sourceTable.filter('a > 0).select('a as 'a1, 'b as 'b1) val rightTable = sourceTable.filter('c.isNotNull).select('b as 'b2, 'c as 'c2) val joinTable = leftTable.join(rightTable, 'a1 === 'b2) joinTable.where('a1 >= 70).select('a1, 'b1).writeToSink(sink1) joinTable.where('a1 < 70 ).select('a1, 'c2).writeToSink(sink2)

谢谢*来自志愿者整理的flink邮件归档