Как CoGroupByKey работает с отбрасыванием FiredPanes?

Т.е., если у меня есть GlobalWindow с триггером, который срабатывает для каждого нового элемента в каждой коллекции, для которого установлено значение discardingFiredPanes, будет ли CoGroupByKey срабатывать с левым нулем, когда правый вызывает пожар, или с последним значением из левого?

Учитывая эти два набора данных

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]|

or:

|id| x1 | x2 | |1 |[10]|null| |1 |[10]|[20]| |1 |[11]|[20]| |1 |[11]|[21]| |1 |[12]|[21]| |1 |[12]|[22]|


person bfabry    schedule 03.08.2016    source источник


Ответы (1)


Элементы с двух сторон CoGroupByKey обрабатываются системой триггеров независимо друг от друга, поэтому вы получите:

|id| x1 | x2 |
|1 |[10]|null|
|1 |null|[20]|
|1 |[11]|null|
|1 |null|[21]|
|1 |[12]|null|
|1 |null|[22]|
person danielm    schedule 03.08.2016