Topik ini menjelaskan cara menggunakan SQL untuk mengakses data di LindormTable dari Sistem Pemrosesan Terdistribusi Lindorm (LDPS).
Persiapan
Sebelum menggunakan SQL untuk mengakses data di LindormTable, kami sarankan Anda memahami tindakan pencegahan yang dijelaskan di Tindakan Pencegahan.
Sumber daya yang diperlukan diinisialisasi berdasarkan jenis pekerjaan Anda. Untuk informasi lebih lanjut, lihat dokumentasi berikut:
Mengakses data di tabel lebar
Anda dapat mengakses data di tabel lebar Lindorm di katalog "lindorm_table". Anda dapat melakukan operasi bahasa manipulasi data (DML) pada tabel lebar Lindorm saat menggunakan LDPS untuk mengakses tabel-tabel tersebut. Operasi bahasa definisi data (DDL) dan partisi tidak didukung. Contoh berikut menunjukkan cara mengakses data di tabel lebar:
Gunakan katalog
"lindorm_table".USE lindorm_table;Kueri skema tabel bernama test.
SHOW CREATE TABLE test;Hasil berikut dikembalikan:
+----------------------------------------------------+ | CREATE TABLE default.test ( | | `id` INT, | | `name` STRING) | | | +----------------------------------------------------+Masukkan data ke tabel lebar Lindorm.
INSERT INTO test VALUES (0, 'Jay');Kueri data di tabel lebar Lindorm.
SELECT * FROM test;
Untuk informasi lebih lanjut tentang sintaks SQL yang didukung, lihat Pernyataan DML.
Gunakan fitur bulkload untuk mengimpor data ke tabel lebar Lindorm (dalam pratinjau publik)
Sintaks SQL yang digunakan untuk mengimpor data secara batch sama dengan sintaks INSERT yang digunakan untuk menyisipkan data normal. Untuk menulis data ke LindormTable secara batch menggunakan SQL, konfigurasikan parameter yang dijelaskan dalam tabel berikut.
Parameter | Deskripsi |
spark.sql.catalog.lindorm_table.bulkLoad.enabled | Menentukan apakah akan mengaktifkan fitur bulkload. Nilai valid:
|
spark.sql.catalog.lindorm_table.bulkLoad.parallelFactor | Jumlah sesi bersamaan yang digunakan untuk menulis data ke satu wilayah tabel lebar. Nilai default: |
Setelah mengaktifkan fitur bulkload, file tabel lebar secara otomatis dibuat berdasarkan data yang diimpor dan didaftarkan. Dengan cara ini, throughput tulis meningkat.
Indeks sekunder dan pencarian tidak dibuat secara otomatis untuk data yang diimpor oleh pekerjaan bulkload.