Lindorm:Gunakan Flink untuk mengakses LindormTable

Open source HBase connector

Untuk informasi tentang cara menggunakan open source HBase connector guna membuat tabel dimensi dan tabel hasil, lihat Dokumentasi HBase connector.

Open source JDBC connector

Saat Anda menggunakan open source JDBC connector untuk mengakses LindormTable, saat ini hanya didukung penggunaan LindormTable sebagai tabel hasil. Untuk penggunaan secara umum, rujuk dokumentasi resmi JDBC connector. Namun, ada beberapa poin yang perlu diperhatikan secara khusus, sebagai berikut:

• Kebutuhan dependensi
  Dibandingkan dengan rentang versi paket dependensi yang relatif luas dalam dokumentasi resmi, versi paket dependensi yang digunakan oleh JDBC connector untuk mengakses LindormTable saat ini dibatasi pada daftar berikut:
  

  • flink-connector-jdbc-core-4.0.0-2.0.jar

  • flink-connector-jdbc-mysql-4.0.0-2.0.jar

  • mysql-connector-j-8.3.0.jar

  Paket dependensi driver JDBC MySQL dapat diunduh dari komunitas.

• Parameter JDBC connector
  Karena penggunaan sebagai tabel sumber dan tabel dimensi tidak didukung, parameter yang terkait dengan fungsionalitas tabel sumber dan tabel dimensi tidak didukung (seperti parameter dengan awalan scan seperti scan.fetch-size, dan parameter dengan awalan lookup seperti lookup.cache).
  Rekomendasi untuk beberapa parameter JDBC connector:
  
  

  • url: Kami menyarankan Anda mengikuti Gunakan Java JDBC APIs untuk mengembangkan aplikasi dalam konfigurasi.

  • username: Gunakan username yang dibuat di instans Lindorm.

  • password: Kata sandi dari username tersebut.

  • connector, table-name: Ikuti rekomendasi komunitas JDBC connector.

  • parameter sink: Sesuaikan secara detail berdasarkan kondisi aktual pekerjaan.

• Pemetaan tipe data
  Pemetaan antara tipe data Flink dan tipe data Lindorm umumnya dapat mengikuti pemetaan tipe data MySQL (rujuk bagian Pemetaan tipe data pada JDBC connector). Namun, beberapa tipe data di Lindorm tidak selaras dengan MySQL. Sebagai contoh, tipe MySQL berikut yang diklaim didukung dalam JDBC connector tidak didukung oleh Lindorm:
  

  • Tipe MEDIUMINT

  • Tipe DATETIME

  • Tipe UNSIGNED selain BIGINT UNSIGNED

Contoh berikut menggunakan Flink SQL untuk mendefinisikan pekerjaan yang mengakses LindormTable melalui JDBC connector. Dalam contoh ini, asumsikan sebuah tabel bernama testflink telah didefinisikan di mesin tabel lebar Lindorm.

# Buat tabel Flink dan mulai pekerjaan
CREATE TABLE source_table(
    c1 INT,
    c2 STRING
) WITH (
  'connector' = 'datagen',
  'rows-per-second' = '2',
  'fields.c2.length' = '5',
  'fields.c1.min' = '1',
  'fields.c1.max' = '100'
);


CREATE TABLE sink_table(
    c1 INT,
    c2 STRING
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:mysql://ld-xxxxx-proxy-lindorm.lindorm.rds.aliyuncs.com:33060/default?sslMode=disabled&allowPublicKeyRetrieval=true&useServerPrepStmts=true&useLocalSessionState=true&rewriteBatchedStatements=true&cachePrepStmts=true&prepStmtCacheSize=300&prepStmtCacheSqlLimit=50000000',
    'username' = 'root',
    'password' = 'root',
    'table-name' = 'testflink'
);


INSERT INTO sink_table SELECT * FROM source_table;

Cloud-native multi-model database Lindorm connector

• Dalam pengembangan pekerjaan Realtime Compute for Apache Flink, Anda dapat mengembangkan pekerjaan yang mengakses mesin tabel lebar Lindorm menggunakan Flink SQL. Untuk detail pengembangan pekerjaan Realtime Compute for Apache Flink, lihat Ikhtisar pengembangan pekerjaan.

• Untuk informasi tentang cara menggunakan connector guna membuat tabel dimensi dan tabel hasil, lihat Dokumentasi cloud-native multi-model database Lindorm connector.