大家好 ~ 这里做一个 window-join[1] 的需求调研, window-join 是 Flink DataStream 上已经有的 feature. 目标是决策是否要在 SQL 上支持该特性, 例如, tumbling window join 语法可能长这样:
```sql select ... window_start, window_end from TABLE( TUMBLE( DATA => TABLE table_a, TIMECOL => DESCRIPTOR(rowtime), SIZE => INTERVAL '1' MINUTE)) tumble_a [LEFT | RIGHT | FULL OUTER] JOIN TABLE( TUMBLE( DATA => TABLE table_b, TIMECOL => DESCRIPTOR(rowtime), SIZE => INTERVAL '1' MINUTE)) tumble_b on tumble_a.col1 = tumble_b.col1 and ... ``` 目前了解到的情况是一些公司 interval join 用的比较多,window join 的 case 还是比较少的, 希望这里可以有更多的反馈。 希望您可以分享 window join 的一些使用案例,以及为什么选用 window-join (而不是 interval join)。 感谢 ~ [1] https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/stream/operators/joining.html Best, Danny Chan
