Building a Trident topology
Trident gives a batching edge to the Storm computation. It lets developers use the abstracted layer for computations over the Storm framework, giving the advantage of stateful processing with high throughput for distributed queries.
Well the architecture of Trident is the same as Storm; it's built on top of Storm to abstract a layer that adds the functionality of micro-batching and execution of SQL-like functions on top of Storm.
For the sake of analogy, one can say that Trident is a lot like Pig for batch processing in terms of concept. It has support for joins, aggregates, grouping, filters, functions, and so on.
Trident has basic batch processing features such as consistent processing and execution of process logic over the tuples exactly once.
Now to understand Trident and its working; let's look at a simple example.
The example we have picked up would achieve the following:
Word count over the stream of sentences (a standard Storm word count kind of topology)
A...
