How a Storm bolt can subscribe to the __tick stream.
Configuration can be applied to the entire topology or any component individually. For example, to enable tick tuples for a singe Bolt do
Config boltConfig = new Config();
boltConfig.put(Config.TOPOLOGY_TICK_TUPLE_FREQ_SECS, 30);
builder.setBolt("my-awesome-bolt", new MyAwesomeBolt()).addConfigurations(boltConfig );
Written by Jamie Rothfeder
Related protips
Have a fresh tip? Share with Coderwall community!
Post
Post a tip
Best
#Storm
Authors
Sponsored by #native_company# — Learn More
#native_title#
#native_desc#