RE: STREAM SQL inner queries

2017-02-02 Thread Radu Tudoran
mail immediately and delete it! -Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Friday, February 03, 2017 12:15 AM To: dev@flink.apache.org Subject: Re: STREAM SQL inner queries Hi Radu, I think mostly processing time queries will fall into the category of que

Re: STREAM SQL inner queries

2017-02-02 Thread Fabian Hueske
sgericht Düsseldorf, HRB 56063, > > Geschäftsführer: Bo PENG, Wanzhou MENG, Lifang CHEN > > This e-mail and its attachments contain confidential information from > > HUAWEI, which is intended only for the person or entity whose address is > > listed above. Any use of the info

RE: STREAM SQL inner queries

2017-01-31 Thread Radu Tudoran
3:45 PM To: dev@flink.apache.org Subject: Re: STREAM SQL inner queries Hi, If the goal is that the materialized result of a streaming query should be equivalent to the result of a batch query on the materialized input, we need to update previously emitted data. Only appending to the already emitt

Re: STREAM SQL inner queries

2017-01-31 Thread Fabian Hueske
> > If this is the case as my assumption that I would say that SINGLE_ > > VALUE should be continuously updated as the stream on top of which is > > applied evolves. > > > > My 2cents (anyway - I think the discussion is very useful and > > hopefully applicable also

RE: STREAM SQL inner queries

2017-01-31 Thread Radu Tudoran
) is prohibited. If you receive this e-mail in error, please notify the sender by phone or email immediately and delete it! -Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Monday, January 30, 2017 8:39 PM To: dev@flink.apache.org Subject: Re: STREAM SQL inner que

Re: STREAM SQL inner queries

2017-01-30 Thread Fabian Hueske
k the discussion is very useful and hopefully > applicable also for other operators/scenarios that we are going to > implement) > > > > > -Original Message----- > From: Fabian Hueske [mailto:fhue...@gmail.com] > Sent: Monday, January 30, 2017 2:09 PM > To: dev@flink

RE: STREAM SQL inner queries

2017-01-30 Thread Radu Tudoran
we are going to implement) -Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Monday, January 30, 2017 2:09 PM To: dev@flink.apache.org Subject: Re: STREAM SQL inner queries Hi Radu, I think it is most important to get the semantics of a streaming query right. In my opin

Re: STREAM SQL inner queries

2017-01-30 Thread Fabian Hueske
ess is > listed above. Any use of the information contained herein in any way > (including, but not limited to, total or partial disclosure, reproduction, > or dissemination) by persons other than the intended recipient(s) is > prohibited. If you receive this e-mail in error, please notify

RE: STREAM SQL inner queries

2017-01-30 Thread Radu Tudoran
-mail in error, please notify the sender by phone or email immediately and delete it! -Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Monday, January 30, 2017 12:33 PM To: dev@flink.apache.org Subject: Re: STREAM SQL inner queries Hi Radu, I thought about your

Re: STREAM SQL inner queries

2017-01-30 Thread Fabian Hueske
ose address is >> listed above. Any use of the information contained herein in any way >> (including, but not limited to, total or partial disclosure, reproduction, >> or dissemination) by persons other than the intended recipient(s) is >> prohibited. If you receive this e-mail

Re: STREAM SQL inner queries

2017-01-27 Thread Fabian Hueske
ing, but not limited to, total or partial disclosure, reproduction, > or dissemination) by persons other than the intended recipient(s) is > prohibited. If you receive this e-mail in error, please notify the sender > by phone or email immediately and delete it! > > -Original Message---

RE: STREAM SQL inner queries

2017-01-27 Thread Radu Tudoran
---Original Message- From: Fabian Hueske [mailto:fhue...@gmail.com] Sent: Thursday, January 26, 2017 4:51 PM To: dev@flink.apache.org Subject: Re: STREAM SQL inner queries Hi everybody, thanks for the proposal Radu. If I understood it correctly, you are proposing a left join between a stream

Re: STREAM SQL inner queries

2017-01-26 Thread Fabian Hueske
utput as 100 is not > than 100) > > User2, 10-> Average is 55 and the output of the topology that > > implements the query is NULL (no output as 10 is not > than 55) > > User3, 40-> Average is 25 (10+40) and the output of the topology that > > impleme

Re: STREAM SQL inner queries

2017-01-26 Thread Xingcan
the query. Also, there is no need for a > window or buffering to implement the logic for assembling the results from > the inner query. > > > Best regards, > > -Original Message- > From: Shaoxuan Wang [mailto:wshaox...@gmail.com] > Sent: Thursday, January 26, 2017

RE: STREAM SQL inner queries

2017-01-26 Thread Radu Tudoran
e results from the inner query. Best regards, -Original Message- From: Shaoxuan Wang [mailto:wshaox...@gmail.com] Sent: Thursday, January 26, 2017 4:36 AM To: dev@flink.apache.org Subject: Re: STREAM SQL inner queries Hi Radu, Similar as the stream-stream join, this stream-stream inner

re: STREAM SQL inner queries

2017-01-25 Thread Zhangrucong
...@gmail.com] 发送时间: 2017年1月26日 11:36 收件人: dev@flink.apache.org 主题: Re: STREAM SQL inner queries Hi Radu, Similar as the stream-stream join, this stream-stream inner query does not seem to be well defined. It needs provide at least some kind of window bounds to complete the streaming SQL semantics. If

Re: STREAM SQL inner queries

2017-01-25 Thread Shaoxuan Wang
Hi Radu, Similar as the stream-stream join, this stream-stream inner query does not seem to be well defined. It needs provide at least some kind of window bounds to complete the streaming SQL semantics. If this is an unbounded join/select, a mechanism of how to store the infinite date has to be co