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 5F140D6E2 for ; Tue, 11 Sep 2012 15:31:53 +0000 (UTC) Received: (qmail 52452 invoked by uid 500); 11 Sep 2012 15:31:48 -0000 Delivered-To: apmail-hadoop-user-archive@hadoop.apache.org Received: (qmail 52373 invoked by uid 500); 11 Sep 2012 15:31:48 -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 52363 invoked by uid 99); 11 Sep 2012 15:31:48 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 11 Sep 2012 15:31:48 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=FSL_FREEMAIL_1,FSL_FREEMAIL_2,FSL_RCVD_USER,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of koteskie@gmail.com designates 74.125.83.48 as permitted sender) Received: from [74.125.83.48] (HELO mail-ee0-f48.google.com) (74.125.83.48) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 11 Sep 2012 15:31:40 +0000 Received: by eekd41 with SMTP id d41so596379eek.35 for ; Tue, 11 Sep 2012 08:31:20 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:reply-to:sender:date:x-google-sender-auth:message-id :subject:from:to:content-type; bh=82X/Pmw4dBWxLwkVP0+tKrTdipEcXzmCQ8yEB66h00A=; b=Y9ZGrE7+oypEZE0G3g0GmDT91tk2060LwKcQ0kbApGFp3cPKU9qGcaZDLDftv65X8n bmNkLUgeeL0K/cTouIsXlh0ctg7yzlLOtf8Er9F+T/lhKluLoABGP/k+GAvBQQHPBD13 qbHUT3LwrPu4NfFHe8iQPcyCdYeOamz8ncIG1ATzVWPMfcNtDBJo/Ho2adRqAMnfMF5g aDgHEgIIfpKiOaUn/rup2BvBbE7iFhs4PZ6Qk1sT/4hT1ATRV1nvyRRdfbSdvQUKtAur 2caxg+sESYlMmwfswm026H4YeCiFzqlZJ5oqtKhoEWv4fZzp9W+c8KopdUTq4HcEyy+n fklw== MIME-Version: 1.0 Received: by 10.204.154.151 with SMTP id o23mr5050896bkw.77.1347377480533; Tue, 11 Sep 2012 08:31:20 -0700 (PDT) Reply-To: frankkootte@gmail.com Sender: koteskie@gmail.com Received: by 10.204.5.139 with HTTP; Tue, 11 Sep 2012 08:31:20 -0700 (PDT) Date: Tue, 11 Sep 2012 17:31:20 +0200 X-Google-Sender-Auth: EcqfT0goXYaLXkHwrTuqLo1XcpI Message-ID: Subject: Implementing a grouping comparator with avro From: Frank Kootte To: user@hadoop.apache.org Content-Type: multipart/alternative; boundary=0015175d03941b076b04c96ec4c8 --0015175d03941b076b04c96ec4c8 Content-Type: text/plain; charset=ISO-8859-1 I need to implement secondary sort within an avro based MR sequence. I however find little to documentation or examples online. I would like to implement this by overriding the 'int compare(AvroWrapper x, AvroWrapper y)' method but I fail to have it invoked. Does anybody have experience implementing secondary sort on deserialised avro objects ? Some help, advise or pointers will be very much appreciated ! -- Mvrgr. Frank --0015175d03941b076b04c96ec4c8 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable I need to implement secondary sort within an avro based MR sequence. I howe= ver=A0find little to documentation o= r examples online.
I would like to implem= ent this by overriding the=A0=A0'= ;int compare(AvroWrapper<T> x, AvroWrapper<T> y)' method bu= t I fail to have it invoked.
Does anybody have e= xperience implementing secondary sort on deserialised avro objects ?=

Some help, advise o= r pointers will be very much appreciated !


--
Mvrgr. F= rank=A0
--0015175d03941b076b04c96ec4c8--