【发布时间】:2020-11-19 13:51:45
【问题描述】:
我有一个要求,我在 BigQuery(每小时分区)中有一个分区表,我必须编写一个批处理作业,一次处理一个分区。
在 hive 中,它很容易做到这一点,就像我可以在主表和一个元数据表中显示分区,我可以在其中维护已处理的分区,然后在两个数据集之间创建差异,使用 except 来识别剩余的分区过程。
我正在 BigQuery 中查看此内容,我可以在其中执行类似的操作以在主表上显示分区并维护一个元数据表,我可以在其中维护已处理的分区。
我发现我可以在主表上做到这一点
SELECT DISTINCT FORMAT_DATETIME('%Y-%m-%d %H:%M:%S', EXTRACT(DATETIME FROM _PARTITIONTIME)) FROM DATASET.TABLE_NAME
但是这会扫描整个表和开销上的开销。
【问题讨论】:
标签: google-cloud-platform google-bigquery