storm模块结构和api对应关系

storm模块结构和api对应关系

 (2012-02-28 23:00:16)

转载▼

标签：  杂谈

TopologyContext context， 记录了component和task的对应关系

 

一个component（如图）包含了若干task，每一个task有一个全局唯一的id， 这个id用于定位zmq的目标和来源

 

context提供了id->task, task->id的映射关系

 

            context.getThisTaskId();

            context.getComponentId(context.getThisTaskId()); //获得指定taskid的componentid（String）

            context.getThisComponentId() //获得componentid（String）

            context.getComponentTasks("String") //制定componentid, 获得对应taskid的list。

 

 

json:{"task->component":{

"1":"count",

"2":"count",

"3":"count",

"4":"count",

"5":"count",

"6":"count",

"7":"count",

"8":"count",

"9":"count",

"10":"count",

"11":"count",

"12":"count",

"13":"__acker",

"14":"split",

"15":"split",

"16":"split",

"17":"split",

"18":"split",

"19":"split",

"20":"split",

"21":"split",

"22":"spout",

"23":"spout",

"24":"spout"},

"taskid":19

}