Dataflow 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或更高版本中進行更改。