2017-11-12 13 views
0

Apache BeamでBigQueryIOのスキーマオプションを指定することはできますか?私の知る限り1は、通常、スキーマを指定するcom.google.api.services.bigquery.model.JobConfigurationLoadを使用することができ、新たなフィールドを使用してテーブルに挿入されたときに更新する必要があります。Apache BeamでBigQueryIOのスキーマ更新オプションを指定する

JobConfigurationLoad loadConfig = new JobConfigurationLoad(); 
.. 
loadConfig.setSchemaUpdateOptions(Arrays.asList("ALLOW_FIELD_ADDITION", "ALLOW_FIELD_RELAXATION")); 

をしかし、どのように、私は、ApacheビームでBigQueryIOクラスを使用してこれを指定することができますか?私はApache Beam SDK 2.1.0を使用しています。

答えて

1

現在、Beamはこれをサポートしていません。すでにa feature requestが提出されています。実装するのはかなり簡単なはずです(寄付は歓迎します:))しかし、私は誰もそれについて積極的に取り組んでいるとは思わない。

関連する問題