Return-Path: Delivered-To: apmail-cassandra-user-archive@www.apache.org Received: (qmail 79842 invoked from network); 18 May 2010 09:10:12 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 18 May 2010 09:10:12 -0000 Received: (qmail 40495 invoked by uid 500); 18 May 2010 09:10:11 -0000 Delivered-To: apmail-cassandra-user-archive@cassandra.apache.org Received: (qmail 40362 invoked by uid 500); 18 May 2010 09:10:09 -0000 Mailing-List: contact user-help@cassandra.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@cassandra.apache.org Delivered-To: mailing list user@cassandra.apache.org Received: (qmail 40354 invoked by uid 99); 18 May 2010 09:10:09 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 May 2010 09:10:09 +0000 X-ASF-Spam-Status: No, hits=1.9 required=10.0 tests=AWL,FREEMAIL_FROM,HTML_MESSAGE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of rantav@gmail.com designates 209.85.214.172 as permitted sender) Received: from [209.85.214.172] (HELO mail-iw0-f172.google.com) (209.85.214.172) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 18 May 2010 09:10:03 +0000 Received: by iwn42 with SMTP id 42so1443706iwn.31 for ; Tue, 18 May 2010 02:09:42 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:mime-version:received:from:date :message-id:subject:to:content-type; bh=xVS/kSoobrbajZ9TCPPBgEVoP4WTBAl8/ZFH5+rLQ3s=; b=JjNnG8VzjHej6SpUj7YYVRiOAqI76qNckvy6uTsEcpI2NcHJwrOorGEHZhi9JI7YA+ GgFZg9/hFvNaKexLkY/54V3+t6VnEQOfhu5GDJWu+TeGn3zIC5+wXgy3eac/JI3Ob9MH 6HPpXNGcTm7DKruoEReq3+RWbzsR9/6DO9ScE= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:from:date:message-id:subject:to:content-type; b=fFWlmmiKEuqTqaf8ATk5oBfUqL7/eaxTzdvMEzGwUCP8TFGVMAqLGYOInMLp3wIFuh TAf2ANXMiYAd1SS5ZKD1pvdepcsj9seNcWxh6dPjasleZyHzkP8T+vWA9C99J/y8Ftik sOtrXtL8pm0iYyJaV/E8BBe1aHR7L7tQJQTNw= Received: by 10.231.149.203 with SMTP id u11mr1321081ibv.6.1274173704162; Tue, 18 May 2010 02:08:24 -0700 (PDT) MIME-Version: 1.0 Received: by 10.231.172.83 with HTTP; Tue, 18 May 2010 02:08:04 -0700 (PDT) From: Ran Tavory Date: Tue, 18 May 2010 12:08:04 +0300 Message-ID: Subject: mapreduce from cassandra to cassandra To: user@cassandra.apache.org Content-Type: multipart/alternative; boundary=0050450146f304cffb0486daaf29 --0050450146f304cffb0486daaf29 Content-Type: text/plain; charset=UTF-8 In the wordcount example the process reads from cassandra and the result is written to a local file at /tmp/word_count* Is it possible to read from cassandra and write the result back to cassandra to a specified cf/row/column? I see that there exists a ColumnFamilyInputFormat but not ColumnFamilyOutputFormat or something like that (in http://svn.apache.org/repos/asf/cassandra/trunk/src/java/org/apache/cassandra/hadoop/ ) My knowledge about hadoop and mr is pretty basic so maybe I'm missing something simple, lmk, thanks! --0050450146f304cffb0486daaf29 Content-Type: text/html; charset=UTF-8 Content-Transfer-Encoding: quoted-printable
In the wordcount example the process reads from cassandra = and the result is written to a local file at /tmp/word_count*
Is it pos= sible to read from cassandra and write the result back to cassandra to a sp= ecified cf/row/column?

I see that there exists a=C2=A0ColumnFamilyInputFormat=C2=A0= but not ColumnFamilyOutputFormat or something like that (in=C2=A0http://svn.apache.org/repos/asf/cassandra/trunk/src/java/org/a= pache/cassandra/hadoop/)

My knowledge about hadoop and mr is pretty basic so maybe I&= #39;m missing something simple, lmk, thanks!
--0050450146f304cffb0486daaf29--