小编Tho*_*mas的帖子

我想在一个公共键上加入多个流，并在所有流贡献了至少一个元素后或在窗口末尾立即触发结果。CoGroupByKey 似乎是合适的构建块，但似乎没有办法表达早期触发条件（计数触发器适用于每个输入集合）？