Fwd: Storm - Streams Api - Window join for event-time processing

[Rúben Garcia <ru...@gmail.com>]

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