Databases Reference
In-Depth Information
builder
.
setSpout
(
"read-feed"
,
new
UsersNavigationSpout
(),
3
);
builder
.
setBolt
(
"get-categ"
,
new
GetCategoryBolt
(),
3
)
.
shuffleGrouping
(
"read-feed"
);
builder
.
setBolt
(
"user-history"
,
new
UserHistoryBolt
(),
5
)
.
fieldsGrouping
(
"get-categ"
,
new
Fields
(
"user"
));
builder
.
setBolt
(
"product-categ-counter"
,
new
ProductCategoriesCounterBolt
(),
5
)
.
fieldsGrouping
(
"user-history"
,
new
Fields
(
"product"
));
builder
.
setBolt
(
"news-notifier"
,
new
NewsNotifierBolt
(),
5
)
.
shuffleGrouping
(
"product-categ-counter"
);
Config
conf
=
new
Config
();
conf
.
setDebug
(
true
);
conf
.
put
(
"redis-host"
,
REDIS_HOST
);
conf
.
put
(
"redis-port"
,
REDIS_PORT
);
conf
.
put
(
"webserver"
,
WEBSERVER
);
LocalCluster
cluster
=
new
LocalCluster
();
cluster
.
submitTopology
(
"analytics"
,
conf
,
builder
.
createTopology
());
}
}
Figure 6-6. Storm topology
