I saw this hint about window joining. However I can't find any example how to do that and therefore this idea was avoided. Could you provide example of window joining for Trident?
2015-06-11 6:55 GMT+03:00 Nikhil Singh <[email protected]>: > 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 > <https://storm.apache.org/documentation/Trident-API-Overview.html> > > > [image: image] > <https://storm.apache.org/documentation/Trident-API-Overview.html> > > > > > > Trident API Overview > <https://storm.apache.org/documentation/Trident-API-Overview.html> > Toggle navigation Apache Storm Home About About Contributing Bylaws > Download Documentation News Trident ... > View on storm.apache.org > <https://storm.apache.org/documentation/Trident-API-Overview.html> > 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. > > >
