I am afraid there is no way to do that. At least I could not think of a way to do it.
Maybe @aljoscha cc'ed could help here. On 29/05/2020 13:25, Sudan S wrote: > Hi, > > I have a usecase where i want to join two streams. I am using coGroup > for this > > KeyBuilder leftKey = new > KeyBuilder(jobConfiguration.getConnectStream().getLeftKey()); > KeyBuilder rightKey = new > KeyBuilder(jobConfiguration.getConnectStream().getRightKey()); > leftSource.coGroup(rightSource).where(leftKey).equalTo(rightKey) > .window(...) .apply() .addSink(*...*); > For apply method i'm using RichCoGroupFunction. I am not able to find access > to Window object similar to > ProcessWindowFunction. I would be interested in extracting start time, end > time and key of the window > Plz suggest if there are any alternatives > > ------------------------------------------------------------------------ > /"The information contained in this e-mail and any accompanying > documents may contain information that is confidential or otherwise > protected from disclosure. If you are not the intended recipient of > this message, or if this message has been addressed to you in error, > please immediately alert the sender by replying to this e-mail and > then delete this message, including any attachments. Any > dissemination, distribution or other use of the contents of this > message by anyone other than the intended recipient is strictly > prohibited. All messages sent to and from this e-mail address may be > monitored as permitted by applicable law and regulations to ensure > compliance with our internal policies and to protect our business."/ > ------------------------------------------------------------------------
signature.asc
Description: OpenPGP digital signature
