flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Kostas Kloudas <k.klou...@data-artisans.com>
Subject Re: About Sliding window
Date Wed, 12 Oct 2016 13:10:59 GMT
Hello again,

Sorry for the delay but I cannot really understand your use case.
Could you explain a bit more what do you mean by “out-of-date” event and “aging” an
event?

Also your windows are of a certain duration or global?

Thanks,
Kostas

> On Oct 11, 2016, at 3:04 PM, Zhangrucong <zhangrucong@huawei.com> wrote:
> 
> Hi Kostas:
> Thank you for your rapid response!
>  
> My use-case is that :
> For every incoming event, we want to age the out-of-date event , count the event in window
and send the result.
>  
> For example:
> The events are coming as flowing:
> <image002.png>
>  
> We want flowing result:
> <image004.png>
>  
>  
> By the way, In StreamSQL API, in FILP11, It will realize row window. It seems that the
function of Slide Event-time row-window suits my use-case. Does data stream API  support row
window?
>  
> Thanks !
>  
> 发件人: Kostas Kloudas [mailto:k.kloudas@data-artisans.com] 
> 发送时间: 2016年10月11日 19:38
> 收件人: user@flink.apache.org
> 主题: Re: About Sliding window
>  
> Hi Zhangrucong,
>  
> Sliding windows only support time-based slide. 
> So your use-case is not supported out-of-the-box.
>  
> But, if you describe a bit more what you want to do, 
> we may be able to find a way together to do your job using 
> the currently offered functionality.
>  
> Kostas
>  
> On Oct 11, 2016, at 1:20 PM, Zhangrucong <zhangrucong@huawei.com <mailto:zhangrucong@huawei.com>>
wrote:
>  
> Hello everyone:
>   Now, I am want to use DataStream sliding window API. I look at the API and I have a
question, dose the sliding time window support sliding by every incoming event?
>  
> Thanks in advance!
>  
> <oledata.mso>


Mime
View raw message