Yerleşik bağlayıcılar veri kaynaklarınızı veya hedeflerinizi kapsamıyorsa Flink çalışma alanınızı genişletmek için özel bir bağlayıcı JAR dosyası yükleyin. Bu konuda özel bağlayıcıların nasıl kaydedileceği, kullanılacağı ve güncelleneceği açıklanmaktadır.
Ön koşullar
Başlamadan önce şunlara sahip olduğunuzdan emin olun:
Realtime Compute for Apache Flink'in Yönetim Portalı içinde bir Flink çalışma alanı
Apache Flink standartlarına göre oluşturulmuş özel bir bağlayıcı JAR dosyası
Kullanım notları
JAR dosyanızı yüklemeden önce aşağıdaki kısıtlamaları gözden geçirin:
| Kısıtlama | Ayrıntılar |
|---|---|
| Benzersizlik | Her bağlayıcı türü yalnızca bir kez kaydedilebilir. |
| Sürüm uyumu | pom.xml dosyanızda belirtilen Flink sürümü çalışma alanınızın Flink çalışma zamanı görüntüsü sürümüyle eşleşmelidir. |
provided kapsamı |
pom.xml dosyanızdaki Flink bağımlılıklarına <scope>provided</scope> ekleyin. Çalışma zamanı katmanında JAR dosyaları yüklemek bağımlılık çakışmalarına yol açar. |
| Shade paketleme | Çalışma zamanında sınıf yolu çakışmalarını önlemek için tüm üçüncü taraf bağımlılıklarını (Flink çalışma zamanı bağımlılıkları hariç) Maven Shade Plugin kullanarak paketleyin. |
Özel bağlayıcı kaydetme
Realtime Compute for Apache Flink'in Yönetim Portalı üzerinde oturum açın.
Hedef çalışma alanının Actions sütununda Console seçeneğine tıklayın.
Sol gezinme bölmesinde Connectors seçeneğine tıklayın.
Custom Connectors sekmesinde Create Custom Connector seçeneğine tıklayın.
-
JAR dosyanızı aşağıdaki yöntemlerden birini kullanarak yükleyin:
Upload File: Click to select seçeneğine tıklayın ve bağlayıcı JAR dosyanızı seçin.
-
Use External URL: Harici bir hizmette barındırılan JAR dosyasının URL'sini girin. Örnek:
https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jarNotİki tür harici URL desteklenir:
Flink çalışma alanınızla ilişkili OSS paketi. Paket ayrıntılarını Yönetim Portalındaki Workspace Details sayfasında görüntüleyin.
Realtime Compute for Apache Flink'in erişebildiği (genel okuma veya izin verilmiş) harici bir depolama sistemi için bir URL.
Next seçeneğine tıklayın. Flink yüklenen JAR dosyasını ayrıştırır. Ayrıştırma başarılı olursa sonraki adıma geçin. Başarısız olursa bağlayıcı kodunuzun Apache Flink standartlarına uygun olduğunu doğrulayın.
Finish seçeneğine tıklayın. Özel bağlayıcı bağlayıcı listesinde görünür.
Bir işte özel bağlayıcı kullanma
Bağlayıcıya işinizin SQL kodunda connector seçeneğini kullanarak başvurun. connector seçeneğinin değeri özel bağlayıcınızın JAR paketindeki DynamicTableFactory tanımlayıcı parametresinin değeridir. Diğer bağlayıcı seçeneklerini özel bağlayıcınız belirler.
İş SQL'si yazma hakkında ayrıntılı bilgi için bkz. İş geliştirimine genel bakış.
Özel bağlayıcıyı güncelleme
Özel bir bağlayıcının güncellenmesi çalışan işleri etkilemez. Güncellemeler işler yeniden başlatıldıktan sonra etkin olur.
Realtime Compute for Apache Flink'in Yönetim Portalı üzerinde oturum açın.
Hedef çalışma alanının Actions sütununda Console seçeneğine tıklayın.
Sol gezinme bölmesinde Connectors seçeneğine tıklayın.
Custom Connectors sekmesinde hedef bağlayıcıyı bulun ve adının yanındaki Edit seçeneğine tıklayın.
-
Yeni JAR dosyasını aşağıdaki yöntemlerden birini kullanarak yükleyin:
Upload File: Click to select seçeneğine tıklayın ve bağlayıcı JAR dosyanızı seçin.
-
Use External URL: Harici bir hizmette barındırılan JAR dosyasının URL'sini girin. Örnek:
https://ossbucket/artifacts/namespaces/flink-default/flink-jobs-1.0-SNAPSHOT.jarNotİki tür harici URL desteklenir:
Flink çalışma alanınızla ilişkili OSS paketi. Paket ayrıntılarını Yönetim Portalındaki Details sayfasında görüntüleyin.
Realtime Compute for Apache Flink'in erişebildiği (genel okuma veya izin verilmiş) harici bir depolama sistemi için bir URL.
Next seçeneğine tıklayın. Flink yüklenen JAR dosyasını ayrıştırır. Ayrıştırma başarılı olursa sonraki adıma geçin. Başarısız olursa bağlayıcı kodunuzun Apache Flink standartlarına uygun olduğunu doğrulayın.
Finish seçeneğine tıklayın.