Return-Path: X-Original-To: apmail-flink-dev-archive@www.apache.org Delivered-To: apmail-flink-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id CD64111DEA for ; Mon, 22 Sep 2014 14:33:51 +0000 (UTC) Received: (qmail 12937 invoked by uid 500); 22 Sep 2014 14:33:51 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 12875 invoked by uid 500); 22 Sep 2014 14:33:51 -0000 Mailing-List: contact dev-help@flink.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@flink.incubator.apache.org Delivered-To: mailing list dev@flink.incubator.apache.org Received: (qmail 12863 invoked by uid 99); 22 Sep 2014 14:33:51 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 22 Sep 2014 14:33:51 +0000 X-ASF-Spam-Status: No, hits=-2000.8 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Mon, 22 Sep 2014 14:33:50 +0000 Received: (qmail 12766 invoked by uid 99); 22 Sep 2014 14:33:30 -0000 Received: from minotaur.apache.org (HELO minotaur.apache.org) (140.211.11.9) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 22 Sep 2014 14:33:30 +0000 Received: from localhost (HELO mail-vc0-f180.google.com) (127.0.0.1) (smtp-auth username aljoscha, mechanism plain) by minotaur.apache.org (qpsmtpd/0.29) with ESMTP; Mon, 22 Sep 2014 14:33:29 +0000 Received: by mail-vc0-f180.google.com with SMTP id hq11so4172140vcb.11 for ; Mon, 22 Sep 2014 07:33:28 -0700 (PDT) MIME-Version: 1.0 X-Received: by 10.220.99.71 with SMTP id t7mr19883611vcn.8.1411396408833; Mon, 22 Sep 2014 07:33:28 -0700 (PDT) Received: by 10.53.9.162 with HTTP; Mon, 22 Sep 2014 07:33:28 -0700 (PDT) In-Reply-To: References: Date: Mon, 22 Sep 2014 16:33:28 +0200 Message-ID: Subject: Re: Adding a serial collection-based execution mode From: Aljoscha Krettek To: dev@flink.incubator.apache.org Content-Type: text/plain; charset=UTF-8 X-Virus-Checked: Checked by ClamAV on apache.org I'll do groupReduce On Mon, Sep 22, 2014 at 4:13 PM, Till Rohrmann wrote: > Then I'll take the join operation. > > On Mon, Sep 22, 2014 at 3:44 PM, Ufuk Celebi wrote: > >> >> On 22 Sep 2014, at 15:37, Stephan Ewen wrote: >> >> > Hi everyone! >> > >> > I have started with a patch that introduces *"local collection-based >> > execution"* of Flink programs. >> >> Very nice! >> >> To have a list of missing operators: >> >> - flatMap <= I'll take this >> - filter <= I'll take this >> - reduce <= I'll take this >> - groupreduce >> - cogroup >> - join >>