incubator-blur-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amccu...@apache.org
Subject [1/2] git commit: Fixed a broken method call.
Date Sat, 18 May 2013 18:05:12 GMT
Updated Branches:
  refs/heads/0.1.5 80de21b59 -> 53d224fd0


Fixed a broken method call.


Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/f5e1675f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/f5e1675f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/f5e1675f

Branch: refs/heads/0.1.5
Commit: f5e1675f818e111d5de47f59ce88cdb157e34e1f
Parents: 80de21b
Author: Aaron McCurry <amccurry@gmail.com>
Authored: Sat May 18 14:03:32 2013 -0400
Committer: Aaron McCurry <amccurry@gmail.com>
Committed: Sat May 18 14:03:32 2013 -0400

----------------------------------------------------------------------
 .../org/apache/blur/mapreduce/BlurReducer.java     |    4 +++-
 1 files changed, 3 insertions(+), 1 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/f5e1675f/src/blur-mapred/src/main/java/org/apache/blur/mapreduce/BlurReducer.java
----------------------------------------------------------------------
diff --git a/src/blur-mapred/src/main/java/org/apache/blur/mapreduce/BlurReducer.java b/src/blur-mapred/src/main/java/org/apache/blur/mapreduce/BlurReducer.java
index 6871922..82ea3e3 100644
--- a/src/blur-mapred/src/main/java/org/apache/blur/mapreduce/BlurReducer.java
+++ b/src/blur-mapred/src/main/java/org/apache/blur/mapreduce/BlurReducer.java
@@ -47,6 +47,7 @@ import org.apache.blur.mapreduce.lib.ProgressableDirectory;
 import org.apache.blur.mapreduce.lib.BlurMutate.MUTATE_TYPE;
 import org.apache.blur.store.hdfs.HdfsDirectory;
 import org.apache.blur.thrift.generated.Column;
+import org.apache.blur.thrift.generated.Selector;
 import org.apache.blur.thrift.generated.TableDescriptor;
 import org.apache.blur.utils.BlurConstants;
 import org.apache.blur.utils.BlurUtil;
@@ -247,7 +248,8 @@ public class BlurReducer extends Reducer<Text, BlurMutate, Text, BlurMutate>
{
   }
 
   protected void fetchOldRecords() throws IOException {
-    List<Document> docs = BlurUtil.termSearch(_reader, _rowIdTerm, new ResetableDocumentStoredFieldVisitor());
+    List<Document> docs = BlurUtil.fetchDocuments(_reader, _rowIdTerm, new ResetableDocumentStoredFieldVisitor(),
+        new Selector());
     for (Document document : docs) {
       String recordId = document.get(RECORD_ID);
       // add them to the new records if the new records do not contain them.


Mime
View raw message