Realtime Compute for Apache Flink：Mengelola konektor kustom

Perhatian

• Agar Realtime Compute for Apache Flink dapat mengidentifikasi dan menggunakan konektor kustom Anda, Anda harus mengembangkan konektor tersebut sesuai dengan standar yang ditetapkan oleh komunitas Apache Flink. Oleh karena itu, Anda perlu mendapatkan file .meta dari konektor kustom yang ingin dikembangkan dan mendeklarasikan kelas pabriknya. Untuk informasi lebih lanjut tentang pengembangan konektor kustom, lihat User-defined Sources & Sinks.

• Anda hanya dapat mengunggah file JAR untuk konektor dengan tipe yang sama satu kali.

• Untuk menghindari konflik dependensi file JAR, perhatikan hal-hal berikut:

  • Pastikan versi gambar Flink sama dengan versi Flink dalam dependensi Project Object Model (POM).

  • Jangan unggah file JAR di lapisan waktu proses. Ini berarti Anda perlu menambahkan <scope>provided</scope> ke dependensi.

  • Gunakan Plugin Shade untuk mengemas dependensi pihak ketiga. Untuk informasi lebih lanjut, lihat Apache Maven Shade plug-in.

Unggah dan gunakan konektor kustom

1. Buka dialog box Buat Konektor Kustom.

   1. Masuk ke Konsol Realtime Compute for Apache Flink.

   2. Temukan ruang kerja yang ingin dikelola dan klik Console di kolom Actions.

   3. Di panel navigasi sisi kiri, klik Connectors.

2. Buat Konektor Kustom.

   1. Di halaman Connectors, klik Create Custom Connector.

   2. Unggah file JAR dari konektor kustom.

      Anda dapat menggunakan salah satu metode berikut untuk mengunggah file JAR dari konektor kustom:

      • Upload File: Klik Click to Select dan pilih file JAR yang diinginkan.

      • Use External URL: Masukkan URL eksternal dari layanan lain. Sebagai contoh, Anda dapat memasukkan https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jar.

        null

        Hanya dua jenis URL eksternal berikut yang didukung:

        • Titik akhir Bucket OSS yang Anda tentukan saat membeli ruang kerja Realtime Compute for Apache Flink. Anda dapat melihat titik akhir Bucket OSS yang Anda tentukan dalam pesan Workspace Details di konsol manajemen Realtime Compute for Apache Flink.

        • Titik akhir sistem penyimpanan eksternal lain yang dapat diakses oleh Realtime Compute for Apache Flink. Daftar kontrol akses (ACL) dari sistem penyimpanan eksternal adalah publik-baca atau Realtime Compute for Apache Flink diberi izin untuk mengakses sistem penyimpanan eksternal.

   3. Setelah mengunggah file JAR, klik Next.

      Sistem akan menguraikan isi file JAR yang diunggah. Jika penguraian berhasil, lanjutkan ke langkah berikutnya. Jika gagal, periksa apakah kode konektor kustom Anda sesuai dengan standar yang ditetapkan oleh komunitas Apache Flink.

   4. Klik Finish.

      Konektor kustom yang dibuat akan muncul di daftar konektor.

3. Gunakan konektor dalam pernyataan DDL draf Anda.

   Untuk informasi lebih lanjut tentang pengembangan draf, lihat Kembangkan Draf SQL.

   null

   Anda harus menetapkan nilai parameter konektor dalam klausa WITH ke nilai parameter identifier DynamicTableFactory dalam file JAR konektor kustom. Parameter lain dalam klausa WITH dan definisinya bervariasi berdasarkan konektor kustom yang dibuat.

Perbarui konektor kustom

1. Buka dialog box Edit Konektor.

   1. Masuk ke Konsol Realtime Compute for Apache Flink.

   2. Temukan ruang kerja yang ingin dikelola dan klik Console di kolom Actions.

   3. Di panel navigasi sisi kiri, klik Connectors.

2. Di tab Konektor, klik tab Custom Connectors. Di tab Konektor Kustom, temukan konektor kustom yang diinginkan dan klik Edit di sebelah kanan nama konektor kustom.

3. Unggah file JAR dari konektor kustom.

   Anda dapat menggunakan salah satu metode berikut untuk mengunggah file JAR dari konektor kustom:

   • Upload File: Klik Click to Select dan pilih file JAR yang diinginkan.

   • Use External URL: Masukkan URL eksternal. Sebagai contoh, Anda dapat memasukkan https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jar.

     null

     Hanya dua jenis URL eksternal berikut yang didukung:

     • Titik akhir Bucket OSS yang Anda tentukan saat membeli ruang kerja Realtime Compute for Apache Flink. Anda dapat melihat titik akhir Bucket OSS yang Anda tentukan dalam pesan Workspace Details di konsol manajemen Realtime Compute for Apache Flink.

     • Titik akhir sistem penyimpanan eksternal lain yang dapat diakses oleh Realtime Compute for Apache Flink. Daftar kontrol akses (ACL) dari sistem penyimpanan eksternal adalah publik-baca atau Realtime Compute for Apache Flink diberi izin untuk mengakses sistem penyimpanan eksternal.

4. Setelah mengunggah file JAR, klik Next.

   Sistem akan menguraikan isi file JAR yang diunggah. Jika penguraian berhasil, lanjutkan ke langkah berikutnya. Jika gagal, periksa apakah kode konektor kustom Anda sesuai dengan standar yang ditetapkan oleh komunitas Apache Flink.

5. Klik Finish.

Referensi

• Realtime Compute for Apache Flink menyediakan berbagai konektor bawaan. Untuk informasi lebih lanjut tentang konektor yang didukung, lihat Konektor yang Didukung.

• Untuk informasi lebih lanjut tentang cara menggunakan konektor CDC (Change Data Capture) untuk Apache Flink, lihat Gunakan Konektor CDC untuk Apache Flink.

• Realtime Compute for Apache Flink mendukung manajemen metadata. Anda dapat membuat katalog untuk mengelola dan mengakses metadata. Untuk informasi lebih lanjut, lihat Kelola Katalog.