Я пытаюсь создать кластерную таблицу в BigQuery.
Когда я тестирую ее в пользовательском интерфейсе, она отлично работает:
CREATE OR REPLACE TABLE `project_id_xyz.temp.clustering`
PARTITION BY date
CLUSTER BY cluster_col AS
SELECT CURRENT_DATE() as date, 1 as cluster_col
Однако, когда я пытаюсь сделать то же самое через Google-bigquery == 1.9.0 в python (3.7.1), таблица создается и разбивается, но не кластеризуется.Как видно на вкладке «детали» в пользовательском интерфейсе.
Вот фрагмент, который я использую для создания таблицы.
dataset = client.dataset("temp")
table = dataset.table("clustering_test")
job_config = bigquery.QueryJobConfig()
job_config.destination = table
job_config.write_disposition = "WRITE_TRUNCATE"
time_partitioning = TimePartitioning()
time_partitioning.field = "date"
job_config.time_partitioning = time_partitioning
job_config.clustering_fields = ["cluster_col"]
sql = """
SELECT CURRENT_DATE() as date, 1 as cluster_col
"""
query_job = client.query(
sql,
location='US',
job_config=job_config)
query_job.result()
Код кажется очень простым и также не выдает никаких исключений,
Есть ли что-то очевидное, что я делаю не так?