知识点
相关文章
更多最近更新
更多storm 大牛博文
2019-03-02 23:38|来源: 网路
csdn博客
新浪博客
about云
转自：http://chenshenglong.blog.51cto.com/8073124/1437523
相关问答
更多-
有storm相关的视频可以下载的吗？[2022-03-14]
bg4.png storm的，这方面不多，有资料可以参考 Storm入门指南 基于Storm进行实时网络攻击检测及数据挖掘文档下载 hadoop、storm、数据挖掘等文档分享 storm实时流计算应用开发框架-天罡从需求到技术方案介绍 hadoop、hive、storm文档、电子书籍分享 storm编程入门：基本概念 hadoop、storm、hbase面试题、工作日常问答 Storm相关20文档与相关包 Storm入门教程汇总 -
charge up a storm的意思[2022-05-09]
charge up原意充电、提价，此句与a storm意思是索取很多，即大量借款 -
请问dance up a storm具体怎么翻译？[2022-06-05]
Hi: 下列还有三个短语相同意思: cook up a storm烹饪上露一手 dance up a storm舞姿翩翩 talk up a storm 侃侃而谈 [MAINLY US INFORMAL:主要用于美国,非正式用语] to do something with a lot of energy and often skill:[以非凡的能力和技能做某事] Rob was in the kitchen cooking up a storm. Rob在厨房里大显身手. (from Cambridge ... -
when the rain,the storm all is up怎么翻译[2022-01-20]
当下雨的时候，风暴都到了 -
Storm为什么依赖zookeeper[2022-03-28]
bg4.png 如果对zookeeper系统的认识一下，可能会加深理解，下面可以参考：zookeeper适用场景：zookeeper解决了哪些问题什么是ZooKeeper，ZooKeeper 能干什么？ZooKeeper的作用zookeeper原理zookeeper适用场景：如何竞选Master及代码实现zookeeper适用场景：配置文件同步分布式网站架构：zookeeper技术浅析zookeeper适用场景：分布式锁实现 -
Storm是什么文件[2023-06-19]
Storm译为汉语即‘暴风雨’、“暴风雪”，是暴风影音软件的英文名，是一种媒体播放器。 Storm还是一个分布式的、容错的实时计算系统，由BackType开发，广泛用于进行实时日志处理，实时统计、实时风控、实时推荐等场景中，目前最新版本是Storm 0.8.0。 Storm还是外文歌曲的名字，具体可在百度音乐中搜索。 -
Storm不支持此功能。 如果Bolt B失败，则只能从Spout进行重放。 让我们假设Spout发出一个由Bolt A处理的元组t1 ，并产生一个输出元组t2 。 如果螺栓B不能处理t2 ，则喷口可以重新发射元组t1 ，其由螺栓A再次处理，导致输出元组t2 。 当然，当第二次处理t1时，Bolt A必须产生相同的输出元组t2 。 此外，处理顺序也会改变。 Spout可以在重新发射t1之前发出其他元组，即Bolt B可能在失败后以不同的顺序接收元组（当Bolt B被恢复时， t2很可能不是第一个元组）。 T ...
-
Storm Fields分组示例(Storm Fields grouping example)[2022-02-14]
您需要将json属性从json对象中拉出，并将两个值（json对象和String groupId）作为双值元组传递。 当您将流声明为拓扑规范逻辑的一部分时，您将为第二个字段指定名称“groupId”，并且事情应该正常工作。 如果您不想修改Kafka喷口，则需要有一个中间螺栓，其唯一目的是将groupId从json对象中分离出来。 中间螺栓还可以使用定向流（emitDirect（）方法），将目标放在json对象中的groupId上。 这就是为什么我不重复使用Kafka喷口的一个原因 - 除了盲目地将数据写入流 ... -
在Apache Storm bolt中使用Apache Camel ProducerTemplate(Using Apache Camel ProducerTemplate in Apache Storm bolt)[2022-09-09]
您的问题的根本原因是您正在向您的风暴配置添加ProducerTemplate，并且它正在抛出异常，因为它不可序列化。 如果那是你自己的类，你可以改变代码使其工作，但由于这是一个Camel类，我会推荐一种不同的方法。 WebSocketBolt：将您的producerTemplate私有成员更改为transient： private transient ProducerTemplate producerTemplate; 这样就不会尝试序列化（将其置于conf中也会遇到同样的问题）。 WebSocketBol ... -
您必须在所有螺栓中ack所有传入的元组，即将collector.ack(input)添加到TransformerBolt.execute(Tuple input) 。 您看到的日志消息是正确的：您的代码调用collector.ack(...)并记录此调用。 拓扑中对ack的调用不是对Spout.ack(...)的调用：每次Spout发出带有消息ID的元组时，此ID都会由拓扑的正在运行的ackers注册。 那些ackers会在Bolt的每个ack上收到一条消息，收集这些消息并在收到元组的所有ack时通知Spo ...