[jira] [Commented] (FLINK-13032) Allow Access to Per-Window State in mergeable window ProcessWindowFunction

2019-07-02 Thread jasine chen (JIRA)


[ 
https://issues.apache.org/jira/browse/FLINK-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16877507#comment-16877507
 ] 

jasine chen commented on FLINK-13032:
-

[~yanghua] yes, it's helpful in our scene, we use session window to analysis 
behavior, and we do need to record ,store and output states of each session 
window

> Allow Access to Per-Window State in mergeable window  ProcessWindowFunction
> ---
>
> Key: FLINK-13032
> URL: https://issues.apache.org/jira/browse/FLINK-13032
> Project: Flink
>  Issue Type: Improvement
>  Components: API / DataStream
>Affects Versions: 1.8.0
>Reporter: jasine chen
>Priority: Major
>
> access to per-window state is allowed in non-merging windows, but it's 
> necessary to access per-window state in mergeable windows 
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Updated] (FLINK-13032) Allow Access to Per-Window State in mergeable window ProcessWindowFunction

2019-06-29 Thread jasine chen (JIRA)


 [ 
https://issues.apache.org/jira/browse/FLINK-13032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

jasine chen updated FLINK-13032:

Summary: Allow Access to Per-Window State in mergeable window  
ProcessWindowFunction  (was: Allow Access to Per-Window State in SessionWindow 
ProcessWindowFunction)

> Allow Access to Per-Window State in mergeable window  ProcessWindowFunction
> ---
>
> Key: FLINK-13032
> URL: https://issues.apache.org/jira/browse/FLINK-13032
> Project: Flink
>  Issue Type: Improvement
>  Components: API / DataStream
>Affects Versions: 1.8.0
>Reporter: jasine chen
>Priority: Major
>
> access to per-window state is allowed in non-merging windows, but it's 
> necessary to access per-window state in mergeable windows 
>  



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (FLINK-13032) Allow Access to Per-Window State in SessionWindow ProcessWindowFunction

2019-06-29 Thread jasine chen (JIRA)
jasine chen created FLINK-13032:
---

 Summary: Allow Access to Per-Window State in SessionWindow 
ProcessWindowFunction
 Key: FLINK-13032
 URL: https://issues.apache.org/jira/browse/FLINK-13032
 Project: Flink
  Issue Type: Improvement
  Components: API / DataStream
Affects Versions: 1.8.0
Reporter: jasine chen


access to per-window state is allowed in non-merging windows, but it's 
necessary to access per-window state in mergeable windows 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)


[jira] [Created] (FLINK-13031) Support dynamic offset in tumbling windows

2019-06-29 Thread jasine chen (JIRA)
jasine chen created FLINK-13031:
---

 Summary: Support dynamic offset in tumbling windows
 Key: FLINK-13031
 URL: https://issues.apache.org/jira/browse/FLINK-13031
 Project: Flink
  Issue Type: Wish
  Components: API / DataStream
Affects Versions: 1.8.0
Reporter: jasine chen


TumblingWindow use _offset_ parameter to solve the timezone issue when start a 
tumbling window of a day, but now the offset is fixed, the processing is not 
correct when the stream contains data from different timezones. 

allow offset extract from element like _DynamicSessionWindow_ can solve this 
problem _._

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)