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)
谢谢
