Dataflow GroupBy - >キーに基づく複数の出力

Question

GroupByの出力をGroupキーに基づいて複数の出力ファイルにリダイレクトする簡単な方法はありますか？

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以降で変更される可能性があることに注意してください。