Return-Path: X-Original-To: apmail-apex-dev-archive@minotaur.apache.org Delivered-To: apmail-apex-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 73AD1187D7 for ; Fri, 20 Nov 2015 01:24:38 +0000 (UTC) Received: (qmail 11243 invoked by uid 500); 20 Nov 2015 01:24:38 -0000 Delivered-To: apmail-apex-dev-archive@apex.apache.org Received: (qmail 11175 invoked by uid 500); 20 Nov 2015 01:24:38 -0000 Mailing-List: contact dev-help@apex.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@apex.incubator.apache.org Delivered-To: mailing list dev@apex.incubator.apache.org Received: (qmail 11157 invoked by uid 99); 20 Nov 2015 01:24:37 -0000 Received: from Unknown (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 20 Nov 2015 01:24:37 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 568F6C05AD for ; Fri, 20 Nov 2015 01:24:37 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 2.98 X-Spam-Level: ** X-Spam-Status: No, score=2.98 tagged_above=-999 required=6.31 tests=[DKIM_SIGNED=0.1, DKIM_VALID=-0.1, HTML_MESSAGE=3, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, SPF_PASS=-0.001, URIBL_BLOCKED=0.001] autolearn=disabled Authentication-Results: spamd4-us-west.apache.org (amavisd-new); dkim=pass (2048-bit key) header.d=datatorrent-com.20150623.gappssmtp.com Received: from mx1-eu-west.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id OT0q2yQZJ_JC for ; Fri, 20 Nov 2015 01:24:32 +0000 (UTC) Received: from mail-oi0-f54.google.com (mail-oi0-f54.google.com [209.85.218.54]) by mx1-eu-west.apache.org (ASF Mail Server at mx1-eu-west.apache.org) with ESMTPS id 68B0B20EBA for ; Fri, 20 Nov 2015 01:24:31 +0000 (UTC) Received: by oies6 with SMTP id s6so57067207oie.1 for ; Thu, 19 Nov 2015 17:24:24 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=datatorrent-com.20150623.gappssmtp.com; s=20150623; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; bh=V9nFfzA/TA5EAQvStzT6mKgeK2nclvaULuVkRxcUtNs=; b=aw2lGPU2r/FXS9GpIK8f+n39GFjyz2JxA39xuYQodkov/JLag1A1oqtA980s0QBLAA CT/zwWPdeOKF61Ct9GsOrX4LiJhXaH1WEweARDbjshzGClcOGeKDD0/rH7M+XpEybD95 J9yHdhlHNrp5jvJjjecIIuvs0xJlVTOpfwULWmnyLRQJMw5vQ5PWhvNWGNNE8JWyO+GR yjvty705LzJW91tkuW5jL09fo5X1fyeXgBqQUTJ8U5i55Pu5ngqM08KMJA73fECE5/dY hx+P24SlmtXIKoPe1pRdejUxqU9E57lpz2r6tAmk6r2M/mc/zoteXO4O+2PNBf4z0FO3 L8Iw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:mime-version:in-reply-to:references:date :message-id:subject:from:to:content-type; bh=V9nFfzA/TA5EAQvStzT6mKgeK2nclvaULuVkRxcUtNs=; b=gM1l1Vlee1DqDBQVqNgW5mkGok5Aubnu/Gsw9LL3usvGryzKllNwPv4A3jEmagIGcS ESTJC86mmBMkBO432FR78MTv1jHLuAX2PHfxtagnsF3bLxf/Er3Vvxf1TnHP7QqpTwIZ cznEixG8hDfdwvud73Ck2bSy3Lz5cdkzEd2VGIn2Faas3U8H1qGhWLq1LlNf9HiwygQU ZFt9KJvdDErRwiRy734VTxSAHpulTvt0iQ6oWOhZsifLE/hFyOzanzOt3Mov5z733Tcz cnTxB/hAz45aNeEX+Xdoh/pWRFn8WHfX4FjyfkIU/xOmB2onRDPFJdKc7NHo7sGiXe3k iT3A== X-Gm-Message-State: ALoCoQnRtlNfgDFyMuZoAVGw5LduC79jBV90BqnHRTH7PU69iteaMgOKfBatfvZw6sQ/qbB1fQem MIME-Version: 1.0 X-Received: by 10.202.56.3 with SMTP id f3mr7000545oia.8.1447982664250; Thu, 19 Nov 2015 17:24:24 -0800 (PST) Received: by 10.202.201.14 with HTTP; Thu, 19 Nov 2015 17:24:24 -0800 (PST) In-Reply-To: References: Date: Thu, 19 Nov 2015 17:24:24 -0800 Message-ID: Subject: Re: Is there a way of defining a default partitioner for an operator besides implement partitioner interface From: Isha Arkatkar To: dev@apex.incubator.apache.org Content-Type: multipart/alternative; boundary=001a113cc3665813e90524eebc11 --001a113cc3665813e90524eebc11 Content-Type: text/plain; charset=UTF-8 I also think property works better, though, can be an easier API to 'set number of partitions for operator to N' And internally it can pick up Stateless Partitioner as default? Thanks, Isha On Thu, Nov 19, 2015 at 5:15 PM, Thomas Weise wrote: > I actually think a property works better as it will let you configure the > partitioner like any other operator component. Like the Kafka consumer. > > -- > sent from mobile > On Nov 19, 2015 4:51 PM, "Siyuan Hua" wrote: > > > Thomas, this is what I'm going to do. But I like Pramod's idea to have an > > annotation > > > > On Thu, Nov 19, 2015 at 4:34 PM, Thomas Weise > > wrote: > > > > > Why not implement the interface on the operator and delegate the call > to > > > the partitioner implementation? > > > > > > On Thu, Nov 19, 2015 at 4:09 PM, Pramod Immaneni < > pramod@datatorrent.com > > > > > > wrote: > > > > > > > Idea for an annotation maybe? > > > > > > > > On Thu, Nov 19, 2015 at 3:49 PM, Siyuan Hua > > > > wrote: > > > > > > > > > Sometimes I want to separate the Partitioner logic from operator > and > > > > still > > > > > I want to have default partitioner for the operator (with > specifying > > it > > > > > from application) > > > > > > > > > > > > > > > Best, > > > > > Siyuan > > > > > > > > > > > > > > > --001a113cc3665813e90524eebc11--