[EAGLE-410] stream tumbling window aggregate library

• Type: Task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: v0.5.0
• Fix Version/s: v0.5.1
• Assignee: Edward Zhang
• Reporter: Edward Zhang
• Due: 05/Aug/16
• Created: 04/Aug/16 23:56
• Updated: 03/Aug/18 05:23
• Resolved: 03/Aug/18 05:23

Description

Many use cases need aggregate data in streaming process, but Storm does not provide high level aggregation API. The most frequently used example is to aggregate data per minute while data is streamlined.

After investigation, we found Siddhi CEP engine is good for this task.

https://docs.wso2.com/display/CEP420/Inbuilt+Windows#InbuiltWindows-externalTimeBatchexternalTimeBatch

This ticket will develop a preview of simple aggregation API for Eagle use case.

Issue Links

• links to: GitHub Pull Request #301
• links to: GitHub Pull Request #304