文字列のPCollectionをTableRowsに変換するには？

私は、PubSubメッセージを受け取りBigQueryに書き込む非常に単純なBeamパイプラインを作成しようとしています。メッセージは文字列として入力され、BigQueryに書き込むにはTableRowに変換する必要があります。私は、私の人生のために、簡単な方法を見つけることができません。この時点で私のテーブルは単なる列に過ぎません。どんな勧告？文字列のPCollectionをTableRowsに変換するには？

出典

2017-10-08 Yuri Grinshteyn

あなたがのTableRowに単一の文字列を変換する関数を書くと、またはPCollection を得ることがPCollection にこの機能を適用するの難しさを持っていますか？ – jkff

前者。私は変換を適用する関数を使用する方法を考え出した....私は関数自体を把握することはできません。 –

BigQueryIO.write（）のjavadocの例を見てきましたかhttps://github.com/apache/beam/blob/master/sdks/java/io/google-cloud-platform/src/main/java/ org/apache/beam/sdk/io/gcp/bigquery/BigQueryIO.java＃L946？それは基本的にちょうど「新しいTableRow（）.set（ "columnName"、value）.set（ "otherColumn"、value） "など。 – jkff

javadoc of BigQueryIO.write()の例を見てください。

構文は次のとおりです。new TableRow().set("columnName", value).set("otherColumn", value)など

出典

2017-10-09 19:24:06 jkff

文字列のPCollectionをTableRowsに変換するには？

答えて

関連する問題