GitHub user kfleischmann opened a pull request:
https://github.com/apache/incubator-flink/pull/42
New operator map partition function
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/kfleischmann/incubator-flink
new_operator_MapPartitionFunction
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/incubator-flink/pull/42.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 #42
----
commit 4e1b57d71f3a141b8206a62f12a9e102b7903fad
Author: kay <[email protected]>
Date: 2014-06-25T09:57:45Z
add some functions
commit b8eeb0c4875f8e914b4665ce750baf698a45d53f
Author: kay <[email protected]>
Date: 2014-06-25T10:22:43Z
MapPartitionDriver added
commit f8eeb9944171ef30857560bf3e9ff36a3e2d4f82
Author: kay <[email protected]>
Date: 2014-06-25T10:30:57Z
add map partition driver strategy
commit 6bbb4cc043d86af0421a3d4228fea788f62dbe64
Author: kay <[email protected]>
Date: 2014-06-25T10:38:48Z
add map partition node map partition descriptor
commit dbfe953bbb3bfb0f2aafafb719599fea8b8d56e6
Author: kay <[email protected]>
Date: 2014-06-25T12:40:36Z
final version integration
commit d1df8307c641071812cc4d1f83ad2aef0eb06570
Author: kay <[email protected]>
Date: 2014-06-25T12:46:48Z
cleanup
commit dba2ce299164019322d5c71f6d7cbdf8c73f9869
Author: kay <[email protected]>
Date: 2014-06-25T13:19:44Z
cleanup
commit 1f8e5a9aff5d1a45004ecb4694674e140ecc4cd5
Author: kay <[email protected]>
Date: 2014-06-25T13:20:55Z
cleanup
commit 8dc6d70678de827882363f3616a70f0f4c5cff85
Author: kay <[email protected]>
Date: 2014-06-25T13:37:30Z
add estimation for map partition operator
commit 968a46e7e164130b864bf7e186c2e461168e118f
Author: kay <[email protected]>
Date: 2014-06-25T13:44:23Z
add map partition test
----
---
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.
---
