iframe-proxy | Sunbelt Computer Software

19 lines (15 loc) · 582 Bytes

class Log4j(object):

def __init__(self, spark):

root_class = "guru.learningjournal.spark.examples"

conf = spark.sparkContext.getConf()

app_name = conf.get("spark.app.name")

log4j = spark._jvm.org.apache.log4j

self.logger = log4j.LogManager.getLogger(root_class + "." + app_name)

def warn(self, message):

self.logger.warn(message)

def info(self, message):

self.logger.info(message)

def error(self, message):

self.logger.error(message)

def debug(self, message):

self.logger.debug(message)

Sunbelt Computer Software