storm_组件

àì夳堔傛蜴生んèń 2022-04-11 13:18 280阅读 0赞

1. IComponent接口

有两个方法：

**public** **class** component **implements** IComponent\{

@Override

**public** **void** declareOutputFields(OutputFieldsDeclarer arg0) \{

@Override

**public** Map<String, Object> getComponentConfiguration() \{

**return** **null**;

![20181206155712976.png][]

2. ISpout接口

有七个方法：

**public** **class** MySpout **implements** ISpout\{

@Override

**public** **void** ack(Object arg0) \{

@Override

**public** **void** activate() \{

@Override

**public** **void** close() \{

@Override

**public** **void** deactivate() \{

@Override

**public** **void** fail(Object arg0) \{

@Override

**public** **void** nextTuple() \{

@Override

**public** **void** open(Map conf, TopologyContext context, SpoutOutputCollector collector) \{

![20181206155733470.png][]

![20181206155736852.png][]

![20181206155740410.png][]

![20181206155744699.png][]

![20181206155748247.png][]

3. IBolt接口

共有三个方法：

**public** **class** MyBolt **implements** IBolt\{

@Override

**public** **void** cleanup() \{

@Override

**public** **void** execute(Tuple tuple) \{

@Override

**public** **void** prepare(Map conf, TopologyContext context, OutputCollector collector) \{

![20181206155806915.png][]

![20181206155810244.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70][]

![20181206155819586.png][]

![20181206155824363.png][]

4. 事务接口

IPartitionedTransactionalSpout接口继承自IComponent接口。

![20181206155845726.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 1][]

![20181206155901241.png][]

IOpaquePartitionedTransactionalSpout接口继承自IComponent接口。

![20181206155914844.png][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 2][]

ITransactionalSpout

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 3][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 4][]

![20181206155951576.png][]

![20181206160001141.png][]

5. 组件之关系

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 5][]

[20181206155712976.png]: /images/20220411/bfec43bb90d343c3b5a46583ddf71dc6.png
[20181206155733470.png]: /images/20220411/2337811b44c748f3a186fec1b11802ef.png
[20181206155736852.png]: /images/20220411/d023ed7579d74116b048f08b247d53f0.png
[20181206155740410.png]: /images/20220411/1d5f5d68401749458308a0617b19e8c5.png
[20181206155744699.png]: /images/20220411/22d3980d45a64840843845412237021c.png
[20181206155748247.png]: /images/20220411/2accac7d9a68443ab45deae2a39513ba.png
[20181206155806915.png]: /images/20220411/beb5b6970a2d4ab9846c54ab71f2045d.png
[20181206155810244.png]: /images/20220411/7091159eae204e29ac03d6fa217e73d6.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70]: /images/20220411/7b540921b64742a7ad7eb9efe721c794.png
[20181206155819586.png]: /images/20220411/80431a2a4594494cae895f5b68ad0067.png
[20181206155824363.png]: /images/20220411/30f633d5c9204af9953926e229a2a1ba.png
[20181206155845726.png]: /images/20220411/3ea4ec0ba81e4764896ddcbeb2860c90.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 1]: /images/20220411/0083c2c748b8488caa673a36d1a21048.png
[20181206155901241.png]: /images/20220411/edec5d0159844377b51fb06644722bf0.png
[20181206155914844.png]: /images/20220411/05e70c3fa27a4e05849a38e4e12903c9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 2]: /images/20220411/a5e6f43422ea440bb103a56e0c08313e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 3]: /images/20220411/7ebded97904a4a8caf6a68affa845c19.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 4]: /images/20220411/268592b156a0498484c030cff5f6f6b2.png
[20181206155951576.png]: /images/20220411/e8ea9f546e134656a3622529419c191a.png
[20181206160001141.png]: /images/20220411/ec6a02fff31c4251bc3c9a968641b148.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxNjY1MzU2_size_16_color_FFFFFF_t_70 5]: /images/20220411/44ddcc3037324f02b70043e2d6c02ac9.png