Untuk mengelola tabel Paimon secara efisien dan fleksibel di Development Console, konfigurasikan toolkit yang diperlukan untuk tugas-tugas seperti menggabungkan file kecil dan mengurutkan data. Topik ini menjelaskan proses konfigurasi tersebut guna memudahkan Anda dalam mengelola data tabel Paimon.
Limitations
Tabel Paimon didukung oleh Ververica Runtime (VVR) 8.0.5 atau versi yang lebih baru.
Prosedur
Unduh paket JAR yang diperlukan untuk lingkungan manajemen data Paimon.
paimon-flink-action:
paimon-ali-vvr: Unduh paket yang sesuai dengan versi VVR Anda:
Untuk VVR 11.2 dan versi yang lebih baru (JDK 11): paimon-ali-vvr-11-vvp-1-ali-16.0-1.jar
Untuk VVR 11.2 dan versi yang lebih baru (JDK 8): paimon-ali-vvr-11-vvp-jdk8-1-ali-16.0-1.jar
Untuk VVR 11.1: paimon-ali-vvr-11.1-1-ali-16.0-1.jar
Untuk VVR 8.0.11: paimon-ali-vvr-8.0-vvp-1-ali-16.0-1.jar
Di Development Console, buka Artifacts dan klik Upload Artifact untuk mengunggah dua paket JAR yang telah Anda unduh pada langkah sebelumnya.
Buka , lalu klik .
Pada dialog Create JAR Deployment, isi item konfigurasi sebagai berikut:
Item Konfigurasi
Deskripsi
Contoh
Mode Implementasi
Pilih Stream Mode atau Batch Mode sesuai kebutuhan.
Batch Mode
Nama Implementasi
Masukkan nama untuk penerapan pekerjaan.
test
Versi Engine
Pilih VVR 8.0.5 atau versi yang lebih baru.
vvr-8.0.5-flink-1.17
JAR URI
Pilih paket JAR
paimon-flink-actionyang diunggah pada Langkah 2.Kelas Titik Masuk
Kelas titik masuk program. Biarkan kosong.
Argumen Utama Titik Masuk
Parameter input yang akan dipanggil dalam metode main. Isi bidang ini sesuai kebutuhan. Untuk detailnya, lihat dokumen fitur terkait. Misalnya, untuk menerapkan pengurutan data, lihat Data consumption.
Dependensi Tambahan
Jalur atau nama file dependensi yang akan disambungkan. Pilih paket
paimon-ali-vvryang Anda unggah pada Langkah 2.Klik Deploy.
Temukan penerapan target dan klik Start. Untuk informasi selengkapnya, lihat Start a job.
Referensi
Untuk mengonfigurasi parameter pekerjaan setelah pekerjaan dimulai, lihat Configure a deployment.
Beberapa parameter mendukung pembaruan dinamis untuk mengurangi downtime bisnis akibat restart. Untuk informasi selengkapnya, lihat Dynamically update the parameter configuration for dynamic scaling.
Untuk optimasi umum pada tabel scalable Paimon dengan primary-key dan append dalam berbagai kasus penggunaan, lihat Performance optimization.