`
尚将军
  • 浏览: 32613 次
  • 性别: Icon_minigender_1
  • 来自: 南京
社区版块
存档分类
最新评论

storm之bolt定时给自己发送tuple

 
阅读更多

继承BasicRichBolt之后,实现如下方法:

public Map<String, Object> getComponentConfiguration() {
        Map<String, Object> conf = new HashMap<String, Object>();
        /**
         * default tick tuple freq: 5 min
         */
        conf.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS,
                com.htsc.zl.app.log.util.Configuration
                        .getInteger("topology.tick.tuple.freq.secs"));
        return conf;
    }

分享到:
评论

相关推荐

    Storm中spout和bolt之间发送和接收数据的java源代码实例

    Storm中spout和bolt之间发送和接收数据的java源代码实例

    storm 示例demo

    import backtype.storm.tuple.Tuple; import backtype.storm.tuple.Values; public class WordNormalizer extends BaseBasicBolt { public void cleanup() {} /** * The bolt will receive the line from the ...

    第一个Storm应用

    Spout已经成功读取文件并把每一行作为一个tuple(在Storm数据以tuple的形式传递)发射过来,我们这里需要创建两个bolt分别来负责解析每一行和对单词计数。 Bolt中最重要的是execute方法,每当一个tuple传过来时它便...

    storm记录级容错.docx

    storm允许用户在spout中发射一个新的源tuple时为其指定一个message id, 这个message id可以是任意的object对象。多个源tuple可以共用一个message id,表示这多个源 tuple对用户来说是同一个消息单元。storm中记录级...

    storm-cassandra:Storm Cassandra集成

    Storm Cassandra集成通过提供一个通用且可配置的backtype.storm.Bolt实现将Storm和Cassandra集成, backtype.storm.Bolt实现将Storm Tuple对象写入Cassandra Column Family。 如何将Storm Tuple数据写入Cassandra是...

    storm-redis:Storm Bolt 状态管理

    第一个是处理消息重放的Spout 部分,第二个是管理主要处理中间状态的Bolt 部分。 ####脱粒机####卡夫卡用作喷口的数据源。 这使得重播消息变得容易和方便。 并且使用 kafka 不需要(拓扑的)喷口自己跟踪消息。 ...

    WIN版 罗技新版BOLT 配对驱动

    WIN版 罗技新版BOLT 配对驱动

    photon bolt网络插件

    photon bolt网络插件

    Bolt 1.4.4.unitypackage

    这是一个第三方开发的Unity可视化编程插件的最新版本Bolt 1.4.4,如果你想做2019版Unity上安装Bolt,劝你还是选择这个1.4.4版本,之前的版本(测试过Bolt1.4.0)可能都会出现错误提示,如:Library\PackageCache\...

    Bolt:CSRF扫描仪-源码

    螺栓笨拙的CSRF扫描仪重要的Bolt处于测试的Beta阶段,这意味着可能存在错误。 不鼓励使用此工具。 欢迎提出请求和问题。 如果您对此仓库感兴趣,我也建议您将它放在监视中。工作流程爬行Bolt将目标网站爬网到指定的...

    Storm Real-time Processing Cookbook实例代码

    Storm is a distributed, reliable, fault-tolerant system for ... You can imagine a Storm cluster as a chain of bolt components that each make some kind of transformation on the data exposed by the spout.

    Bolt1.2.3.unitypackage

    Bolt1.2.3,2018年最新的版本,可以完美运行在5.x版本和2017版本上面

    流式大数据处理的三种框架:Storm,Spark和Samza

    一个拓扑中包括spout和bolt两种角色,其中spout发送消息,负责将数据流以tuple元组的形式发送出去;而bolt则负责转换这些数据流,在bolt中可以完成计算、过滤等操作,bolt自身也可以随机将数据发送给其他bolt。由...

    storm-bolt-of-death:一个Apache Storm拓扑,根据设计,它将在运行时触发故障

    死亡风暴 ... bolt-of-death-A2 &lt;&lt;&lt; branch A | wordSpout -----+ | +-----&gt; noop-B1 &lt;&lt;&lt; branch B 如果启用了拓扑的kill开关(默认情况下,请参见下文,请参见下文),那么dea

    Getting Started with Storm

    Storm is a distributed, reliable, fault-tolerant system for ... You can imagine a Storm cluster as a chain of bolt components that each make some kind of transformation on the data exposed by the spout.

    BOLT引擎.chm

    bolt chm 帮助文档 官方只有网页版的。我把它制作为 windows的帮助文档

    Bolt 1.4.4.unitypackage_.zip

    这是一个第三方开发的Unity可视化编程插件的最新版本Bolt 1.4.4,如果你想做2019版Unity上安装Bolt,劝你还是选择这个1.4.4版本,之前的版本(测试过Bolt1.4.0)可能都会出现错误提示,如:Library\PackageCache\...

    storm demo

    代码参考传智播客课程编写,演示了如何使用storm的spout,bolt,Topology

    Storm Real-time Processing Cookbook

    Storm is a distributed, reliable, fault-tolerant system for ... You can imagine a Storm cluster as a chain of bolt components that each make some kind of transformation on the data exposed by the spout.

    Unity可视化编程插件Bolt最新版1.4.13

    Unity可视化编程插件Bolt最新版1.4.13 Unity可视化编程插件Bolt最新版1.4.13 Unity可视化编程插件Bolt最新版1.4.13

Global site tag (gtag.js) - Google Analytics