[
https://issues.apache.org/jira/browse/CALCITE-1237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Julian Hyde updated CALCITE-1237:
---------------------------------
Component/s: stream
> Session windows for streaming SQL
> ---------------------------------
>
> Key: CALCITE-1237
> URL: https://issues.apache.org/jira/browse/CALCITE-1237
> Project: Calcite
> Issue Type: Bug
> Components: stream
> 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)
