GitHub user mbalassi opened a pull request:
https://github.com/apache/incubator-flink/pull/102
Streaming prototype update
Enhanced CoFunction and connectors functionality, refactored examples.
Several minor bugfixes.
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/102.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 #102
----
commit 6549a3fae2befc53a5d8b070914656d3d89c4fd3
Author: Yingjun Wu <[email protected]>
Date: 2014-08-07T19:15:49Z
[streaming] Added database-backed state
commit 486eb346c870c3064bf3a6444bf788f818b1c506
Author: szape <[email protected]>
Date: 2014-08-15T11:35:48Z
[streaming] CoFlatMap & CoGroupReduce functionality
commit 60cf57d4984e37d465c4b5b042c27650d62db874
Author: Yingjun Wu <[email protected]>
Date: 2014-08-11T09:40:50Z
[streaming] Memcached, MySQl and SQLite support for state management.
commit 1ef97c0350bd3ac5ff16d4ea802ae07cba16c695
Author: mbalassi <[email protected]>
Date: 2014-08-18T14:19:08Z
[streaming] Refactored db state connectors and added their license
Conflicts:
flink-addons/flink-streaming/flink-streaming-connectors/pom.xml
commit aeee61aea30a875d97bcff68547f1642ea2011d0
Author: ghermann <[email protected]>
Date: 2014-08-18T15:31:18Z
[streaming] Refactored stream components with InputHandler & OutputHandler
commit bb0e065296f2330fef481a002538303e8b7a2dd9
Author: mbalassi <[email protected]>
Date: 2014-08-19T09:48:14Z
[streaming] Minor bug and license header fixes
commit 167f822423dcba78e6664c37e8c326663addd6af
Author: ghermann <[email protected]>
Date: 2014-08-19T16:04:19Z
[streaming] Updated DBStates
commit a61b8a0d509122607b89e37016d5dbea33315ca1
Author: gyfora <[email protected]>
Date: 2014-08-21T10:51:54Z
[streaming] DataStream merge fix + example clean-up
commit 27a6f6323e1aac89ff693b3b485a06aa18f0be98
Author: gyfora <[email protected]>
Date: 2014-08-22T10:12:31Z
[streaming] CoRecordReader and iterator added + ConnectedDataStream refactor
commit 3da51d1c794f6e63772c553a95a4c09018f510f3
Author: mbalassi <[email protected]>
Date: 2014-08-22T12:14:00Z
[streaming] Examples updated with CoFunctions
commit 3844b101522055dfd2c2f0b0639225af09963ead
Author: eszesd <[email protected]>
Date: 2014-08-22T13:09:59Z
[streaming] Added JSONParser and updated Twitter connector
commit 83d19c326e1bf866d143afe4661a1e64dd493f6c
Author: eszesd <[email protected]>
Date: 2014-08-22T15:11:28Z
[streaming] WindowJoin Example refactored
----
---
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.
---
