Anda dapat menggunakan Apache Flink sumber terbuka atau Alibaba Cloud Realtime Compute for Apache Flink untuk terhubung ke LindormTable. Metode yang dijelaskan dalam topik ini berlaku untuk kedua platform tersebut.
Informasi latar belakang
Anda dapat menentukan tabel Lindorm sebagai tabel dimensi Flink atau tabel hasil, lalu menggunakan Flink SQL atau Flink DataStream untuk mengaksesnya.
Prasyarat
Jika Anda menggunakan Apache Flink sumber terbuka untuk terhubung ke LindormTable, versi LindormTable harus 2.4.3 atau lebih baru. Jika menggunakan Alibaba Cloud Realtime Compute for Apache Flink, versi LindormTable tidak dibatasi. Untuk informasi lebih lanjut tentang cara melihat atau meningkatkan versi LindormTable, lihat Catatan Rilis LindormTable dan Tingkatkan Versi Mesin Minor dari Instance Lindorm.
Alamat IP klien Anda harus ditambahkan ke daftar putih instance Lindorm. Untuk informasi lebih lanjut, lihat Konfigurasikan Daftar Putih.
Catatan penggunaan
Untuk terhubung ke instance Lindorm melalui Internet atau jika instance Lindorm yang ingin Anda akses adalah instance Lindorm satu node, Anda harus meningkatkan SDK Anda dan mengubah konfigurasi sebelum melakukan operasi yang dijelaskan dalam topik ini. Untuk informasi lebih lanjut, lihat Langkah 1 di Gunakan ApsaraDB untuk API HBase Java untuk terhubung dan menggunakan LindormTable.
Jika aplikasi Anda ditempatkan pada instance Elastic Compute Service (ECS), pastikan bahwa instance Lindorm Anda dan instance ECS memenuhi persyaratan berikut untuk memastikan konektivitas jaringan:
Instance Lindorm Anda dan instance ECS harus berada di wilayah yang sama. Kami menyarankan Anda juga menempatkan kedua instance di zona yang sama untuk mengurangi latensi jaringan.
Instance Lindorm Anda dan instance ECS harus berada di VPC yang sama.
Jika Anda menggunakan Apache Flink sumber terbuka untuk mengakses tabel Lindorm, Anda hanya dapat mengakses tabel yang mirip HBase. Tabel SQL yang dibuat dengan menggunakan lindorm-cli tidak dapat ditentukan sebagai tabel dimensi atau tabel hasil di Apache Flink sumber terbuka. Anda hanya dapat menentukan tabel yang mirip HBase yang dibuat dengan menggunakan Hbaseue Shell sebagai tabel dimensi atau tabel hasil di Flink sumber terbuka. Jika Anda menggunakan Alibaba Cloud Realtime Compute for Apache Flink, Anda dapat mengakses semua tabel Lindorm.
Jika Anda menggunakan Realtime Compute for Apache Flink bersama dengan Flink SQL untuk mengakses tabel Lindorm, Anda dapat menggunakan konektor Lindorm tanpa perlu melakukan modifikasi.
Lihat titik akhir
Titik akhir LindormTable untuk API HBase digunakan jika Anda menggunakan Flink untuk mengakses tabel Lindorm. Anda dapat melihat titik akhir LindormTable di konsol Lindorm.
Jika Anda mengakses tabel Lindorm dengan menggunakan akun yang baru dibuat, pastikan bahwa akun tersebut memiliki izin baca dan tulis pada tabel Flink. Untuk informasi lebih lanjut tentang cara memberikan izin baca dan tulis, lihat Berikan Izin kepada Pengguna.
Buat tabel dimensi
Jika Anda ingin menggunakan Flink sumber terbuka untuk mengakses tabel Lindorm, ikuti langkah-langkah yang dijelaskan di Buat Tabel Dimensi.
Jika Anda menggunakan Realtime Compute for Apache Flink untuk mengakses tabel Lindorm, ikuti langkah-langkah yang dijelaskan di Buat Tabel Dimensi Lindorm.
Buat tabel hasil
Jika Anda ingin menggunakan Flink sumber terbuka untuk mengakses tabel Lindorm, ikuti langkah-langkah yang dijelaskan di Buat Tabel Hasil.
Jika Anda ingin menggunakan Realtime Compute for Apache Flink untuk mengakses tabel Lindorm, ikuti langkah-langkah yang dijelaskan di Buat Tabel Hasil Lindorm.