Dataflow Java SDKでのBigQueryパッチ操作

Question

question：データフローでスキーマを動的に更新するカスタムシンクを作成しましたか？Patch操作がBigQueryIO APIのどこかに公開されているのでしょうか？

これは、オンザフライでスキーマを更新するための重要な部分です。後方互換性のある方法でスキーマをマージしています。

Answer 1

これはSDK自体にはありませんが、DoFnからの副作用の標準パターンを使用できます。具体的には、作成するBigQueryクライアントは、DoFnsはシリアル化可能でなければならないため、一時的なマークを付ける必要があります。

class PatchFn extends DoFn<> { 
    private transient BigQuery bq; 
    ... 
}