Good article with handful explanations and pictures! I have some questions: 1. If you are emmmiting the data on streams via collector.emit("streamId1", values), collector.emit("streamId2", values) how do you get your data in the public void execute(TupleWindow inputWindow)? The nputWindow.get() doesn't have a parameter StreamId? 2. In the above context, does the inputWindow contain data for all the streams emmited to it? Can you get them, via for (Tuple tuple : tuplesInWindow) { tuple.getValue( streamId1, 0); } I look forward for your answers? Regards, florin ... View more