本文为您介绍如何管理Flink全托管自定义函数(UDF),包括注册、更新和删除。
注意事项
为了避免JAR包依赖冲突,您需要注意以下几点:
- Flink镜像的版本请与Pom依赖中的Flink版本保持一致。
- 请不要上传Runtime层的JAR包,即在依赖中添加
<scope>provided</scope>
。 - 其他第三方依赖请采用Shade方式打包,Shade打包详情参见Apache Maven Shade Plugin。
注册UDF
如果您的SQL需要使用UDF,您需要先注册您的UDF,才能在SQL中使用。
更新UDF
如果您的UDF JAR文件中,新增了UDF或已注册了UDF的代码变更,您可以按照以下步骤更新UDF JAR文件。
删除UDF
如果您的UDF JAR文件不再使用,您可以按照以下步骤删除UDF。
在文档使用中是否遇到以下问题
更多建议
匿名提交