想请问一下咱们flink udf怎么上传和注册的?[阿里云实时计算 Flink版]

请教一下咱们flink udf怎么上传和注册的,我把自定义jar包放到lib下,然后创建:CREATE TEMPORARY SYSTEM FUNCTION arraysort AS ‘com.streaming.flink.udsf.ArraySortFunction’;在使用这个函数的时候,不知道为什么没有数据返回,select name,arraysort(dfsds,’desc’) ddd from (values (‘222’,ARRAY[‘wefrwe’,’wef’,’wef’]),(‘222’,ARRAY[‘wef’,’wef21′,’wef22′])) as nametable(name,dfsds) 也不报错

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====