Shulou(Shulou.com)05/31 Report--

This article mainly introduces "what is the difference between BaseBasicBolt and BaseRichBolt". In daily operation, I believe many people have doubts about the difference between BaseBasicBolt and BaseRichBolt. The editor consulted all kinds of materials and sorted out simple and easy-to-use methods of operation. I hope it will be helpful to answer the doubts of "what is the difference between BaseBasicBolt and BaseRichBolt?" Next, please follow the editor to study!

Stream grouping:

Shuffle Grouping: random grouping, randomly distributing the tuple in the stream, and ensuring that each bolt can receive roughly the same number of tuple.

Fields Grouping: field grouping, such as grouping by userid, tuple with the same userid will be distributed to a task in the same bolt, while different userid will be assigned to the task in a different bolt.

All Grouping: broadcast packet, for each tuple, all bolt are received.

Global Grouping: global grouping, which sends the tuple generated by all source instances to a single target instance (specifically, the task with the lowest ID).

Non Grouping: no grouping, which means stream doesn't care who will receive its tuple. At present, this grouping has the same effect as Shuffle grouping, but one difference is that storm will put the bolt into the same thread of the bolt subscriber to execute.

Direct Grouping: direct grouping, which is a special grouping method in which the source determines which component will receive packets from the tuple. Only message flows declared as Direct Stream can declare this grouping method. And the tuple must be transmitted using the emitDirect method.

Local or shuffle grouping: if the target bolt has one or more task in the same working process, the tuple will be randomly generated to these tasks. Otherwise, it is consistent with the normal Shuffle Grouping behavior.

The difference between BaseBasicBolt and BaseRichBolt

BaseRichBoltYou must-and are able to- manually ack () an incoming tuple.Can be used to delay acking a tuple, e.g. For algorithms that need to work across multiple incoming tuples.BaseBasicBoltAuto-acks the incoming tuple at the end of its execute () method.These bolts are typically simple functions or filters. At this point, the study on "what is the difference between BaseBasicBolt and BaseRichBolt" is over. I hope to be able to solve your doubts. The collocation of theory and practice can better help you learn, go and try it! If you want to continue to learn more related knowledge, please continue to follow the website, the editor will continue to work hard to bring you more practical articles!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.