[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-02-05 Thread dyanarose
Github user dyanarose closed the pull request at: https://github.com/apache/flink/pull/5295 ---

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-25 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r163796598 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0 +1,101 @@

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-24 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r163692223 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0 +1,101 @@

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-24 Thread walterddr
Github user walterddr commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r163684364 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0 +1,101 @@

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161807900 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SessionWindowTimeGapExtractor.java --- @@ -0,0 +1,30 @@

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161807869 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java --- @@ -0,0

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161807837 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0 +1,101 @@

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161807850 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java --- @@ -0,0

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread dyanarose
Github user dyanarose commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161807828 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0 +1,101 @@

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161798960 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161800866 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/SessionWindowTimeGapExtractor.java --- @@ -0,0 +1,30

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161799107 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicEventTimeSessionWindows.java --- @@ -0,0

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161799438 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java --- @@ -0,0

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-16 Thread sunjincheng121
Github user sunjincheng121 commented on a diff in the pull request: https://github.com/apache/flink/pull/5295#discussion_r161799387 --- Diff: flink-streaming-java/src/main/java/org/apache/flink/streaming/api/windowing/assigners/DynamicProcessingTimeSessionWindows.java --- @@ -0,0

[GitHub] flink pull request #5295: [FLINK-8384] [streaming] Session Window Assigner w...

2018-01-14 Thread dyanarose
GitHub user dyanarose opened a pull request: https://github.com/apache/flink/pull/5295 [FLINK-8384] [streaming] Session Window Assigner with Dynamic Gaps ## What is the purpose of the change This PR adds the ability for the Session Window assigners to to have dynamic