Re: AW: Is watermark used by joining two streams

2017-07-31 Thread G.S.Vijay Raajaa
gt;>>> Vijay Raajaa GS >>>> >>>> On Jul 31, 2017 1:14 AM, "wei" wrote: >>>> >>>> Hello Fabian, >>>> >>>> >>>> >>>> thank you for your answer! >>>> >>>> >>>

Re: AW: Is watermark used by joining two streams

2017-07-31 Thread Fabian Hueske
gt;> >>> On Jul 31, 2017 1:14 AM, "wei" wrote: >>> >>> Hello Fabian, >>> >>> >>> >>> thank you for your answer! >>> >>> >>> >>> Does it mean that the operator will wai

Re: AW: Is watermark used by joining two streams

2017-07-31 Thread G.S.Vijay Raajaa
>> Hello Fabian, >> >> >> >> thank you for your answer! >> >> >> >> Does it mean that the operator will wait until get two watermarks from >> the input streams and emits then the “slower” watermark? >> >> >>

Re: AW: Is watermark used by joining two streams

2017-07-31 Thread Fabian Hueske
Hueske [mailto:fhue...@gmail.com] > *Gesendet:* Sunday, July 30, 2017 11:17 AM > *An:* xie wei > *Cc:* user > *Betreff:* Re: Is watermark used by joining two streams > > > > Periodic and punctuated watermarks only differ in the way that they are > generated. Afterwards th

Re: AW: Is watermark used by joining two streams

2017-07-30 Thread G.S.Vijay Raajaa
ueske [mailto:fhue...@gmail.com] *Gesendet:* Sunday, July 30, 2017 11:17 AM *An:* xie wei *Cc:* user *Betreff:* Re: Is watermark used by joining two streams Periodic and punctuated watermarks only differ in the way that they are generated. Afterwards they are treated the same. An operator with two input s

AW: Is watermark used by joining two streams

2017-07-30 Thread wei
: xie wei Cc: user Betreff: Re: Is watermark used by joining two streams Periodic and punctuated watermarks only differ in the way that they are generated. Afterwards they are treated the same. An operator with two input streams will always sync its own watermarks to the watermarks of both input

Re: Is watermark used by joining two streams

2017-07-30 Thread Fabian Hueske
Periodic and punctuated watermarks only differ in the way that they are generated. Afterwards they are treated the same. An operator with two input streams will always sync its own watermarks to the watermarks of both input streams, i.e., to the "slower" watermark of both inputs. So if the left inp

Is watermark used by joining two streams

2017-07-28 Thread xie wei
Hello, i want to join two streams based on event time window, every stream has its own watermark, one has priodic watermark and the other has punctuated watermark. are the watermarks used to trigger the join? if yes, which one and how is it used? Thank you and best regards Wei