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.
