둘 또는 여러 PCollection 참여하면 *없이 * 흐름 키

Question

가정하자 PCollection의 P1을 갖는다 {1,2,3} PCollection의 P2는 {A, B, C}

I 쌍을 갖는다 PCollection를 생성하고자했다 p1과 p2는 {A, 1}, {B, 2}, {C, 3}

과 같은 도움이됩니다.

감사합니다, K

Answer 1

은 내가 조인을 수행하기 위해 CoGroupByKey를 사용 후 1, 2, ... 각 PCollection의 요소에 일련 번호를 할당 할 stateful ParDo를 사용하는 것이 좋습니다, 그리고 거라고 생각합니다. 즉, 각 PCollection은 1 명의 작업자를 사용하여 순차적으로 처리되지만 현재이 특정 작업을보다 효율적으로 구현하는 방법을 생각할 수 없습니다.