我们可以使用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
}
}
抱歉格式不对