Todos os produtos
Search

Este produto

    Realtime Compute for Apache Flink:Gerenciar UDFs

    Central de documentação

    Realtime Compute for Apache Flink:Gerenciar UDFs

    Última atualização: Nov 03, 2026

    Você precisa registrar uma UDF para usá-la em uma implantação SQL. Este tópico descreve como registrar, atualizar e excluir UDFs.

    Antes de começar

    • Se um usuário RAM ou uma função RAM precisar gerenciar UDFs, verifique se ele tem permissão para acessar o namespace de destino. Para mais informações, consulte autorização do console de desenvolvimento.

    • Para evitar conflitos de dependência em arquivos JAR ao desenvolver UDFs, siga estas diretrizes:

      • Certifique-se de que a versão do Flink selecionada na página de desenvolvimento corresponda à versão do Flink na sua dependência POM.

      • Para dependências relacionadas ao Flink, defina o scope como provided adicionando <scope>provided</scope>.

      • Use o Apache Maven Shade Plugin para empacotar outras dependências de terceiros. Para mais informações, consulte Apache Maven Shade Plugin.

      Nota

      Para mais informações sobre conflitos de dependência do Flink, consulte Como solucionar conflitos de dependência do Flink?.

    Registrar uma UDF

    UDFs de catálogo

    1. Acesse a página de registro de UDF.

      1. Faça logon no console do Realtime Compute for Apache Flink.

      2. Na coluna Actions do workspace de destino, clique em Console.

      3. No painel de navegação à esquerda, clique em Development > ETL.

      4. Clique na guia Functions.

    2. Clique em Register UDF.

    3. Faça upload do arquivo JAR da UDF.

      Você pode fazer upload de um arquivo JAR de UDF de uma das seguintes formas:

      • Upload a file: Clique em Select a file ao lado do campo Select a file para escolher o artefato da UDF. Se a UDF tiver dependências, clique em Select a file ao lado do campo Dependency File para fazer upload dos arquivos necessários.

        Nota

        • Seu arquivo UDF é enviado para o diretório sql-artifacts no bucket OSS selecionado.

        • Para uma UDF Java, as dependências podem ser empacotadas no arquivo JAR da UDF ou enviadas separadamente. Para uma UDF Python, recomendamos que você faça upload das dependências separadamente.

      • External URL: Para usar um arquivo UDF de outro serviço, forneça sua URL externa.

        Nota

        Dois tipos de URLs externas são suportados:

        • O bucket OSS associado ao seu workspace Flink. Veja os detalhes do bucket na página Workspace Details no Portal de Gerenciamento.

        • Uma URL para um sistema de armazenamento externo ao qual o Realtime Compute for Apache Flink tenha acesso (leitura pública ou com permissão concedida).

    4. Clique em OK.

    5. Na página Available Functions, selecione as UDFs que deseja registrar e clique em Create Function.

      O console de desenvolvimento analisa o arquivo de artefato, identifica classes que usam as interfaces Flink UDF, UDAF e UDTF, e preenche automaticamente o campo Function Name com os nomes das classes. Após registrar uma UDF, você pode visualizá-la na lista Functions. Um ícone amarelo "fx" aparece à esquerda de cada UDF registrada.

      Nota

      Ao registrar uma UDF de catálogo, a versão mais recente do Flink é usada para análise por padrão. Se sua implantação SQL usar uma versão anterior do mecanismo, isso pode causar problemas de incompatibilidade. Para resolver, você pode implementar o código da UDF com base na versão necessária do mecanismo e registrá-la como uma UDF no nível de implantação. Para mais informações, consulte UDFs no nível de implantação.

    UDFs no nível de implantação

    Importante

    • UDFs Python no nível de implantação são suportadas apenas no VVR 8.0.3 e versões posteriores.

    • Ao usar uma UDF Python no nível de implantação, você pode configurar arquivos de dependência usando parâmetros como python.files ou python.archives nos parâmetros da implantação.

    • Ao usar uma UDF Python no nível de implantação, a verificação profunda (deep check) não é suportada. Você deve pular a verificação profunda ao implantar o job.

    Siga estas etapas para registrar uma UDF no nível de implantação:

    1. Faça upload do arquivo JAR da UDF ou do arquivo Python.

      No painel de navegação à esquerda, acesse Artifacts e faça upload do arquivo JAR da UDF ou do arquivo Python.

    2. Especifique a UDF no nível de implantação na implantação.

      Na seção Additional Dependencies da implantação, especifique o arquivo JAR da UDF ou o arquivo Python.

    3. Registre a UDF no nível de implantação.

      • UDF Java

        CREATE TEMPORARY FUNCTION yourfunctionname;

      • UDF Python

        CREATE TEMPORARY FUNCTION yourfunctionname LANGUAGE Python;

    Atualizar uma UDF

    Siga estas etapas para atualizar um arquivo JAR de UDF após adicionar uma nova UDF ou modificar uma existente.

    1. Acesse a página de registro de UDF.

      1. Faça logon no console do Realtime Compute for Apache Flink.

      2. Na coluna Actions do workspace de destino, clique em Console.

      3. No painel de navegação à esquerda, clique em Development > ETL.

      4. Clique na guia Functions.

    2. Na lista Functions, passe o mouse sobre o nome da UDF de destino e clique no ícone 更新JAR.

    3. Faça upload do arquivo JAR da UDF. Na caixa de diálogo Update UDF JAR, selecione o método Upload a file ou External URL, configure os campos Select a file e Dependency File e clique em Modify.

      Importante

      • O novo arquivo JAR da UDF deve conter as classes de todas as UDFs registradas atualmente.

      • As alterações no novo arquivo JAR da UDF entram em vigor apenas para implantações novas ou reiniciadas. As implantações em execução continuam usando o arquivo antigo até serem reiniciadas.

    4. Clique em Modify.

    Excluir uma UDF

    Nota

    Antes de excluir um arquivo JAR de UDF, certifique-se de que nenhuma implantação ou arquivo SQL faça referência às UDFs registradas a partir dele.

    Para excluir um arquivo JAR de UDF, siga estas etapas:

    1. Acesse a página de registro de UDF.

      1. Faça logon no console do Realtime Compute for Apache Flink.

      2. Na coluna Actions do workspace de destino, clique em Console.

      3. No painel de navegação à esquerda, clique em Development > ETL.

      4. Clique na guia Functions.

    2. Na lista Functions, passe o mouse sobre o nome da UDF de destino e clique no ícone 删除JAR.

    3. Selecione a caixa de seleção Delete all functions and the associated file.

      Para excluir o arquivo JAR da UDF, você também precisa excluir todas as UDFs registradas a partir dele para evitar inconsistências de dados.

    4. Clique em OK.

    Tópicos relacionados