[UDF] How to load udf jar in pyhive ?

[BruceWong96]

In kyuubi doc, the engine side can finish loading udf .

So, how to do it. My test code is below.

configuration = get_set_command(sql_0)
# dev
# kyuubi_host = 'x.x.x.x'
# prod
kyuubi_host = 'x.x.x.x'

cursor = hive.connect(host=kyuubi_host, port=8888, username='user01', configuration=configuration).cursor()

sql_arr = sql_0.split(u';')
for index in range(len(sql_arr)):
    sql_arr[index] = sql_arr[index]

# for sql in sql_arr:
    # print(sql)
    # print('---------++++++++++++++-------------')

for sql in sql_arr:
    cursor.execute(sql)
    print('---------++++++++++++++-------------')
    print(cursor.fetchall())`

Thanks.

[pan3793]

Call ADD JAR ... using SQL cursor.execute(sql)

https://spark.apache.org/docs/latest/sql-ref-syntax-aux-resource-mgmt-add-jar.html

[BruceWong96]

Thanks