2016-07-28 11 views
1

データフローを使用してBQパーティションテーブルにストリーミングしようとしています。 ドキュメントには、次の情報が記載されています。BQパーティションテーブルへのストリーミング

_PARTITIONTIME列には、ストリーミングバッファのデータにNULL値があります。

日付パーティションテーブルに行を挿入する場合があります。

BigQueryが正しいパーティションを推測できるように、挿入する行のパーティション時間を設定できる方法はありますか?

これまでのところ、私はやってみた:tableRow.set("_PARTITIONTIME", milliessinceepoch); しかし、私はno such fieldの例外でヒットします。

答えて

1

1か月ほど前に、日付パーティションテーブルの特定のパーティションにストリームすることができます。たとえば、テーブルTの日付20160501のパーティションに挿入するには、テーブル名がT$20160501

のinsertallを呼び出すことができます
0

AFAIKでは、書き込みの時点で、BigQueryでは行単位で手動でパーティションを指定することはできません。挿入時から推測されます。

BigQueryの組み込みパーティションテーブル機能の代わりに、データフローの機能を使用して複数のBigQueryテーブルに同時にストリーミングすることができます。Sharding BigQuery output tablesを参照してください。

関連する問題