HI
i didn't get it , can you please clarify with an example in case each of
operation A and B emit multiple elements.
On Wed, Nov 30, 2016 at 3:34 PM, Kostas Kloudas <k.klou...@data-artisans.com
> wrote:
> Hi Janardhan,
>
> After the first windowing operation, the timestamp of the emitted element
> for each window
> will be the (endOfWindow - 1). So in your case, in the second windowing
> operation (window by 5)
> there will be at most one element per window.
>
> I hope this answers your question.
>
> Kostas
>
> > On Nov 29, 2016, at 7:25 PM, Janardhan Reddy <
> janardhan.re...@olacabs.com> wrote:
> >
> > Hi,
> >
> > Suppose we have a stream like this.
> >
> > someStream.timeWindow(Time.minutes(15)).apply {
> > operation A
> >
> > }.keyby("....").window(TumblingEventTimeWindows.ofseconds(5)).apply {
> >
> > operation B
> >
> > }.keyby("....").window(TumblingEventTimeWindows.ofseconds(5)).apply {
> >
> > operation C
> >
> > }
> >
> > Say operation A emits some elements => it would be emitted every 15
> minutes.
> >
> > How would be the window behaviour of where operation B takes place if
> operation A takes more than 5 seconds with ingestion Time characteristic.
> Similarly how would windows behave near operation C if operation B takes
> more than 5 seconds.
> >
> >
> > Thanks
> > Janardhan
>
>
