BigQuery mendukung tabel yang dipartisi dan pengelompokan tabel. Untuk mengetahui informasi selengkapnya tentang partisi dan cluster di BigQuery, lihat Pengantar tabel yang dipartisi serta Membuat dan menggunakan tabel yang dikelompokkan.
Sebelum memulai
Di Konsol Cloud, buka halaman Dataform.
Pilih atau buat repositori.
Pilih atau buat ruang kerja pengembangan.
Peran yang diperlukan
Untuk mendapatkan izin yang diperlukan untuk mengonfigurasi partisi dan cluster tabel,
minta administrator untuk memberi Anda peran IAM
Dataform Editor (roles/dataform.editor
) di ruang kerja.
Untuk mengetahui informasi selengkapnya tentang cara memberikan peran, lihat Mengelola akses.
Anda mungkin juga bisa mendapatkan izin yang diperlukan melalui peran khusus atau peran bawaan lainnya.
Membuat partisi tabel
Untuk membuat partisi tabel, tambahkan partition_expression BigQuery
ke blok bigquery
dalam file SQLX definisi tabel.
Untuk membuat partisi tabel, ikuti langkah-langkah berikut:
- Buka ruang kerja pengembangan Anda.
- Di panel Files, luaskan
definitions/
. - Buka file SQLX definisi tabel.
Di blok
config
, tambahkan blokbigquery
di bawah deklarasi jenis tabel dalam format berikut:config { type: "table", bigquery: { } }
Di blok
bigquery
, masukkan cuplikan kode berikut:partitionBy: "PARTITION_EXPRESSION"
Ganti PARTITION_EXPRESSION dengan ekspresi untuk mempartisi tabel.
Opsional: Klik Format.
Contoh kode berikut menunjukkan partisi tabel berdasarkan jam dalam file SQLX definisi tabel:
config {
type: "table",
bigquery: {
partitionBy: "DATETIME_TRUNC(<timestamp_column>, HOUR)"
}
}
Contoh kode berikut menunjukkan partisi tabel berdasarkan nilai bilangan bulat dalam file SQLX definisi tabel:
config {
type: "table",
bigquery: {
partitionBy: "RANGE_BUCKET(<integer_column>, GENERATE_ARRAY(0, 1000000, 1000))"
}
}
Menyetel filter partisi
Untuk mengetahui informasi selengkapnya mengenai filter partisi di BigQuery, lihat bagian Menetapkan atribut filter partisi yang diperlukan pada tabel yang dipartisi.
Untuk menyetel filter partisi, ikuti langkah-langkah berikut:
- Buka ruang kerja pengembangan Anda.
- Di panel Files, luaskan
definitions/
. - Buka file SQLX definisi tabel yang dipartisi.
Di blok
bigquery
, masukkan cuplikan kode berikut:requirePartitionFilter : true
Opsional: Klik Format.
Contoh kode berikut menunjukkan filter partisi yang ditetapkan dalam blok bigquery
pada file SQLX tabel yang dipartisi:
config {
type: "table",
bigquery: {
partitionBy: "DATE(ts)",
requirePartitionFilter : true
}
}
SELECT CURRENT_TIMESTAMP() AS ts
Menetapkan periode retensi data untuk partisi
Untuk mengontrol retensi semua partisi dalam tabel yang dipartisi, ikuti langkah-langkah berikut:
- Buka ruang kerja pengembangan Anda.
- Di panel Files, luaskan
definitions/
. - Buka file SQLX definisi tabel yang dipartisi.
Di blok
bigquery
, masukkan cuplikan kode berikut:partitionExpirationDays: NUMBER_OF_DAYS
Ganti NUMBER_OF_DAYS dengan jumlah hari yang Anda inginkan untuk mempertahankan partisi.
Opsional: Klik Format.
Contoh kode berikut menunjukkan periode retensi untuk partisi yang ditetapkan ke
14 hari dalam blok bigquery
file SQLX tabel yang dipartisi:
config {
type: "table",
bigquery: {
partitionBy: "DATE(ts)",
partitionExpirationDays: 14,
}
}
SELECT CURRENT_TIMESTAMP() AS ts
Membuat cluster tabel
Untuk membuat cluster tabel, tambahkan clustering_column_list BigQuery ke blok bigquery
dalam file SQLX definisi tabel.
Untuk membuat cluster tabel, ikuti langkah-langkah berikut:
- Buka ruang kerja pengembangan Anda.
- Di panel Files, luaskan
definitions/
. - Buka file SQLX definisi tabel.
Di blok
bigquery
, masukkan cuplikan kode berikut:clusterBy: ["CLUSTER_COLUMN"]
Ganti CLUSTER_COLUMN dengan nama kolom yang akan digunakan untuk mengelompokkan tabel.
Opsional: Klik Format.
Contoh kode berikut menunjukkan tabel yang telah dipartisi yang dikelompokkan berdasarkan kolom name
dan revenue
:
config {
type: "table",
bigquery: {
partitionBy: "DATE(ts)",
clusterBy: ["name", "revenue"]
}
}
SELECT CURRENT_TIMESTAMP() as ts, name, revenue
Langkah selanjutnya
- Untuk mempelajari cara menggunakan kembali kode dengan include, lihat Menggunakan kembali variabel dan fungsi dengan include.
- Untuk mempelajari cara mengonfigurasi tabel inkremental, lihat Mengonfigurasi tabel inkremental.