即,如果我有一个带有触发器的 GlobalWindow,该触发器在每个 pcollection 上的每个新元素上触发,设置为 discardingFiredPanes,当 rhs 引起火灾时,CoGroupByKey 是否会以 lhs null 触发,或者使用 lhs 的最后一个值触发?
鉴于这两个数据集
p1:
|id|x1|
|1 |10|
|1 |11|
|1 |12|
p2:
|id|x2|
|1 |20|
|1 |21|
|1 |22|
我应该期待:
|id| x1 | x2 |
|1 |[10]|null|
|1 |null|[20]|
|1 |[11]|null|
|1 |null|[21]|
|1 |[12]|null|
|1 |null|[22]|
或者:
|id| x1 | x2 |
|1 |[10]|null|
|1 |[10]|[20]|
|1 |[11]|[20]|
|1 |[11]|[21]|
|1 |[12]|[21]|
|1 |[12]|[22]|