Spark - Доступ к log4j logger из PandasUDF - PullRequest
0 голосов
/ 21 января 2019

Я использую Spark-2.4 и пытаюсь получить доступ к логгеру log4j из функции PandasUDF. Как это можно сделать на драйвере:

sc = SparkContext(conf=conf) 
log4jLogger = sc._jvm.org.apache.log4j 
log = log4jLogger.LogManager.getLogger(__name__) 
log.warn("Hello World!")

Может кто-нибудь выложить пример

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...