O'Reilly logo

Storm Blueprints: Patterns for Distributed Real-time Computation by Brian O'Neill, P. Taylor Goetz

Stay ahead with the world's most comprehensive technology and business learning platform.

With Safari, you learn the way you learn best. Get unlimited access to videos, live online training, learning paths, books, tutorials, and more.

Start Free Trial

No credit card required

The topology

With the architectural concepts in place, let's return to the use case. To keep things focused on the integration, we will keep the topology simple. The following diagram depicts the topology:

The topology

The FIX Spout emits tuples containing simple FIX messages. Then the filter checks the type of the message, filtering for stock orders that contain pricing information. Then, those filtered tuples flow to the DruidState object, which is the bridge to Druid.

The code for this simple topology is as follows:

public class FinancialAnalyticsTopology { public static StormTopology buildTopology() { TridentTopology topology = new TridentTopology(); FixEventSpout ...

With Safari, you learn the way you learn best. Get unlimited access to videos, live online training, learning paths, books, interactive tutorials, and more.

Start Free Trial

No credit card required