2015-10-06 41 views

回答

4

一個可能的辦法是實現一個自定義接收器(批次):https://cloud.google.com/dataflow/model/custom-io#creating-sinks

+0

或者,您可以通過自定義pTransform執行寫入卡桑德拉。在這種情況下,您將不得不處理容錯問題。 – pjesa

+0

在GitHub上「卡桑德拉 - 數據流」項目似乎是在做這兩者的混合:它實現了一個自定義的轉換,但轉換是做什麼大概一個自定義接收會做。 – jkff