flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbalassi <...@git.apache.org>
Subject [GitHub] flink pull request: [streaming] Consolidate streaming API method n...
Date Tue, 02 Jun 2015 15:32:18 GMT
GitHub user mbalassi opened a pull request:


    [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:


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.krettek@gmail.com>
Date:   2015-05-28T08:40:56Z

    [FLINK-2103] [streaming] [api-extending] Expose partitionBy to user
    Closes #743

commit f5da9217efd0731eda8fad9ec6a1a48946cfddf4
Author: mbalassi <mbalassi@apache.org>
Date:   2015-06-02T08:49:37Z

    [FLINK-2103] [streaming] [api-extending] PartitionBy for connected streams, scala &

commit 35e5cbd58fc69b5984f4e22e5b728ead45f9309f
Author: mbalassi <mbalassi@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 infrastructure@apache.org or file a JIRA ticket
with INFRA.

View raw message