Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/395
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabl
Github user rmetzger commented on a diff in the pull request:
https://github.com/apache/flink/pull/395#discussion_r24737554
--- Diff:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/windowing/StreamWindowTypeInfo.java
---
@@ -0,0 +1,
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/395#discussion_r24737330
--- Diff: docs/streaming_guide.md ---
@@ -857,7 +895,7 @@ After installing Docker an image can be pulled for each
connector. Containers ca
For the easies
Github user mbalassi commented on a diff in the pull request:
https://github.com/apache/flink/pull/395#discussion_r24737233
--- Diff: docs/streaming_guide.md ---
@@ -383,9 +389,40 @@
dataStream.groupBy(groupingField).window(Count.of(100)).every(â¦).max(field);
This will
Github user senorcarbone commented on the pull request:
https://github.com/apache/flink/pull/395#issuecomment-74393323
+1 for merging asap. It's an improvement on both semantics and performance
prospects for windowing.
---
If your project is set up for it, you can reply to this email
GitHub user gyfora opened a pull request:
https://github.com/apache/flink/pull/395
StreamWindow abstraction + modular window computations
This PR introduces a rework to the current windowing semantics, by major
API and Runtime improvements.
The core new abstraction is the S
