Return-Path: X-Original-To: apmail-hadoop-user-archive@minotaur.apache.org Delivered-To: apmail-hadoop-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 6103FFE02 for ; Sun, 31 Mar 2013 18:10:55 +0000 (UTC) Received: (qmail 67558 invoked by uid 500); 31 Mar 2013 18:10:50 -0000 Delivered-To: apmail-hadoop-user-archive@hadoop.apache.org Received: (qmail 67443 invoked by uid 500); 31 Mar 2013 18:10:50 -0000 Mailing-List: contact user-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@hadoop.apache.org Delivered-To: mailing list user@hadoop.apache.org Received: (qmail 67434 invoked by uid 99); 31 Mar 2013 18:10:50 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 31 Mar 2013 18:10: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 (nike.apache.org: domain of sandy.ryza@cloudera.com designates 209.85.215.174 as permitted sender) Received: from [209.85.215.174] (HELO mail-ea0-f174.google.com) (209.85.215.174) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 31 Mar 2013 18:10:43 +0000 Received: by mail-ea0-f174.google.com with SMTP id m14so812750eaj.33 for ; Sun, 31 Mar 2013 11:10:23 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20120113; h=mime-version:x-received:in-reply-to:references:date:message-id :subject:from:to:content-type:x-gm-message-state; bh=FkSbi6cGfdnw/sg8mMILZ46U7xrhk7vwPxVEPgIfqdU=; b=F9qFl+eDuDol7/ze9sCKh0XH/vpAN2PQPZcnKR7w7xgKf5IqrvgD+b4vbCdEr8R7Nk tt1akOISsdB0Fq03JiQVWZQnApbIApqykxCABm3wtvUbHjoyNcS+iVzzUMmaXoRebawQ 34ZlxZRBs73ukO3Zdq698dO85mX1TTQya5UJa1TafTsZAHTpC/TvWAfaEVe2w1/jFQHl 0046+uGaEt7MaJ5OyaOo4k17eUch/+tDYiHBNGq+uUeDa0qLo5QY+xYDoUHNZFUH8ilv y7MF1++eF68gJ21FKRcg5aSGIvN1x/n2sNZtKvKIsRsRTDJ66UDlSNfZxq3zJ8epFVHg 0s7A== MIME-Version: 1.0 X-Received: by 10.15.43.132 with SMTP id x4mr29735769eev.31.1364753423452; Sun, 31 Mar 2013 11:10:23 -0700 (PDT) Received: by 10.15.25.8 with HTTP; Sun, 31 Mar 2013 11:10:23 -0700 (PDT) In-Reply-To: References: Date: Sun, 31 Mar 2013 11:10:23 -0700 Message-ID: Subject: Re: Streaming value of (200MB) from a SequenceFile From: Sandy Ryza To: user@hadoop.apache.org Content-Type: multipart/alternative; boundary=089e0160c21c03128d04d93c6b96 X-Gm-Message-State: ALoCoQnVCvuzBHIb+d6kvlWIOeZ8HQaq1HCk/IaVliVG6qjZhz/qCUZPx6F/g/SXHeSLbRccq/KZ X-Virus-Checked: Checked by ClamAV on apache.org --089e0160c21c03128d04d93c6b96 Content-Type: text/plain; charset=ISO-8859-1 Hi Jerry, I assume you're providing your own Writable implementation? The Writable readFields method is given a stream. Are you able to perform you able to perform your processing while reading the it there? -Sandy On Sat, Mar 30, 2013 at 10:52 AM, Jerry Lam wrote: > Hi everyone, > > I'm having a problem to stream individual key-value pair of 200MB to 1GB > from a MapFile. > I need to stream the large value to an outputstream instead of reading the > entire value before processing because it potentially uses too much memory. > > I read the API for MapFile, the next(WritableComparable key, Writable val) > does not return an input stream. > > How can I accomplish this? > > Thanks, > > Jerry > --089e0160c21c03128d04d93c6b96 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable Hi Jerry,

I assume you're providing your own Writabl= e implementation? The Writable readFields method is given a stream. =A0Are = you able to perform you able to perform your processing while reading the i= t there?

-Sandy

On Sat,= Mar 30, 2013 at 10:52 AM, Jerry Lam <chilinglam@gmail.com> wrote:
Hi everyone,

=
I'm having a problem to stream individual key-value pair of 200MB = to 1GB from a MapFile.
I need to stream the large value to an outputstream instead of reading= the entire value before processing because it potentially uses too much me= mory.

I read the API for MapFile, the=A0next(WritableComparab= le key, Writable val) does not return an input stream.

=
How can I accomplish this?=A0

Thanks,

Jerry

--089e0160c21c03128d04d93c6b96--