2

つまり、各 pcollection のすべての新しい要素で起動するトリガーを持つ GlobalWindow があり、discardingFiredPanes に設定されている場合、CoGroupByKey は、rhs が発火したときに lhs null で発火しますか、それとも lhs の最後の値で発火しますか?

これらの 2 つのデータセットを考えると

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 に答える