Hi,
I'm a newbie in many parts of Storm, and I'm 'fighting' against the
aggregation with Trident. I'm using the following topology:
topology.newStream("tweets", spout)
.each(new Fields("tweet"), new Analyse(), new Fields("analysis"))
.aggregate(new Fields("analysis"), new AggregateAnalysis(), new
Fields("aggregation"))
.each(new Fields("aggregation"), new PrintFilter())
Basically I'm trying to aggregate the sentiment analysis over a batch of
tweets. The spout is a FixedBatchSpout. The functions and the aggregator
look to work fine, the stream is being processed as I expected. But the
problem is it does not stop to process the batch. Reading the documentation
about ReducerAggregator my implementation looks to do whjat I expect. But
still, I can get it aggregating the whole batch.
Anybody has any idea what I'm doing wrong?
All help would be appreciated.
Cheers,
--
Sergio Fernández
Partner Technology Manager
Redlink GmbH
m: +43 6602747925
e: [email protected]
w: http://redlink.co
