gearpump-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Manu Zhang (JIRA)" <>
Subject [jira] [Commented] (GEARPUMP-23) Add DSL window (time series) support
Date Thu, 12 May 2016 01:01:12 GMT


Manu Zhang commented on GEARPUMP-23:

Thanks, Kam.

I read this paper some while ago. It has a great summary of algebraic properties of aggregate
operations. For example, count is associative, invertible and commutative, and thus fits for
out-of-order processing with accumulating and distracting. Other operations may have more
restrictions and harder to handle in a window aggregation.  It's worthwhile to explore how
to implement the approach of the paper on Gearpump for the long term.

The shortcut to go now is to stick to the Beam model, although my impression (which could
be wrong) is that it requires the aggregation to be associative and commutative.

> Add DSL window (time series) support 
> -------------------------------------
>                 Key: GEARPUMP-23
>                 URL:
>             Project: Apache Gearpump
>          Issue Type: New Feature
>          Components: streaming
>    Affects Versions: 0.8.0
>            Reporter: Kam Kasravi
>            Assignee: Manu Zhang
>             Fix For: 0.8.1
> Time series support is need for both GEARPUMP-21 and GEARPUMP-22. This was originally
github issue  [1917|]. Other realtime streaming
engines support time windows such as [Flink|],
[Beam|] and a future release
of [Spark|].
A comparison matrix is found [here|]

This message was sent by Atlassian JIRA

View raw message