Return-Path: Delivered-To: apmail-hadoop-pig-commits-archive@www.apache.org Received: (qmail 13102 invoked from network); 5 May 2009 22:52:15 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 5 May 2009 22:52:15 -0000 Received: (qmail 47639 invoked by uid 500); 5 May 2009 22:52:15 -0000 Delivered-To: apmail-hadoop-pig-commits-archive@hadoop.apache.org Received: (qmail 47619 invoked by uid 500); 5 May 2009 22:52:15 -0000 Mailing-List: contact pig-commits-help@hadoop.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: pig-dev@hadoop.apache.org Delivered-To: mailing list pig-commits@hadoop.apache.org Received: (qmail 47605 invoked by uid 500); 5 May 2009 22:52:15 -0000 Delivered-To: apmail-incubator-pig-commits@incubator.apache.org Received: (qmail 47595 invoked by uid 99); 5 May 2009 22:52:09 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 05 May 2009 22:52:09 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=10.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.130] (HELO eos.apache.org) (140.211.11.130) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 05 May 2009 22:52:07 +0000 Received: from eos.apache.org (localhost [127.0.0.1]) by eos.apache.org (Postfix) with ESMTP id 5F8BD1149F for ; Tue, 5 May 2009 22:51:47 +0000 (GMT) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: Apache Wiki To: pig-commits@incubator.apache.org Date: Tue, 05 May 2009 22:51:47 -0000 Message-ID: <20090505225147.5891.39617@eos.apache.org> Subject: [Pig Wiki] Update of "PigMultiQueryPerformanceSpecification" by RichardDing X-Virus-Checked: Checked by ClamAV on apache.org Dear Wiki user, You have subscribed to a wiki page or wiki category on "Pig Wiki" for change notification. The following page has been changed by RichardDing: http://wiki.apache.org/pig/PigMultiQueryPerformanceSpecification ------------------------------------------------------------------------------ 2. Set the index on the leaf operator of the map plan based on the order this map plan on the inner plan list. 3. Add the reduce plan of the splittee to the inner plan list of the demux operator in the same order as the corresponding map plan. 4. The outputs of merged map plan of the splitter are indexed key/value pairs and are sent to the reduce tasks. - 5. The demux operator extracts the index from the key/values it receives and attaches them to the corresponding reduce plan in its inner plan list. + 5. The demux operator extracts the index from the key/values it receives and uses it to find the corresponding reduce plan in its inner plan list. 6. The chosen reduce plan consumes the key/values data. [[Anchor(PartitionScheme)]]