[
https://issues.apache.org/jira/browse/APEXMALHAR-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15293607#comment-15293607
]
Siyuan Hua commented on APEXMALHAR-1939:
----------------------------------------
h2. Roadmap for next phase
In next phase, we will focus on windowed transformations with following features
- Watermark - Ingestion time watermark / watermark from tuple
- Early Triggers - How frequent to emit real-time partial result
- Late Triggers - When to emit updated result with tuple comes after watermark
- Customizable trigger action - What to do when trigger is fired
- Spool window state - Large In-Memory state could be spooled to disk
- 3 different accumulation models: ignore, accumulation, accumulation + delta
- Window support: Non-Mergeable window(fix window, sliding window), Mergeable
window(session window)
- 3 tuple time support: event time, system time, ingestion time
> Stream API
> ----------
>
> Key: APEXMALHAR-1939
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-1939
> Project: Apache Apex Malhar
> Issue Type: New Feature
> Reporter: Siyuan Hua
> Priority: Critical
> Labels: roadmap
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
