2 qq 23660243 qq_23660243 于 2016.04.27 23:47 提问

storm BaseRichBolt declareOutputFields

我其实就是想问问

public void declareOutputFields(OutputFieldsDeclarer declarer) {
declarer.declare(new Fields("xxxx"));
}
这个方法到底起到了什么作用

2个回答

devmiao
devmiao   Ds   Rxr 2016.04.27 23:53
已采纳
qq_23660243
qq_23660243 谢谢
大约 2 年之前 回复
GodStorm_KK
GodStorm_KK   2016.12.23 23:43

设置输出流的字段名称,看一下storm自带的wordcount例子你就明白了

Csdn user default icon
上传中...
上传图片
插入图片
准确详细的回答,更有利于被提问者采纳,从而获得C币。复制、灌水、广告等回答会被删除,是时候展现真正的技术了!
其他相关推荐
Storm-declareOutputFields-declare
最近项目需要开始接触storm,感觉跟spark差距还是不小的,不过每个平台都有各自的优势,不做过多评价。有个地方,一直困扰了我好久,就是不管是spout实现类还是bolt实现类里面都有个declareOutputFields的方法,后面declare出去的东西我是真看不明白有啥用,然后按照官网看了一下,结合自身理解在此梳理一下,如果有同学有同样的问题希望能给你解惑。 如图,这是我的
Storm的BaseBasicBolt源码解析ack机制
我们在学习ack机制的时候,我们知道Storm的Bolt有BaseBasicBolt和BaseRichBolt。 在BaseBasicBolt中,BasicOutputCollector在emit数据的时候,会自动和输入的tuple相关联,而在execute方法结束的时候那个输入tuple会被自动ack。 在使用BaseRichBolt需要在emit数据的时候,显示指定该数据的源tuple要加
Storm BaseBasicBolt和BaseRichBolt。
我们在学习ack机制的时候,我们知道Storm的Bolt有BaseBasicBolt和BaseRichBolt。 在BaseBasicBolt中,BasicOutputCollector在emit数据的时候,会自动和输入的tuple相关联,而在execute方法结束的时候那个输入tuple会被自动ack。 在使用BaseRichBolt需要在emit数据的时候,显示指定该数据的源tuple要加上
storm中declareOutputFields方法的使用规则及与fieldsGrouping方法的联系
public class Output extends BaseBasicBolt{ @Override public void execute(Tuple tuple, BasicOutputCollector arg1) { String str=tuple.getString(0); String str1=tuple.getString(1); arg1.emit(new
Strom中IBasicBolt与IRichBolt的区别
Storm 中 IRichBolt 与 IBasicBolt 在Storm中,如果要保证消息发送成功,每个处理tuple,都必须进行ack或者fail。因为storm会追踪每个tuple要占用内存。所以如果你不ack/fail每一个tuple,那么最终年会看到OutOfMemory错误。 对于SplitSentence这一部分,如果用IRichBolt来做(想写得更少,可以直接继承BaseRi
BasicBolt和IRichBolt之间的区别
IRichBolt继承自IBolt,IBolt会使用OutputCollector来发送元组。public interface IBolt extends Serializable { ... void prepare(Map stormConf, TopologyContext context, OutputCollector collector); ... }OutputCollector有
IBasicBolt和IRichBolt之间的区别
IRichBolt继承自IBolt,IBolt会使用OutputCollector来发送元组。 public interface IBolt extends Serializable { ... void prepare(Map stormConf, TopologyContext context, OutputCollector collector); ... }1234512345
Storm里面fieldsGrouping和Field的概念详解
这个Field通常和fieldsGrouping分组机制一起使用,这个Field特别难理解,我自己也是在网上看了好多文章,感觉依旧讲的不是很清楚,是似而非,没有抓到重点。这个问题足足困扰了我3-4天时间,一直理解不了Field的概念, 当前我觉得new Fields("word")就相当于表的表头,就是定义这个域,这个域里面放的东西,是emit进去的 Spouts---
Storm应用系列之——Spout、Bolt API
Storm中常用的Bolt和Spout API介绍
storm基础详解
Storm基础详解 一、storm是什么 Storm是一个分布式的、可靠的、高容错的实时流式数据处理系统。 二、storm的特性 简单的编程模型。类似于MapReduce降低了并行批处理复杂性,Storm降低了进行实时处理的复杂性,可以使用各种编程语言,容错性,水平扩展,可靠的消息处理等。 三、storm的应用场景 Storm主要的应用场景就是流式数据处理,例如实时推荐系统,实时监控系