Cara mengonfigurasi konektor tabel lebar saat menggunakan Flink SQL untuk menyerahkan tugas komputasi -

Saat menggunakan mesin streaming Lindorm untuk memproses tugas komputasi, Anda dapat menggunakan tabel lebar sebagai tabel dimensi atau tabel hasil. Topik ini menjelaskan cara mengonfigurasi konektor tabel lebar saat menggunakan Flink SQL untuk menyerahkan tugas komputasi.

Informasi latar belakang

Saat menggunakan Flink SQL untuk menyerahkan tugas komputasi di mesin streaming Lindorm, Anda harus mengeksekusi pernyataan CREATE TABLE dan mengonfigurasi parameter terkait konektor.

Menggunakan tabel lebar di mesin streaming Lindorm

CREATE TABLE lindorm_table(
  c1 VARCHAR,
  c2 DOUBLE,
  c3 BIGINT,
  PRIMARY KEY (c1, c2) NOT ENFORCED -- Primary key yang ditentukan dalam pernyataan ini harus sama dengan primary key dari tabel hasil yang dibuat di LindormTable.
)WITH(
      'connector'='lindorm',
      'seedServer'='ld-bp17pwu1541ia****-proxy-lindorm.lindorm.rds.aliyuncs.com:30020',
      'userName'='yourUser',
      'password'='yourPassword',
      'tableName'='yourTablename',
      'namespace'='yourNamespace'
    ); -- Konfigurasikan parameter terkait konektor dalam klausa WITH.

Catatan

Untuk informasi lebih lanjut tentang pernyataan CREATE TABLE, lihat CREATE TABLE.

Parameter terkait konektor

Parameter Umum

Parameter	Nilai default	Diperlukan	Deskripsi
seedServer	Tidak ada	Ya	Titik akhir yang digunakan untuk terhubung ke LindormTable menggunakan API Java HBase. Untuk informasi lebih lanjut, lihat Lihat titik akhir LindormTable.
namespace	Tidak ada	Ya	Namespace tempat tabel lebar berada.
userName	Tidak ada	Ya	Nama pengguna yang digunakan untuk terhubung ke LindormTable.
password	Tidak ada	Ya	Kata sandi yang digunakan untuk terhubung ke LindormTable.
tableName	Tidak ada	Ya	Nama tabel lebar.
bufferSize	5.000	Tidak	Jumlah batch di mana data ditulis.
flushIntervalMs	2.000	Tidak	Interval di mana operasi `flush` dilakukan saat data ditulis ke tabel lebar. Unit: milidetik. Jika jumlah data yang ditulis ke tabel lebar kecil, operasi `flush` dilakukan berdasarkan interval yang ditentukan. Catatan Jumlah data berdasarkan mana operasi flush dilakukan pada interval tertentu bervariasi sesuai dengan skenario bisnis.
columnFamily	f	Tidak	Nama keluarga kolom. Catatan Saat Anda menggunakan tabel lebar di mesin streaming Lindorm, apakah parameter columnFamily diperlukan tergantung pada bagaimana tabel lebar dibuat. Jika tabel lebar dibuat menggunakan API ApsaraDB for HBase untuk Java, parameter ini diperlukan. Jika tabel lebar dibuat menggunakan Lindorm SQL, parameter ini opsional.

Parameter Spatio-Temporal

Parameter	Nilai default	Diperlukan	Deskripsi
cacheTTLMs	-1	Tidak	Waktu hidup (TTL) cache data. Nilai default parameter ini adalah -1, yang menunjukkan bahwa tidak ada cache data yang dihasilkan. Unit: milidetik. Setelah cache data kedaluwarsa, indeks spasio-temporal dibangun kembali saat kueri berikutnya dilakukan.
geomHint	Tidak ada	Tidak	Kueri Lookup Join yang ditentukan. Nilai parameter ini dalam format `<columnName>:<queryFunction>`. Contoh: `fence:st_contains`. Saat kueri Lookup Join dieksekusi, persamaan spasio-temporal dalam kondisi Join diganti dengan kueri spasio-temporal yang ditentukan. Sebagai contoh, persamaan `fence=ST_MakePoint(x,y))` diganti dengan kueri `ST_Contains(fence, ST_MakePoint(x,y))` yang ditentukan. queryFunction mendukung fungsi-fungsi berikut: ST_Contains ST_Within ST_DWithin ST_DWithinSphere ST_Intersects ST_Overlaps ST_Equals
geomIndex	Tidak ada	Tidak	Kolom berdasarkan indeks spasio-temporal dibuat. Kueri Lookup Join untuk tabel dipercepat menggunakan indeks dalam memori. Indeks hanya dapat dibuat untuk satu kolom dalam tabel. Fungsi-fungsi berikut dapat dipercepat menggunakan indeks dalam memori: ST_Contains ST_Within ST_DWithin ST_DWithinSphere ST_Intersects ST_Overlaps ST_Equals Penting Parameter geomIndex harus ditentukan bersama dengan parameter geomHint dan cacheTTLMs. Nilai parameter cacheTTLMs harus lebih besar dari 0.