Таким образом, мое требование:
- Подсчитать количество исключений в UDF Hive
- Если эти исключения go превышают указанное количество, генерировать исключение
Я слежу за этим блогом , и он намекнул мне использовать MapredContext, который доступен в GenericUDF. Я создал свой UDF и использовал метод override для public void configure. Однако, как только я создал свой UDF и попытался использовать его в консоли улья (использовал его через временную функцию), он продолжает выдавать NullPointerException для метода MapredContext.get().getReporter().
Есть ли что-нибудь, что нужно сделать, например, какая-то инициализация, прежде чем мы сможем сделать MapredContext.get().getReporter().