在storm中使用實時儲存會對效能帶來很大的考驗,所以在很多場景中還是使用定時儲存;而且storm自帶了定時功能,使用方式如下:
首先在topo中的config中定義乙個通訊時間,定義方式如下:
conf.put(config.topology_tick_tuple_freq_secs, 60);
設定這個屬性以後,就會每隔60秒傳送一次心跳資訊到所有的bolt中,也就是每隔60秒在所有的bolt中都會收到心跳tuple,所以在bolt中的execute方法中可以這樣處理:
if (tuple.getsourcecomponent().equals(constants.system_component_id)
&& tuple.getsourcestreamid().equals(
constants.system_tick_stream_id))
}else
在C 中使用儲存過程
本文以sql server2000為例,示例資料庫為china,表為test,來說明以c 中使用sql儲存過程的方法。一 test表的建立sql語句 create table test55 uid int identity 1,1 class1 varchar 20 class2 varchar 2...
在C 中使用儲存過程
在c 中使用儲存過程 本文以sql server2000為例,示例資料庫為china,表為test,來說明以c 中使用sql儲存過程的方法。一 test表的建立sql語句 create table test55 uid int identity 1,1 class1 varchar 20 class...
在C 中使用儲存過程
2007年05月23日 23 42 00 本文以sql server2000為例,示例資料庫為china,表為test,來說明以c 中使用sql儲存過程的方法。一 test表的建立sql語句 create table test55 uid int identity 1,1 class1 varcha...