Return-Path: X-Original-To: apmail-flink-issues-archive@minotaur.apache.org Delivered-To: apmail-flink-issues-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 92F2518669 for ; Tue, 2 Jun 2015 15:32:28 +0000 (UTC) Received: (qmail 70032 invoked by uid 500); 2 Jun 2015 15:32:28 -0000 Delivered-To: apmail-flink-issues-archive@flink.apache.org Received: (qmail 69993 invoked by uid 500); 2 Jun 2015 15:32:28 -0000 Mailing-List: contact issues-help@flink.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.apache.org Delivered-To: mailing list issues@flink.apache.org Received: (qmail 69984 invoked by uid 99); 2 Jun 2015 15:32:28 -0000 Received: from Unknown (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Jun 2015 15:32:28 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 0FA0CCAC33 for ; Tue, 2 Jun 2015 15:32:28 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.971 X-Spam-Level: X-Spam-Status: No, score=0.971 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, T_RP_MATCHES_RCVD=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id z8KG89yNF_7M for ; Tue, 2 Jun 2015 15:32:20 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with SMTP id CC1A924CE9 for ; Tue, 2 Jun 2015 15:32:19 +0000 (UTC) Received: (qmail 69624 invoked by uid 99); 2 Jun 2015 15:32:18 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Jun 2015 15:32:18 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id D72FEE0044; Tue, 2 Jun 2015 15:32:18 +0000 (UTC) From: mbalassi To: issues@flink.incubator.apache.org Reply-To: issues@flink.incubator.apache.org Message-ID: Subject: [GitHub] flink pull request: [streaming] Consolidate streaming API method n... Content-Type: text/plain Date: Tue, 2 Jun 2015 15:32:18 +0000 (UTC) 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 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 Date: 2015-06-02T08:49:37Z [FLINK-2103] [streaming] [api-extending] PartitionBy for connected streams, scala & docs commit 35e5cbd58fc69b5984f4e22e5b728ead45f9309f Author: mbalassi 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. ---