Return-Path: X-Original-To: apmail-incubator-crunch-user-archive@minotaur.apache.org Delivered-To: apmail-incubator-crunch-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 57416E4F4 for ; Thu, 14 Feb 2013 10:29:54 +0000 (UTC) Received: (qmail 11667 invoked by uid 500); 14 Feb 2013 10:29:54 -0000 Delivered-To: apmail-incubator-crunch-user-archive@incubator.apache.org Received: (qmail 11491 invoked by uid 500); 14 Feb 2013 10:29:50 -0000 Mailing-List: contact crunch-user-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: crunch-user@incubator.apache.org Delivered-To: mailing list crunch-user@incubator.apache.org Received: (qmail 11469 invoked by uid 99); 14 Feb 2013 10:29:49 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Feb 2013 10:29:49 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of lionel.herbet@gmail.com designates 209.85.212.51 as permitted sender) Received: from [209.85.212.51] (HELO mail-vb0-f51.google.com) (209.85.212.51) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Feb 2013 10:29:41 +0000 Received: by mail-vb0-f51.google.com with SMTP id fq11so1333448vbb.24 for ; Thu, 14 Feb 2013 02:29:21 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:x-received:date:message-id:subject:from:to :content-type; bh=KVkBISwBp4itlWfPv71NfaWa5rElch4rVnp3hbhDTmw=; b=P/w9VyzcD1EcSxGecncruIPZXds/xh66GG0wzs/eSKWwYYy9WkoOrxVW/dg/MbEs4n 9bChucQHyC3vW0ZSnf+9ekEYvLhrSnHQetv7fPPJULP9OzurJbiuOUW0IOQXih0FP7F5 EvXPCEGRLC98FNoWeBIb1kOLLindC88Y8DdxnmMTmbpOpiB/xdXXUxADGS6aDLbBaX86 5H2bxcxJHlYDpsLK31Ec+U1uc6iL3CRcAivCd9YK7A9iGsGNMwUtVyW/buaO/BOxTtZt EuO2Yi2y/hDmnjNESP8wHB1iud1rNGZeguSRGhRSVZCOqr0oMjS4wk5BtWTSzCK7MzLs z8Kg== MIME-Version: 1.0 X-Received: by 10.52.32.230 with SMTP id m6mr29158120vdi.83.1360837761093; Thu, 14 Feb 2013 02:29:21 -0800 (PST) Received: by 10.58.252.229 with HTTP; Thu, 14 Feb 2013 02:29:21 -0800 (PST) Date: Thu, 14 Feb 2013 11:29:21 +0100 Message-ID: Subject: [Scrunch] implicit PTypeH value on parallelDo method From: Lionel Herbet To: crunch-user@incubator.apache.org Content-Type: multipart/alternative; boundary=bcaec517c4b258cf2404d5acbb3d X-Virus-Checked: Checked by ClamAV on apache.org --bcaec517c4b258cf2404d5acbb3d Content-Type: text/plain; charset=ISO-8859-1 Hi, I'm currently testing scrunch after few MR Job implementation on crunch. I was wondering if it would be possible to have implicit PTypeH parameter in PcollectionLike scala trait methods ? PCollection scala class already has implicit PtypeH parameter for map method. For example in PcollectionLike scala Trait we could add the method def parallelDo[T](fn: DoFn[S, T])(implicit pt: PTypeH[T]) = { new PCollection[T](native.parallelDo(fn, pt.get(getTypeFamily()))) } This method is equivalent to the existing one but with an implicit value for PTypeH depending on [T] class type. def parallelDo[T](fn: DoFn[S, T], ptype: PType[T]) = { new PCollection[T](native.parallelDo(fn, ptype)) } What do you think ? Lionel --bcaec517c4b258cf2404d5acbb3d Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable 
Hi,

I'm currently testing scrunch after few MR Job implementation on crunch=
.
I was wondering if it would be possible to have implicit PTypeH parameter
in PcollectionLike scala trait methods ?
PCollection scala class already has implicit PtypeH parameter for map
method.

For example in PcollectionLike scala Trait we could add the method

def parallelDo[T](fn: DoFn[S, T])(implicit pt: PTypeH[T]) =3D {
        new PCollection[T](native.parallelDo(fn, pt.get(getTypeFamily())))
    }

This method is equivalent to the existing one but with an implicit value
for PTypeH depending on [T] class type.

def parallelDo[T](fn: DoFn[S, T], ptype: PType[T]) =3D {
    new PCollection[T](native.parallelDo(fn, ptype))
  }

What do you think ?

Lionel
=
--bcaec517c4b258cf2404d5acbb3d--