Realtime Compute for Apache Flink：Kelola konektor kustom

Perhatian

• Agar Realtime Compute for Apache Flink dapat mendeteksi dan menggunakan konektor kustom Anda dengan benar, kembangkan konektor tersebut sesuai dengan standar yang ditetapkan oleh komunitas Flink. Pastikan Anda menyediakan file metadata konektor dan mendeklarasikan kelas Factory-nya. Untuk informasi selengkapnya tentang pengembangan konektor kustom, lihat User-defined Sources & Sinks.

• Anda hanya dapat mengunggah satu jenis konektor dalam satu kali unggah.

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

  • Pastikan versi runtime image Flink konsisten dengan versi Flink yang ditentukan dalam dependensi Project Object Model (POM).

  • Jangan mengunggah paket JAR pada lapisan runtime. Artinya, tambahkan <scope>provided</scope> pada dependensinya.

  • Kemas dependensi pihak ketiga lainnya menggunakan metode Shade. Untuk informasi selengkapnya tentang pengemasan Shade, lihat Apache Maven Shade Plugin.

Unggah dan gunakan konektor kustom

1. Buka halaman pendaftaran konektor kustom.

   1. Masuk ke Realtime Compute for Apache Flink console.

   2. Di kolom Actions ruang kerja yang dituju, klik Console.

   3. Di panel navigasi sebelah kiri, klik Connectors.

2. Daftarkan konektor kustom.

   1. Di halaman Connectors, klik Create Custom Connector.

   2. Unggah file JAR konektor kustom.

      Anda dapat mengunggah file JAR konektor kustom dengan salah satu cara berikut:

      • Upload File: Klik Select File dan pilih file JAR konektor yang dituju.

      • External URL: Untuk menggunakan file JAR dari layanan lain, Anda dapat menggunakan fitur external URL untuk mengambil file tersebut. Contohnya: https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jar

        Catatan

        Hanya dua jenis external URL berikut yang didukung:

        • URL untuk Bucket OSS yang Anda pilih saat membuat ruang kerja Flink. Anda dapat melihat Bucket OSS yang terhubung di halaman Workspace Details di Realtime Compute for Apache Flink console.

        • URL untuk sistem penyimpanan eksternal lain yang memiliki izin akses oleh Realtime Compute for Apache Flink (public-read atau izin yang diberikan).

   3. Setelah pengunggahan selesai, klik Next.

      Sistem akan mengurai konten konektor kustom yang Anda unggah. Jika penguraian berhasil, Anda dapat melanjutkan ke langkah berikutnya. Jika penguraian gagal, pastikan kode konektor kustom Anda mematuhi standar komunitas Flink.

   4. Klik Finish.

      Konektor kustom yang dibuat akan muncul dalam daftar konektor.

3. Anda dapat menggunakan konektor tersebut dalam DDL pekerjaan.

   Untuk informasi selengkapnya tentang pengembangan pekerjaan, lihat Ikhtisar pengembangan pekerjaan.

   Catatan

   Nilai parameter connector dalam klausa WITH adalah nilai parameter identifier dari DynamicTableFactory dalam paket JAR konektor kustom Anda. Parameter WITH lainnya beserta maknanya ditentukan oleh konektor kustom yang Anda kembangkan.

Perbarui konektor kustom

1. Buka halaman pembaruan konektor kustom.

   1. Masuk ke Realtime Compute for Apache Flink console.

   2. Di kolom Actions ruang kerja yang dituju, klik Console.

   3. Di panel navigasi sebelah kiri, klik Connectors.

2. Di tab Custom Connectors, temukan konektor kustom yang dituju dan klik Edit di samping namanya.

3. Unggah file JAR konektor kustom.

   Anda dapat mengunggah file JAR konektor kustom dengan salah satu cara berikut:

   • Upload File: Klik Select File dan pilih file JAR konektor yang dituju.

   • External URL: Masukkan external URL. Contohnya: https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jar

     Catatan

     Hanya dua jenis external URL berikut yang didukung:

     • URL untuk Bucket OSS yang Anda pilih saat membuat ruang kerja Flink. Anda dapat melihat Bucket OSS yang terhubung di halaman Workspace Details di Realtime Compute for Apache Flink console.

     • URL untuk sistem penyimpanan eksternal lain yang memiliki izin akses oleh Realtime Compute for Apache Flink (public-read atau izin yang diberikan).

4. Setelah pengunggahan selesai, klik Next.

   Sistem akan mengurai konten konektor kustom yang Anda unggah. Jika penguraian berhasil, Anda dapat melanjutkan ke langkah berikutnya. Jika penguraian gagal, pastikan kode konektor kustom Anda mematuhi standar komunitas Flink.

5. Klik Finish.

Referensi

• Flink menyediakan berbagai konektor bawaan. Untuk informasi selengkapnya tentang konektor bawaan yang didukung, lihat Supported connectors.

• Untuk informasi selengkapnya tentang penggunaan konektor Change Data Capture (CDC) edisi komunitas, lihat Use community edition CDC connectors.

• Flink menyediakan manajemen data dengan memungkinkan Anda membuat catalog untuk mengelola dan mengakses metadata terkait. Untuk informasi selengkapnya, lihat Catalogs.