diff --git a/ext/store/bigquery/table.go b/ext/store/bigquery/table.go index afe1c567b4..8def08eccf 100644 --- a/ext/store/bigquery/table.go +++ b/ext/store/bigquery/table.go @@ -71,6 +71,10 @@ func (t TableHandle) Update(ctx context.Context, res *resource.Resource) error { } } + if table.Cluster != nil { + metadataToUpdate.Clustering = toBQClustering(table.Cluster) + } + _, err = t.bqTable.Update(ctx, metadataToUpdate, "") if err != nil { var metaErr *googleapi.Error diff --git a/ext/store/bigquery/table_test.go b/ext/store/bigquery/table_test.go index 9314845199..ce1c9be91c 100644 --- a/ext/store/bigquery/table_test.go +++ b/ext/store/bigquery/table_test.go @@ -245,6 +245,9 @@ func TestTableHandle(t *testing.T) { "type": "INTEGER", }, }, + "cluster": map[string]any{ + "using": []string{"session"}, + }, "partition": map[string]any{ "field": "product_day", "type": "DAY",