April 2015
Beginner to intermediate
194 pages
4h 18m
English
Storm topology can be configured by the TopologyBuilder class by creating spouts and bolts, and then by submitting the topology.
Some implementations of spouts are available in Storm, such as BaseRichSpout, ClojureSpout, DRPCSpout, FeederSpout, FixedTupleSpout, MasterBatchCoordinator, RichShellSpout, RichSpoutBatchTriggerer, ShellSpout, SpoutTracker, TestPlannerSpout, TestWordSpout, and TransactionalSpoutCoordinator.
We can write a custom bolts by extending any of the aforementioned classes or implementing the ISpout interface:
public class NumberSpout extends BaseRichSpout { private SpoutOutputCollector collector; private static int currentNumber = 1; @Override public void open( Map conf, TopologyContext context, ...Read now
Unlock full access