240 投稿
storm
收录了10篇文章 · 30人关注
  • Storm的可靠性与ack机制

    无论是实时处理还是离线处理，都会遇到一个不可避免的问题是，失败任务如何重做？Storm提供了一个ack机制。首先来看一下ISpout接口的方法。...

    orisonchan 3 3
  • Resize,w 360,h 240
    JStorm运行依赖storm-core的任务：依赖冲突与解决

    发表于个人博客，原文发表地址。JStorm虽然用Java语言重新实现了storm，但是对于storm的external部分并未实现。现在在JSt...

    峰巢 1 3
  • Flux模式开发提交JStorm任务

    原文地址查看本文原址 传统法式采用提交jar包的方式运行topology，一旦我们需要改变拓扑里头的相应配置，我们就必须重新编译和打包，而Flu...

    峰巢 1 6
  • Resize,w 360,h 240
    storm学习第二天QA（flume-kafa-storm-redis 运行）

    主要内容：解决部署运行遇到问题 Q1 为什么storm 部署的任务没有日志 也就是说没有采集任何数据 A: A:step1 【知识点补充】 em...

    0.1 小王同学加油 0 2
  • storm启动问题

    问题描述：网页中登陆storm 8080端口 发现supervisor的数目与自己已经启动的supervisor个数不一致。但是各个节点上sup...

    孙睿888 0 0
  • Storm坑集锦

    KafkaSpout 1.poutConfig继承KafkaConfig，可以通过SpoutConfig设置kafkaSpout基本属性spou...

    Magia 0 0
  • Resize,w 360,h 240
    storm_集群调度原理

    前言： 因为前面讲个那3个demo都是local topology运行，所以对storm集群状态下的工作情况没有介绍太多，写面我们来详细描述一下...

    hello_coke 0 3
  • storm_定时机制tick使用

    背景： 我们知道在java中可以有最少3钟方式来实现定时任务：1、普通thread(里面使用while循环以及sleep) 2、Timer和Ti...

    hello_coke 0 2
  • Resize,w 360,h 240
    storm_Trident

    简介： Trident 是 Storm 的一种高度抽象的实时计算模型，它可以将高吞吐量（每秒百万级）数据输入、有状态的流式处理与低延时的分布式查...

    hello_coke 0 1
  • Resize,w 360,h 240
    storm_初识

    简介: Storm是一个分布式的，可靠的，容错的数据流处理系统。它会把工作任务委托给不同类型的组件，每个组件负责处理一项简单特定的任务。Stor...

    hello_coke 0 3

专题公告

storm学习