Hello, I'm trying to develop an topology on Apache Storm base on Streams API (v2.2.0). One part of build the topology I have two PairStream<Long, Object> (I'm working with mapped objects instead of Tuple) that were formed via mapToPair operation. The key of PairStream is an timestamp truncated to Seconds because my data the only correlation that I have is with time.
This being said, when I'm joining two streams I make: mapToPairStream1 .window(TumblingWindow.of(....)) .join(mapToPairStream2) I know that TumblingWindows(and SlidingWindow) class has an method #withTimestampField(String fieldName). Somehow I really can't find a way to pass the filedName as the correct one of the object. Any suggestions? Thank you
