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 CD6521111D for ; Wed, 18 Jun 2014 12:39:26 +0000 (UTC) Received: (qmail 54805 invoked by uid 500); 18 Jun 2014 12:39:26 -0000 Delivered-To: apmail-flink-dev-archive@flink.apache.org Received: (qmail 54752 invoked by uid 500); 18 Jun 2014 12:39:26 -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 54741 invoked by uid 99); 18 Jun 2014 12:39:26 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Jun 2014 12:39:26 +0000 X-ASF-Spam-Status: No, hits=-2.3 required=5.0 tests=RCVD_IN_DNSWL_MED,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of u.celebi@fu-berlin.de designates 130.133.4.66 as permitted sender) Received: from [130.133.4.66] (HELO outpost1.zedat.fu-berlin.de) (130.133.4.66) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 18 Jun 2014 12:39:21 +0000 Received: from inpost2.zedat.fu-berlin.de ([130.133.4.69]) by outpost.zedat.fu-berlin.de (Exim 4.82) for dev@flink.incubator.apache.org with esmtp (envelope-from ) id <1WxF8j-003HG2-3d>; Wed, 18 Jun 2014 14:38:57 +0200 Received: from wlan-141-23-101-182.tubit.tu-berlin.de ([141.23.101.182]) by inpost2.zedat.fu-berlin.de (Exim 4.82) for dev@flink.incubator.apache.org with esmtpsa (envelope-from ) id <1WxF8j-0009Je-1D>; Wed, 18 Jun 2014 14:38:57 +0200 Content-Type: text/plain; charset=us-ascii Mime-Version: 1.0 (Mac OS X Mail 7.2 \(1874\)) Subject: Re: [stratosphere-users] FlatJoin implementation From: Ufuk Celebi In-Reply-To: Date: Wed, 18 Jun 2014 14:38:56 +0200 Content-Transfer-Encoding: quoted-printable Message-Id: <191E9433-D7E5-40EF-839D-FA7DD56CD828@fu-berlin.de> References: <7b905c5a-7ec6-4e9d-a284-5b6ae3b0b977@googlegroups.com> <43FA1ED9-0718-4A37-9335-C39E4091D58F@fu-berlin.de> To: dev@flink.incubator.apache.org X-Mailer: Apple Mail (2.1874) X-Originating-IP: 141.23.101.182 X-Virus-Checked: Checked by ClamAV on apache.org On 18 Jun 2014, at 14:31, Fabian Hueske wrote: > Why not? > You do >=20 > = data1.join(data2).where(0).equalTo(0).projectFirst(0,1).projectSecond(1).t= ypes(Long.class, > Long.class, Long.class).flatMap(new MyFM()) What if I want the join to collect the left side, right side and union? = But I'm not sure how realistic this use case is and if it is what = Asterios had in mind?=20=