Gunakan SQL untuk membaca dan menulis data di tabel lebar LindormTable dari Lindorm Distributed Processing System (LDPS).
Prasyarat
Sebelum memulai, pastikan Anda telah:
Membaca Pencegahan untuk menggunakan SQL dalam mengakses LindormTable.
Menginisialisasi sumber daya yang diperlukan untuk jenis pekerjaan Anda:
Pekerjaan Java: Buat pekerjaan dalam Java
Pekerjaan Python: Buat pekerjaan dalam Python
Akses data di tabel lebar
Tabel lebar LindormTable dapat diakses melalui katalog lindorm_table di LDPS. LDPS mendukung operasi bahasa manipulasi data (DML) pada tabel lebar, tetapi tidak mendukung operasi bahasa definisi data (DDL) maupun partisi.
Alur kerja umumnya adalah: beralih ke katalog lindorm_table, memverifikasi skema tabel, lalu menjalankan pernyataan DML Anda.
Beralih ke katalog
USE lindorm_table;Kueri skema tabel
SHOW CREATE TABLE test;Output-nya seperti berikut:
+----------------------------------------------------+
| CREATE TABLE default.test ( |
| `id` INT, |
| `name` STRING) |
| |
+----------------------------------------------------+Masukkan data
INSERT INTO test VALUES (0, 'Jay');Kueri Data
SELECT * FROM test;Untuk daftar lengkap sintaksis SQL yang didukung, lihat pernyataan DML.
Impor data secara massal (pratinjau publik)
Sintaksis SQL-nya sama dengan pernyataan INSERT standar. Saat bulkload diaktifkan, LDPS secara langsung menghasilkan dan mendaftarkan file tabel lebar dari data yang diimpor, sehingga meningkatkan throughput penulisan.
Konfigurasikan parameter berikut sebelum menjalankan impor:
| Parameter | Deskripsi | Default |
|---|---|---|
spark.sql.catalog.lindorm_table.bulkLoad.enabled | Mengaktifkan fitur bulkload. Atur ke true untuk mengaktifkan. | false |
spark.sql.catalog.lindorm_table.bulkLoad.parallelFactor | Jumlah sesi konkuren yang digunakan untuk menulis data ke satu wilayah tabel lebar. | 4 |
Indeks sekunder dan indeks pencarian tidak dibuat secara otomatis untuk data yang diimpor oleh pekerjaan bulkload.
Langkah berikutnya
Jelajahi referensi sintaksis DML lengkap: pernyataan DML