GCSにprotobufオブジェクトを書き込む

Question

私はgcsにprotobufオブジェクトを書き込むデータフロー（Java API）を作成しています。誰もがこれを行う方法で私を助けてもらえますか？コードなどのサンプルが役に立ちます。

Answer 1

https://issues.apache.org/jira/browse/BEAM-221にはいくつかの考えがあります。コンポジットPTransformで

ラップAvroIO：

• アブロスキーマ[]ちょうど単一バイトです。
• 読み取り時に、バイト[]からユーザのプロトタイプ に変換します。
• 書き込みでは、protoからbyte []に​​変換します。

このように、ProtoIOはAvroIO.Read + ParDo（読み取り）またはParDo + AvroIO.Writeの単純なラッパーになります。