2

即,如果我有一个带有触发器的 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]|

4

1 回答 1

2

CoGroupByKey 两侧的元素每个都被触发器系统独立处理,所以你会得到:

|id| x1 | x2 |
|1 |[10]|null|
|1 |null|[20]|
|1 |[11]|null|
|1 |null|[21]|
|1 |[12]|null|
|1 |null|[22]|
于 2016-08-03T19:59:31.733 回答