storm使用範例

2021-07-11 17:18:29 字數 1223 閱讀 4227

此案例實現從陣列中隨機讀取字串傳送到bolt,bolt將字串變成大寫傳送到下乙個bolt,bolt將字串加上時間戳然後寫到檔案中

public class randomwordspout extends baserichspout ;

/** 初始化方法,在spout元件例項化時呼叫一次

*/@override

public void open(map map, topologycontext tc, spoutoutputcollector collector)

//不斷地往下乙個元件傳送tuple訊息

//這裡面是該spout元件的核心邏輯

@override

public void nexttuple()

//宣告本spout元件傳送出去的tuple中的資料的欄位名

@override

public void declareoutputfields(outputfieldsdeclarer declarer)

}

public class handlerbolt extends basebasicbolt 

//宣告該bolt元件要發出去的tuple的字段

@override

public void declareoutputfields(outputfieldsdeclarer declare)

}

public class morebolt extends basebasicbolt  catch (ioexception e) 

}//該bolt元件的核心處理邏輯

//每收到乙個tuple訊息,就會被呼叫一次

@override

public void execute(tuple tuple, basicoutputcollector collector) catch (ioexception e)

} //本bolt已經不需要傳送tuple訊息到下乙個元件,所以不需要再宣告tuple的字段

@override

public void declareoutputfields(outputfieldsdeclarer declare)

}

public class topomain 

}

游標使用範例

declare colname varchar 100 declare cu cname cursor for select name from syscolumns where id object id sh data 1 ok open cu cname fetch next from cu c...

chmod使用範例

chmod 750 a.out 改變 a.out的許可權為750 chmod a x a.out 對所有使用者增加 a.out的執行許可權,a all 表示所有使用者 chmod u rwx a.out 設定屬主的許可權為讀 寫和執行,u user 表示屬主使用者 chmod g rw a.out ...

cmake使用範例

cmake作為一款跨平台的專案構建工具,其使用範圍已經越來越廣,本文以實際專案為例,展示乙個使用該編譯工具的模板。希望我們都能在這些高效的工具幫助下都享受程式設計的樂趣。project src libs modules includes build bin cmakelists 根目錄下cmakel...