org.gramar.storm.gramar:walkthrough
Differences
This shows you the differences between two versions of the page.
| Both sides previous revision Previous revision | Next revision Both sides next revision | ||
|
org.gramar.storm.gramar:walkthrough [2016/08/12 14:28] chrisgerken |
org.gramar.storm.gramar:walkthrough [2016/08/12 14:29] chrisgerken |
||
|---|---|---|---|
| Line 229: | Line 229: | ||
| Other observations include: | Other observations include: | ||
| - | * For each bolt and spout, there is a generated interface that defines the bolt or spout behavior that might be needed by the business logic. | + | * For each bolt and spout, there is a generated interface that defines the bolt or spout behavior that might be needed by the business logic. |
| - | * Each interface will have an ack() and fail() method, although their use for bolts and spouts is, of course, different. | + | * Each interface will have an ack() and fail() method, although their use for bolts and spouts is, of course, different. |
| - | * Each interface will define emit methods for each stream onto which the spout or bolt emits | + | * Each interface will define emit methods for each stream onto which the spout or bolt emits |
| - | * Each bolt helper class has a method for each stream from which the bolt reads. Each of those methods takes the type of bean that defines the stream tuple shape and a reference to the interface for the bolt. Use the interface reference to emit tuples, to ack and to fail. | + | * Each bolt helper class has a method for each stream from which the bolt reads. Each of those methods takes the type of bean that defines the stream tuple shape and a reference to the interface for the bolt. Use the interface reference to emit tuples, to ack and to fail. |
| - | * Each spout helper class has a nextTuples() method that takes a reference to the spout's interface. Use this interface to emit tuples, either with a message ID for reliable topologies or without a message ID for unreliable topologies. | + | * Each spout helper class has a nextTuples() method that takes a reference to the spout's interface. Use this interface to emit tuples, either with a message ID for reliable topologies or without a message ID for unreliable topologies. |
org.gramar.storm.gramar/walkthrough.txt · Last modified: 2016/08/13 11:41 by chrisgerken
Page Tools
Except where otherwise noted, content on this wiki is licensed under the following license: CC Attribution-Share Alike 4.0 International
