Я пытаюсь зарегистрировать функцию java для запуска контекста sql из пользовательского jar, скажем, a.jar.
И этот a.jar зависит от других банок, таких как b.jar и b.jar, зависит от других банок, таких как c.jar и т. Д.
Обратите внимание, что все банки жирные, что означает, что они также включают их зависимости.
Когда я запускаю приведенный ниже код, он успешно добавляется в sqlContext, но при вызове моей Java-функции c.jar не обнаруживается.
Тот же код прекрасно работает с jupyter, но не работает с zeppelin.
Я пробовал z.load или добавил зависимости от интерфейса интерпретатора zeppelin. Также добавлен c.jar вручную. Пока ничего не получалось.
sqlContext.registerJavaFunction("cust","com.foo.Bar")
sqlContext.sql("SELECT cust(tweet) from foos").show(n=1)