flink on zeppelin使用手册(持更)
发布时间
阅读量:
阅读量
加载udf和 jar包
%flink.conf
flink.udf.jars /etc/udf/myudf.jar(或者在hdfs上 hdfs:///tmp/udf/myudf.jar)
flink.execuion.jars hdfs:///tmp/flinkjars (加载flink本身不带的jar包)
在Zeppelin环境中同样支持编写UDF,但仅限于采用Scala语言进行开发。而上述所提及的方式则具备更高的灵活性,既适用于Java也适用于Scala语言,完成编写后需进行打包并加载至系统中。
查看udf
%flink.ssql(type=update)
show functions
全部评论 (0)
还没有任何评论哟~
