整套大数据学习资料(视频+笔记)百度网盘无门槛下载:http://www.edu360.cn/news/content?id=3377

8.1.3. 用户定义的Streaming计数器

hadoop 小红牛 9℃ 0评论

使用Streaming的MapReduce程序可以向标准错误流发送一行特殊格式的信息来增加计数器的值,这种技术可被视为一种计数器控制手段。信息的格式如下:

reporter:counter:group,counter,amount

以下Python代码片段将Temperature组的Missing计数器的值增加1:

sys.stderr.write("reporter:counter:Temperature,Missing,1\n")

状态信息也可以类似方法发出,格式如下:

reporter:status:messoge

转载请注明:全栈大数据 » 8.1.3. 用户定义的Streaming计数器

喜欢 (0)or分享 (0)
发表我的评论
取消评论

表情

Hi,您需要填写昵称和邮箱!

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址