我们可以在mapreduce中使用log4j吗?



我们可以使用log4j登录mapreduce吗?如果是,提供在map-reduce中使用log4j记录信息的步骤。我写了下面的log4。

下面是在Mapper中配置Log4j的一种简单方法,仅用于

记录MapReduce作业的标准实践

,代码片段在这里

进口org.apache.log4j.Logger;//其他导入忽略

公共类SampleMapper扩展Mapperprivate Logger Logger = Logger. getlogger (SampleMapper.class);

@Override
protected void setup(Context context) {
    logger.info("Initializing NoSQL Connection.")
    try {
        // logic for connecting to NoSQL - ommitted
    } catch (Exception ex) {
        logger.error(ex.getMessage());
    }
}
@Override
protected void map(LongWritable key, Text value, Context context) throws IOException, InterruptedException {
    // mapper code ommitted
}

}

抱歉格式不对

相关内容

  • 没有找到相关文章

最新更新