Executing the implementation
Enough with the code, let's get on with the demo! We start the topology using the main method of the FinancialAnalyticsTopology class. For a better demo, we introduce random prices between zero and one hundred. (Refer back to the Emitter code.)
Once the topology is started, you will see the following output:
2014-02-16 09:47:15,479-0500 | INFO [Thread-18] DefaultCoordinator.initializeTransaction(24) | Initializing Transaction [1615] 2014-02-16 09:47:15,482-0500 | INFO [Thread-22] DruidState.commit(28) | Committing partition [0] of batch [1615] 2014-02-16 09:47:15,484-0500 | INFO [Thread-22] StormFirehose.sendMessages(82) | Beginning commit to Druid. [7996] messages, unlocking [START] 2014-02-16 09:47:15,511-0500 | INFO ...
Get Storm Blueprints: Patterns for Distributed Real-time Computation now with the O’Reilly learning platform.
O’Reilly members experience books, live events, courses curated by job role, and more from O’Reilly and nearly 200 top publishers.
