Return-Path: X-Original-To: apmail-crunch-user-archive@www.apache.org Delivered-To: apmail-crunch-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 42F7910EFD for ; Wed, 12 Mar 2014 15:44:53 +0000 (UTC) Received: (qmail 90901 invoked by uid 500); 12 Mar 2014 15:44:52 -0000 Delivered-To: apmail-crunch-user-archive@crunch.apache.org Received: (qmail 90850 invoked by uid 500); 12 Mar 2014 15:44:51 -0000 Mailing-List: contact user-help@crunch.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@crunch.apache.org Delivered-To: mailing list user@crunch.apache.org Received: (qmail 90839 invoked by uid 99); 12 Mar 2014 15:44:50 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 12 Mar 2014 15:44:50 +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 (athena.apache.org: domain of jwills@cloudera.com designates 209.85.216.51 as permitted sender) Received: from [209.85.216.51] (HELO mail-qa0-f51.google.com) (209.85.216.51) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 12 Mar 2014 15:44:46 +0000 Received: by mail-qa0-f51.google.com with SMTP id j7so2675499qaq.38 for ; Wed, 12 Mar 2014 08:44:25 -0700 (PDT) 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:from:date :message-id:subject:to:content-type; bh=pXBYb3Y0YMC/H3+EjQObLhl+dDMvrlOBUsvjqFv9hNw=; b=M5fC71IFKxamTcxjLsDyDvWbqdKsAf4unSr9PkbzV3tpPbpXX3FW6gLhj0FT4Owss/ EzOGjD9bTbL+e+XZ5mE5BjO+iAzTR/XRJvWhvr00nBaFkYDeFc2emZjfaodCCShLfP7D NN9LSDjL4z3K2xRe5cgPPQH46qr2nsG9rsVrvr6zRoAMDG5/A5Xo90QmW+qqUYbBl8Ag JKo5/7cYvCvSO8szegWrhbXtUdopxDiXbsyVd9o3rZeJ5CluGkyJbqt9bpP8ANNUwTgS 9neuzbWZc5roKjud9WY3wX0FNxmeSvPBHpLfWS9kgCxJWNlGGpGt8SjkGIn40au3X2ot QxNA== X-Gm-Message-State: ALoCoQlHej1r06HV8z1lc8MrHZJCPD9XJS5w7Gw8PEkkv8r55fp1SN3OIDUSoOFgkeoqU7+ukQOC X-Received: by 10.224.14.77 with SMTP id f13mr56466478qaa.31.1394639065714; Wed, 12 Mar 2014 08:44:25 -0700 (PDT) MIME-Version: 1.0 Received: by 10.224.172.202 with HTTP; Wed, 12 Mar 2014 08:44:05 -0700 (PDT) In-Reply-To: References: From: Josh Wills Date: Wed, 12 Mar 2014 08:44:05 -0700 Message-ID: Subject: Re: convert a scrunch.PCollection to a crunch.PCollection ? To: user@crunch.apache.org Content-Type: multipart/alternative; boundary=047d7bdc80d81a24ca04f46ab670 X-Virus-Checked: Checked by ClamAV on apache.org --047d7bdc80d81a24ca04f46ab670 Content-Type: text/plain; charset=ISO-8859-1 Scrunch PCollections have a member called "native" that returns the underlying Java PCollection. I think we could allow the conversion to happen automatically by updating o.a.c.s.Conversions to include implicit methods for going _back_ from a Scrunch PCollection to a Java PCollection (right now, only the Java -> Scala methods are provided.) On Wed, Mar 12, 2014 at 8:27 AM, Barry,Nathan wrote: > Hi > > I'm migrating some code from crunch to scrunch and I'm running into an > issue leveraging a crunch based API that takes a crunch PCollection as a > parameter but I have a scrunch PCollection which results in compilation > errors when trying to pass the scrunch Pcollection into the API > > What am I missing? I _think_ I have the proper conversion imports in > place. > > [ERROR] found : org.apache.crunch.scrunch. > PCollection[org.apache.hadoop.hbase.client.Put] > [ERROR] required: org.apache.crunch.PCollection[org.apache.hadoop.hbase. > client.Put] > > Thanks, > > Nathan > > CONFIDENTIALITY NOTICE This message and any included attachments are > from Cerner Corporation and are intended only for the addressee. The > information contained in this message is confidential and may constitute > inside or non-public information under international, federal, or state > securities laws. Unauthorized forwarding, printing, copying, distribution, > or use of such information is strictly prohibited and may be unlawful. If > you are not the addressee, please promptly delete this message and notify > the sender of the delivery error by e-mail or you may call Cerner's > corporate offices in Kansas City, Missouri, U.S.A at (+1) (816)221-1024. > -- Director of Data Science Cloudera Twitter: @josh_wills --047d7bdc80d81a24ca04f46ab670 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Scrunch PCollections have a member called "native&quo= t; that returns the underlying Java PCollection. I think we could allow the= conversion to happen automatically by updating o.a.c.s.Conversions to incl= ude implicit methods for going _back_ from a Scrunch PCollection to a Java = PCollection (right now, only the Java -> Scala methods are provided.)


On Wed, Mar 1= 2, 2014 at 8:27 AM, Barry,Nathan <NBARRY@cerner.com> wrote:<= br>
Hi

I'm migrating some code from crunch to scrunch and I'm running into= an issue leveraging a crunch based API that takes a crunch PCollection as = a parameter but I have a scrunch PCollection which results in compilation e= rrors when trying to pass the scrunch Pcollection into the API

What am I missing? =A0I _think_ I have the proper conversion imports in pla= ce.

[ERROR] =A0found =A0 : org.apache.crunch.scrunch.PCollection[or= g.apache.hadoop.hbase.client.Put]
[ERROR] =A0required: org.apache.crunch.PCollection[org.apache.h= adoop.hbase.client.Put]

Thanks,

Nathan

CONFIDENTIALITY NOTICE This message and any included attachments are from C= erner Corporation and are intended only for the addressee. The information = contained in this message is confidential and may constitute inside or non-= public information under international, federal, or state securities laws. = Unauthorized forwarding, printing, copying, distribution, or use of such in= formation is strictly prohibited and may be unlawful. If you are not the ad= dressee, please promptly delete this message and notify the sender of the d= elivery error by e-mail or you may call Cerner's corporate offices in K= ansas City, Missouri, U.S.A at (+1) (816)221-1024.



--
Directo= r of Data Science
Twitter: @josh_wills
--047d7bdc80d81a24ca04f46ab670--