Advertisement

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)

还没有任何评论哟~