Skip to content
This repository has been archived by the owner on Jun 16, 2023. It is now read-only.

IBasicBolt IRichBolt

Jump to bottom
longdafeng edited this page Oct 14, 2014 · 3 revisions

In fact, a lot of people using JStorm/Storm don't know the difference between IBasicBolt and IRichBolt. We suggest using IBasicBolt as much as possible.

There are two interfaces in IRichBolt:

  • emit(String streamId, Tuple anchor, List tuple), -- the next component's tasks will send Ack response to Acker.
  • emit(String streamId, List tuple), -- the next component's tasks won't send Ack response to Acker
IBasicBolt will wrapper the first interface.

IBatchBolt will wrapper the second interface.

Clone this wiki locally