Return-Path: X-Original-To: apmail-mahout-commits-archive@www.apache.org Delivered-To: apmail-mahout-commits-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 785269717 for ; Sun, 4 Dec 2011 07:36:25 +0000 (UTC) Received: (qmail 17162 invoked by uid 500); 4 Dec 2011 07:36:24 -0000 Delivered-To: apmail-mahout-commits-archive@mahout.apache.org Received: (qmail 17050 invoked by uid 500); 4 Dec 2011 07:36:19 -0000 Mailing-List: contact commits-help@mahout.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@mahout.apache.org Delivered-To: mailing list commits@mahout.apache.org Received: (qmail 17039 invoked by uid 99); 4 Dec 2011 07:36:17 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 04 Dec 2011 07:36:17 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Sun, 04 Dec 2011 07:36:14 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id D8D0C238899C; Sun, 4 Dec 2011 07:35:52 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1210065 - /mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/cvb/InMemoryCollapsedVariationalBayes0.java Date: Sun, 04 Dec 2011 07:35:52 -0000 To: commits@mahout.apache.org From: ssc@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20111204073552.D8D0C238899C@eris.apache.org> X-Virus-Checked: Checked by ClamAV on apache.org Author: ssc Date: Sun Dec 4 07:35:52 2011 New Revision: 1210065 URL: http://svn.apache.org/viewvc?rev=1210065&view=rev Log: MAHOUT-912 InMemoryCollapsedVariationalBayes0 should ignore _SUCCESS files Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/cvb/InMemoryCollapsedVariationalBayes0.java Modified: mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/cvb/InMemoryCollapsedVariationalBayes0.java URL: http://svn.apache.org/viewvc/mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/cvb/InMemoryCollapsedVariationalBayes0.java?rev=1210065&r1=1210064&r2=1210065&view=diff ============================================================================== --- mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/cvb/InMemoryCollapsedVariationalBayes0.java (original) +++ mahout/trunk/core/src/main/java/org/apache/mahout/clustering/lda/cvb/InMemoryCollapsedVariationalBayes0.java Sun Dec 4 07:35:52 2011 @@ -39,6 +39,7 @@ import org.apache.mahout.common.Abstract import org.apache.mahout.common.CommandLineUtil; import org.apache.mahout.common.Pair; import org.apache.mahout.common.commandline.DefaultOptionCreator; +import org.apache.mahout.common.iterator.sequencefile.PathFilters; import org.apache.mahout.common.iterator.sequencefile.SequenceFileIterable; import org.apache.mahout.math.DenseMatrix; import org.apache.mahout.math.DenseVector; @@ -483,7 +484,7 @@ public class InMemoryCollapsedVariationa if(fs.isFile(vectorPath)) { subPaths.add(vectorPath); } else { - for(FileStatus fileStatus : fs.listStatus(vectorPath)) { + for(FileStatus fileStatus : fs.listStatus(vectorPath, PathFilters.logsCRCFilter())) { subPaths.add(fileStatus.getPath()); } }