关于1.9使用hive中的udf

Wed, 25 Sep 2019 04:21:35 -0700 

各位大佬好：
        目前我在使用1.9版本中hive的udf碰到如下问题：
        1、hive的udf都是注册在default库中，sql里面带有default关键词，flink程序就会报错
        我通过 tableEnv.useCatalog("hive") 
、tableEnv.useDatabase("default")这种方式解决了default关键词的问题
        同时发现如果不使用tableEnv.useDatabase("xx_db"),直接使用  xx_db.fun是找不到函数的


        2、使用上面的方式能使用hive中指定某个库的udf，但是需要使用flink中注册的表会很麻烦
        sql里需要这么写（default_catalog.default_database.xx_table）


 请问大家有没有好的使用方式和建议？感谢 ！

回复