作者:Jack47 PS：如果喜歡我寫的文章，歡迎關注我的微信公眾賬號程序員傑克，兩邊的文章會同步，也可以添加我的RSS訂閱源。 內容簡介# 本文是Storm系列之一，介紹了Storm的起源，S ...

作者: 大圓那些事 | 文章可以轉載，請以超鏈接形式標明文章原始出處和作者信息 網址: http://www.cnblogs.com/panfeng412/archive/2012/11/30/ho ...

本文首先介紹了Storm的基本概念和數據流模型，然后結合一個典型應用場景來說明Storm支持Topology之間數據流訂閱的必要性，最后對比了Storm與另一個流處理系統在數據流模型上的區別之處。 ...

Storm中Spout用於讀取並向計算拓撲中發送數據源，最近在調試一個topology時遇到了系統qps低，處理速度達不到要求的問題，經過排查后發現是由於對Spout的使用模式不當導致的多線程同步等待 ...

package guavacache; import java.util.concurrent.ExecutionException; import java.util.concurrent.T ...

一、配置開發環境 storm有兩種操作模式: 本地模式和遠程模式。使用本地模式的時候，你可以在你的本地機器上開發測試你的topology， 一切都在你的本地機器上模擬出來; 用遠程模式的時候你提交的 ...

Apache Storm簡介 Storm是一個分布式的，可靠的，容錯的數據流處理系統。Storm集群的輸入流由一個被稱作spout的組件管理，spout把數據傳遞給bolt， bolt要么把數據保存 ...

基於0.93版本的Storm SpoutConfig繼承自KafkaConfig。由於SpoutConfig和KafkaConfig所有的instance field全是public, ...

流聚合（stream join）是指將具有共同元組（tuple）字段的數據流（兩個或者多個）聚合形成一個新的數據流的過程。 從定義上看，流聚合和SQL中表的聚合（table join）很像，但是二者 ...

最近在使用storm做一個實時計算的項目,Spout需要從 KAFKA 集群中讀取數據，為了提高開發效率，直接使用了Storm提供的KAFKA插件。今天抽空看了一下KafkaSpout的源 ...