데이터 흐름 GroupBy -> 키 기반 다중 출력

Question

그룹 키를 기반으로 GroupBy의 출력을 여러 출력 파일로 리디렉션 할 수있는 간단한 방법이 있습니까?

Bin.apply(GroupByKey.<String, KV<Long,Iterable<TableRow>>>create()) 
.apply(ParDo.named("Print Bins").of(...) 
.apply(TextIO.Write.to(*Output file based on key*)) 

싱크대가 해결책이라면 샘플 코드를 알려주시겠습니까?

감사합니다.

Answer 1

빔 2.2에는이를 수행하는 API 인 TextIO.write().to(DynamicDestinations)이 포함됩니다 (source 참조). 현재로서는이 API를 사용하려는 경우 2.2.0-SNAPSHOT 버전을 사용할 수 있습니다. 이 API는 실험적이며 Beam 2.3 이상에서 변경 될 수 있습니다.