[
https://issues.apache.org/jira/browse/FLINK-1058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14123406#comment-14123406
]
ASF GitHub Bot commented on FLINK-1058:
---------------------------------------
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
----
> Add documentation for streaming feature
> ---------------------------------------
>
> Key: FLINK-1058
> URL: https://issues.apache.org/jira/browse/FLINK-1058
> Project: Flink
> Issue Type: Task
> Components: Streaming
> Affects Versions: 0.7-incubating
> Reporter: Henry Saputra
> Assignee: Márton Balassi
> Labels: documentation
>
> With the new Flink streaming feature, need full documentation on how it works
> and examples on how to use it before it can go to core.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)