Julian Hyde created CALCITE-1237:
------------------------------------
Summary: Session windows for streaming SQL
Key: CALCITE-1237
URL: https://issues.apache.org/jira/browse/CALCITE-1237
Project: Calcite
Issue Type: Bug
Reporter: Julian Hyde
Assignee: Julian Hyde
A session window is a collection of rows whose key values, when sorted, have a
gap of at most N.
(Should "at most" be "less than"?)
The key type can be any type that has a minus operator, that is, numeric and
date-time.
I propose the following syntax: {{session(key [, ...]*, interval)}}. For
example:
{code}
select stream session(rowtime, productId, interval '5' second),
productId, count(*) as c
from Orders
group by session(rowtime, productId, interval '5' second),
productId
{code}
to find bursts of orders for the same product where consecutive orders are no
more than 5 seconds apart.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
