[
https://issues.apache.org/jira/browse/FLINK-2683?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14901323#comment-14901323
]
ASF GitHub Bot commented on FLINK-2683:
---------------------------------------
Github user StephanEwen commented on the pull request:
https://github.com/apache/flink/pull/1147#issuecomment-142098492
Concerning Watermarks: I think that is the assumption right now, yes.
Since the operators produce records with timestamps based on their
processing time, they cannot simply forward watermarks. They should be able to
auto-generate watermarks based on their processing time, but I am not sure if
that is what we would want...
> Add utilities for heap-backed keyed state in time panes
> -------------------------------------------------------
>
> Key: FLINK-2683
> URL: https://issues.apache.org/jira/browse/FLINK-2683
> Project: Flink
> Issue Type: Sub-task
> Components: Streaming
> Affects Versions: 0.10
> Reporter: Stephan Ewen
> Assignee: Stephan Ewen
> Fix For: 0.10
>
>
> Time panes are commonly used for aligned time windows (tumbling and sliding).
> These utilities would represent the panes with per-pane keyed state.
> The implementation must support:
> - Evicting panes efficiently
> - iterating over the union of all panes' state per key for all keys
> (computing the window function for all keys)
> - efficient append the state for a key in a random pane
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
