Instead of specific spouts, there are basic spouts that can have the fields and stream id's configured by each topology, along with custom configuration keys (in case of more than one spout), and of course custom parsers.
Added the symbol field to the Quote class
StockPriceSpout now extends the AbstractSpout, with dynamic field declaration, configuration of quote fetcher, symbols, etc. Possibility to fetch multiple quotes, using a queue to store quotes, fetch new quotes when empty queue.
TradeQuoteSimulatedSpout has a very poor "simulation" of quotes. The spout now extends the StockPriceSpout since only the emission of tuples differs.
Removed unused imports.
Removed unused imports.
Moved the creation of the index of files from the initialize method
Modified the AdEventSpout to conform with the FileSpout interface
Modified the TwitterStreamSpout to conform with the standard for spouts
Removed unused imports
Spout cleanup, generalization of spout functionality
Introduction of parsers to work in conjunction with spouts
Modified the parser interface to enable it to return more than one tuple per parse, e.g. a single line can produce more than one tuple.
StreamValues is just an enclosure for Values with an additional field for the stream ID
Modification of the spouts to conform with new parser interface
Replaced the AdEventSpout by a parser
Added an spout for Kafka with ability to parse strings
Added the topology context to the attributes
Check to see if the queue is empty, then fetch new quotes. Still needs to keep track of last quotes downloaded do avoid emitting repeated quotes.
Added JCommander and GSON dependencies