GitHub user mbalassi opened a pull request:
https://github.com/apache/incubator-flink/pull/115
Streaming prototype update
Issues addressed:
* [FLINK-1058] Streaming initial documentation
* [FLINK-1080] Added aggregations for streaming
* Enhancing DataStream functionality
* a couple fixes
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/incubator-flink master
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-flink/pull/115.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #115
----
commit 5a27148bbaace0014177772f13eb2be0fc95d460
Author: ghermann <[email protected]>
Date: 2014-08-29T15:18:12Z
[streaming] Fixed SlidingWindowStateIterator
commit 96e1a89e32603e0c7028806f7f8f62e85b3002d1
Author: gyfora <[email protected]>
Date: 2014-09-02T11:58:40Z
[streaming] Reduce operator added to ConnectedDataStream + test
commit 7b1158b674b80946e0cba869a8d44d104058f9d2
Author: ghermann <[email protected]>
Date: 2014-09-02T12:47:48Z
[streaming] Updated directed emit to not use output names when all outputs
are selected
commit a6a0ed1b3b079e9afeb07ec6e2acdaec02894af4
Author: Eszes Dávid <[email protected]>
Date: 2014-09-02T13:58:14Z
[FLINK-1080] [streaming] Streaming aggregation added
Conflicts:
flink-addons/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
commit 384ac414df7223aaf1442a42cfb55da39b971e13
Author: mbalassi <[email protected]>
Date: 2014-09-05T12:41:53Z
[streaming] Added TypeInfo to DataStream
commit e9dffee5c533078c446d1ad4d621ee935d0a6fdd
Author: gyfora <[email protected]>
Date: 2014-09-05T14:07:59Z
[FLINK-1080] [streaming] Streaming aggregation update and refactor
commit 0fd9f76b4e49701802791257b365ef5083a42097
Author: mbalassi <[email protected]>
Date: 2014-09-02T16:06:32Z
[FLINK-1058] [streaming] Streaming initial documentation
----
---
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 enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
