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 A37EEF472 for ; Sun, 24 Mar 2013 14:17:22 +0000 (UTC) Received: (qmail 75070 invoked by uid 500); 24 Mar 2013 14:17:17 -0000 Delivered-To: apmail-hadoop-user-archive@hadoop.apache.org Received: (qmail 74976 invoked by uid 500); 24 Mar 2013 14:17:17 -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 74968 invoked by uid 99); 24 Mar 2013 14:17:17 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 24 Mar 2013 14:17:17 +0000 X-ASF-Spam-Status: No, hits=-0.7 required=5.0 tests=RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of harsh@cloudera.com designates 209.85.210.172 as permitted sender) Received: from [209.85.210.172] (HELO mail-ia0-f172.google.com) (209.85.210.172) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 24 Mar 2013 14:17:12 +0000 Received: by mail-ia0-f172.google.com with SMTP id l29so4760278iag.17 for ; Sun, 24 Mar 2013 07:16:51 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20120113; h=x-received:mime-version:in-reply-to:references:from:date:message-id :subject:to:content-type:x-gm-message-state; bh=rf7M/bAGI4/wWbsVqDkozuYF/UNtJCIK77P19Jol3B4=; b=BSbmFeMqNQmQ0iSFioPjzSiuVKuM+QmHebqwxk6ojGfOk9eJjcbE+3yKa8Le/UOjjI qIOgRcfGviKIxI50Hs4Woj/X9BiA3KEwd0WE1ko6yhcPXDrog3u4x5ev6ZknnWzaU27L NWuTEEAuktwkiwRddHG0mYCGjoUa1s1OSMHO2EPvvomPzbgFRMcMtz8wt+qFsx0b0rLR eoxVP4k1tXiAMdJxh0vO983+D8BOV+jiz1F6YqVwdIN68KJYNt1ZyE0NOKm82QHpasEp mBAxgoSHloP0xffvFoBnfxaIFmUhGGxbEP0FbKNayAMSW/Y0aFg7aik98PBngapLY2S7 y1PQ== X-Received: by 10.50.78.202 with SMTP id d10mr2688458igx.69.1364134610995; Sun, 24 Mar 2013 07:16:50 -0700 (PDT) MIME-Version: 1.0 Received: by 10.50.181.198 with HTTP; Sun, 24 Mar 2013 07:16:30 -0700 (PDT) In-Reply-To: References: From: Harsh J Date: Sun, 24 Mar 2013 19:46:30 +0530 Message-ID: Subject: Re: 2 Reduce method in one Job To: "" Content-Type: text/plain; charset=ISO-8859-1 X-Gm-Message-State: ALoCoQnzyru8CDjDSCyrIQWZ+J9AT3E8riDYrKtjXX80r0WRWwv2qMmkoYRH/7YsFBCzDProHwkF X-Virus-Checked: Checked by ClamAV on apache.org Yes, just use an identity mapper (in new API, the base Mapper class itself identity-maps, in the old API use IdentityMapper class) and set the input path as the output path of the first job. If you'll be ending up doing more such step-wise job chaining, consider using Apache Oozie's workflow system. On Sun, Mar 24, 2013 at 7:23 PM, Fatih Haltas wrote: > Thank you very much. > > You are right Harsh, it is exactly what i am trying to do. > > I want to process my result, according to the keys and i donot spend time > writing this data to hdfs, I want to pass data as input to another reduce. > > One more question then, > Creating 2 diffirent job, secondone has only reduce for example, is it > possible to pass first jobs output as argument to second job? > > > On Sun, Mar 24, 2013 at 5:44 PM, Harsh J wrote: >> >> You seem to want to re-sort/partition your data without materializing >> it onto HDFS. >> >> Azuryy is right: There isn't a way right now and a second job (with an >> identity mapper) is necessary. With YARN this is more possible to >> implement into the project, though. >> >> The newly inducted incubator project Tez sorta targets this. Its in >> its nascent stages though (for general user use), and the website >> should hopefully appear at >> http://incubator.apache.org/projects/tez.html soon. Meanwhile, you can >> read the proposal behind this project at >> http://wiki.apache.org/incubator/TezProposal. Initial sources are at >> https://svn.apache.org/repos/asf/incubator/tez/trunk/. >> >> On Sun, Mar 24, 2013 at 6:33 PM, Fatih Haltas >> wrote: >> > I want to get reduce output as key and value then I want to pass them to >> > a >> > new reduce as input key and input value. >> > >> > So is there any Map-Reduce-Reduce kind of method? >> > >> > Thanks to all. >> >> >> >> -- >> Harsh J > > -- Harsh J