GitHub user mbalassi opened a pull request:
https://github.com/apache/flink/pull/761
[streaming] Consolidate streaming API method names
* This PR build on #743 and adds partitionBy for connected streams, scala
and docs
* Does the renames discussed on the mailing list in 35e5cbd
* The renamed methods are already tested for functionality except for
`partitionByHash` for which added in this PR
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mbalassi/flink rename
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/761.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 #761
----
commit 61fb5ee11447a4a5f2983378e65ad73eb1829677
Author: Aljoscha Krettek <aljoscha.kret...@gmail.com>
Date: 2015-05-28T08:40:56Z
[FLINK-2103] [streaming] [api-extending] Expose partitionBy to user
Conflicts:
flink-staging/flink-streaming/flink-streaming-core/src/main/java/org/apache/flink/streaming/api/datastream/DataStream.java
Closes #743
commit f5da9217efd0731eda8fad9ec6a1a48946cfddf4
Author: mbalassi <mbala...@apache.org>
Date: 2015-06-02T08:49:37Z
[FLINK-2103] [streaming] [api-extending] PartitionBy for connected streams,
scala & docs
commit 35e5cbd58fc69b5984f4e22e5b728ead45f9309f
Author: mbalassi <mbala...@apache.org>
Date: 2015-06-02T15:01:48Z
[streaming] [api-breaking] Consolidate DataStream method names
To better match the names of the DataSet API the following renamings were
made:
- DataStream.merge -> DataStream.union
- DataStream.distribute -> DataStream.rebalance
- DataStream.partitionBy -> DataStream.partitionByHash
----
---
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 infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
