Hi,

First of all let me introduce myself - My name is Radu Tudoran and I am working 
in the field of Big Data processing with a high focus on streaming and more 
recently in the area of SQL. 

I wanted to raise a question/proposal for discussion in the community:

Based on our requirements I realized that I would need to create a window (e.g. 
hop window) that would move on every incoming element based. The syntax that I 
have in mind for it is
 
HOP(column_name, # EVENT , INTERVAL # )   (or should it rather be # ELEMENT 
instead of EVENT?)
 
I wanted to check with you what do you think about such a grammar to go 
directly in Calcite? I think it is relevant for streaming scenarios where you 
do not necessary have events coming at regular time interval but you would 
still like to react on every event. 
As an example you can consider a stock market application where you would 
always compute for every new offer the average over the last hour.

Best regards,

Reply via email to