Join internally calls multiReduce. You can browse the code and see how its
done. For "windowed join" the last paragraph in this document is the way to
go..Trident API Overview
| |
| | | | | | | |
| Trident API OverviewToggle navigation Apache Storm Home About About
Contributing Bylaws Download Documentation News Trident ... |
| |
| View on storm.apache.org | Preview by Yahoo |
| |
| |
-Nikhil
On Tuesday, June 9, 2015 5:55 PM, Дмитрий Калашников
<[email protected]> wrote:
Hello,
My goal is, using Trident API, joining by key of several streams with different
number of output fields. In one case streams are come from different kafka
spouts and in another case topology with single spout is forked. Since joining
is required not only within a batch, join operation is not helpful. I saw
mentioning of multiReduce but I cannot figure out how to use it
Any suggestion how to handle this?
Regards,Dmitry Kalashnikov.
