Tüm Ürünler
Search

Bu Ürün

    Realtime Compute for Apache Flink:UDF'leri Yönetin

    Belge Merkezi

    Realtime Compute for Apache Flink:UDF'leri Yönetin

    Son Güncelleme:Oct 04, 2026

    Bir SQL dağıtımında kullanmak için bir UDF kaydetmeniz gerekir. Bu konuda UDF'lerin nasıl kaydedileceği, güncelleneceği ve silineceği açıklanmaktadır.

    Başlamadan önce

    • Bir RAM kullanıcısının veya RAM rolünün UDF'leri yönetmesi gerekiyorsa, hedef ad alanına erişim iznine sahip olduğundan emin olun. Daha fazla bilgi için bkz. geliştirme konsolu yetkilendirmesi.

    • UDF geliştirirken JAR dosyalarındaki bağımlılık çakışmalarını önlemek için aşağıdaki yönergeleri uygulayın:

      • Geliştirme sayfasında seçtiğiniz Flink sürümünün POM bağımlılığınızdaki Flink sürümüyle eşleştiğinden emin olun.

      • Flink ile ilgili bağımlılıklar için, <scope>provided</scope> ekleyerek kapsamını provided olarak ayarlayın.

      • Diğer üçüncü taraf bağımlılıkları paketlemek için Apache Maven Shade Plugin'i kullanın. Daha fazla bilgi için bkz. Apache Maven Shade Plugin.

      Not

      Flink bağımlılık çakışmaları hakkında daha fazla bilgi için bkz. Flink bağımlılık çakışmalarını nasıl giderebilirim?.

    Bir UDF Kaydetme

    Katalog UDF'leri

    1. UDF kayıt sayfasına gidin.

      1. Realtime Compute for Apache Flink konsolunda oturum açın.

      2. Hedef çalışma alanının Actions sütununda Console öğesini tıklayın.

      3. Sol gezinme bölmesinde Development > ETL öğelerini seçin.

      4. Functions sekmesini tıklayın.

    2. Register UDF öğesini tıklayın.

    3. UDF JAR dosyasını yükleyin.

      Bir UDF JAR dosyasını aşağıdaki yöntemlerden biriyle yükleyebilirsiniz:

      • Upload a file: UDF yapınızı seçmek için Select a file alanının yanındaki Select a file öğesini tıklayın. UDF'nin bağımlılıkları varsa, gerekli dosyaları yüklemek için Dependency File alanının yanındaki Select a file öğesini tıklayın.

        Not

        • UDF dosyanız, seçtiğiniz OSS paketindeki sql-artifacts dizinine yüklenir.

        • Java UDF için bağımlılıklar UDF JAR dosyasına paketlenmiş veya ayrı olarak yüklenebilir. Python UDF için bağımlılıkları ayrı olarak yüklemenizi öneririz.

      • External URL: Başka bir hizmetten bir UDF dosyası kullanmak için harici URL'sini belirtin.

        Not

        İ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şimine sahip olduğu (genel okuma veya izin verilmiş) harici bir depolama sistemi için URL.

    4. OK öğesini tıklayın.

    5. Available Functions sayfasında kaydetmek istediğiniz UDF'leri seçin ve Create Function öğesini tıklayın.

      Geliştirme konsolu, yapı dosyasını ayrıştırır, Flink UDF, UDAF ve UDTF arayüzlerini kullanan sınıfları belirler ve İşlev Adı alanını sınıf adlarıyla otomatik olarak doldurur. Bir UDF kaydedildikten sonra bunu Functions listesinde görüntüleyebilirsiniz. Kayıtlı her UDF'nin solunda sarı bir "fx" simgesi görünür.

      Not

      Bir katalog UDF'si kaydederken, varsayılan olarak ayrıştırma için en son Flink sürümü kullanılır. SQL dağıtımınız daha eski bir altyapı sürümü kullanıyorsa bu durum uyumsuzluk sorunlarına neden olabilir. Bunu çözmek için UDF kodunu gereken altyapı sürümüne göre uygulayabilir ve dağıtım düzeyinde bir UDF olarak kaydedebilirsiniz. Daha fazla bilgi için bkz. Dağıtım Düzeyinde UDF'ler.

    Dağıtım Düzeyinde UDF'ler

    Önemli

    • Dağıtım düzeyinde Python UDF'leri yalnızca VVR 8.0.3 ve sonraki sürümlerde desteklenir.

    • Dağıtım düzeyinde bir Python UDF kullanırken, dağıtım parametrelerinde python.files veya python.archives gibi parametreleri kullanarak bağımlılık dosyalarını yapılandırabilirsiniz.

    • Dağıtım düzeyinde bir Python UDF kullanırken sözdizimi denetimi desteklenmez. Dağıtımı başlatırken sözdizimi denetimini atlamalısınız.

    Dağıtım düzeyinde bir UDF kaydetmek için şu adımları izleyin:

    1. UDF JAR dosyasını veya Python dosyasını yükleyin.

      Sol gezinme bölmesinde Artifacts bölümüne gidin ve UDF JAR veya Python dosyasını yükleyin.

    2. Dağıtımda dağıtım düzeyinde UDF'yi belirtin.

      Dağıtım için Additional Dependencies bölümünde UDF JAR veya Python dosyasını belirtin.

    3. Dağıtım düzeyinde UDF'yi kaydedin.

      • Java UDF

        CREATE TEMPORARY FUNCTION yourfunctionname;

      • Python UDF

        CREATE TEMPORARY FUNCTION yourfunctionname LANGUAGE Python;

    Bir UDF'yi Güncelleme

    Yeni bir UDF ekledikten veya mevcut olanı değiştirdikten sonra bir UDF JAR dosyasını güncellemek için şu adımları izleyin.

    1. UDF kayıt sayfasına gidin.

      1. Realtime Compute for Apache Flink konsolunda oturum açın.

      2. Hedef çalışma alanının Actions sütununda Console öğesini tıklayın.

      3. Sol gezinme bölmesinde Development > ETL öğelerini seçin.

      4. Functions sekmesini tıklayın.

    2. Functions listesinde hedef UDF adının üzerine gelin ve 更新JAR simgesini tıklayın.

    3. UDF JAR dosyasını yükleyin. Update UDF JAR iletişim kutusunda Upload a file veya External URL yöntemini seçin, Select a file ve Dependency File alanlarını yapılandırın ve Modify öğesini tıklayın.

      Önemli

      • Yeni UDF JAR dosyası, şu anda kayıtlı olan tüm UDF'lerin sınıflarını içermelidir.

      • Yeni UDF JAR dosyasındaki değişiklikler yalnızca yeni veya yeniden başlatılan dağıtımlar için geçerli olur. Çalışan dağıtımlar, yeniden başlatılana kadar eski dosyayı kullanmaya devam eder.

    4. Modify öğesini tıklayın.

    Bir UDF'yi Silme

    Not

    Bir UDF JAR dosyasını silmeden önce, ondan kaydedilen UDF'lere başvuran herhangi bir dağıtım veya SQL dosyası olmadığından emin olun.

    Bir UDF JAR dosyasını silmek için şu adımları izleyin:

    1. UDF kayıt sayfasına gidin.

      1. Realtime Compute for Apache Flink konsolunda oturum açın.

      2. Hedef çalışma alanının Actions sütununda Console öğesini tıklayın.

      3. Sol gezinme bölmesinde Development > ETL öğelerini seçin.

      4. Functions sekmesini tıklayın.

    2. Functions listesinde hedef UDF adının üzerine gelin ve 删除JAR simgesini tıklayın.

    3. Delete all functions and the associated file onay kutusunu seçin.

      UDF JAR dosyasını silmek için veri tutarsızlıklarını önlemek amacıyla ondan kaydedilen tüm UDF'leri de silmelisiniz.

    4. OK öğesini tıklayın.

    İlgili konular