package org.apache.lucene.benchmark.byTask.tasks;

/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

import org.apache.lucene.benchmark.byTask.PerfRunData;
import org.apache.lucene.benchmark.byTask.feeds.QueryMaker;

/**
 * Search task.
 * 
 * <p>Note: This task reuses the reader if it is already open. 
 * Otherwise a reader is opened at start and closed at the end.
 */
public class SearchMatchTask extends MatchTask {

  public SearchMatchTask(PerfRunData runData) {
    super(runData);
  }

  public boolean withRetrieve() {
    return false;
  }

  public boolean withSearch() {
    return true;
  }

  public boolean withTraverse() {
    return false;
  }

  public boolean withWarm() {
    return false;
  }

  public QueryMaker getQueryMaker() {
    return getRunData().getQueryMaker(this);
  }
}
package org.apache.lucene.benchmark.byTask.tasks;

/**
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

import org.apache.lucene.benchmark.byTask.PerfRunData;
import org.apache.lucene.benchmark.byTask.feeds.QueryMaker;
import org.apache.lucene.document.Document;
import org.apache.lucene.index.IndexReader;
import org.apache.lucene.search.Hits;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.MatchCollector;
import org.apache.lucene.search.Query;
import org.apache.lucene.store.Directory;


/**
 * Read index (abstract) task.
 * Sub classes implement withSearch(), withWarm(), withTraverse() and withRetrieve()
 * methods to configure the actual action.
 * 
 * <p>Note: All ReadTasks reuse the reader if it is already open. 
 * Otherwise a reader is opened at start and closed at the end.
 *  
 * <p>Other side effects: none.
 */
public abstract class MatchTask extends ReadTask {

  public MatchTask(PerfRunData runData) {
    super(runData);
  }

  public int doLogic() throws Exception {
    int res = 0;
    boolean closeReader = false;
    
    // open reader or use existing one
    IndexReader ir = getRunData().getIndexReader();
    if (ir == null) {
      Directory dir = getRunData().getDirectory();
      ir = IndexReader.open(dir);
      closeReader = true;
      //res++; //this is confusing, comment it out
    }
    
    // optionally warm and add num docs traversed to count
    if (withWarm()) {
      Document doc = null;
      for (int m = 0; m < ir.maxDoc(); m++) {
        if (!ir.isDeleted(m)) {
          doc = ir.document(m);
          res += (doc==null ? 0 : 1);
        }
      }
    }
    
    if (withSearch()) {
      res++;
      IndexSearcher searcher = new IndexSearcher(ir);
      QueryMaker queryMaker = getQueryMaker();
      Query q = queryMaker.makeQuery();
      Hits hits = null;
      searcher.match(q, new MatchCollector() {
        public void collect(int docId) {
          // nothing
//          System.out.println("DOC: " + docId);
        }
      });
      //System.out.println("searched: "+q);
      
      if (withTraverse() && hits!=null) {
        int traversalSize = Math.min(hits.length(), traversalSize());
        if (traversalSize > 0) {
          boolean retrieve = withRetrieve();
          for (int m = 0; m < hits.length(); m++) {
            int id = hits.id(m);
            res++;
            if (retrieve) {
              res += retrieveDoc(ir, id);
            }
          }
        }
      }
      
      searcher.close();
    }
    
    if (closeReader) {
      ir.close();
    }
    return res;
  }

//  protected int retrieveDoc(IndexReader ir, int id) throws IOException {
//    return (ir.document(id) == null ? 0 : 1);
//  }

  /**
   * Return query maker used for this task.
   */
  public abstract QueryMaker getQueryMaker();

  /**
   * Return true if search should be performed.
   */
  public abstract boolean withSearch();

  /**
   * Return true if warming should be performed.
   */
  public abstract boolean withWarm();
  
  /**
   * Return true if, with search, results should be traversed.
   */
  public abstract boolean withTraverse();

//  /**
//   * Specify the number of hits to traverse.  Tasks should override this if they want to restrict the number
//   * of hits that are traversed when {@link #withTraverse()} is true. Must be greater than 0.
//   *
//   * Read task calculates the traversal as: Math.min(hits.length(), traversalSize())
//   * @return Integer.MAX_VALUE
//   */
//  public int traversalSize()
//  {
//    return Integer.MAX_VALUE;
//  }

  /**
   * Return true if, with search & results traversing, docs should be retrieved.
   */
  public abstract boolean withRetrieve();

}
Index: src/java/org/apache/lucene/benchmark/byTask/tasks/ReadTask.java
===================================================================
--- src/java/org/apache/lucene/benchmark/byTask/tasks/ReadTask.java	(revision 525635)
+++ src/java/org/apache/lucene/benchmark/byTask/tasks/ReadTask.java	(working copy)
@@ -21,6 +21,7 @@
 import org.apache.lucene.benchmark.byTask.feeds.QueryMaker;
 import org.apache.lucene.document.Document;
 import org.apache.lucene.index.IndexReader;
+import org.apache.lucene.search.HitCollector;
 import org.apache.lucene.search.Hits;
 import org.apache.lucene.search.IndexSearcher;
 import org.apache.lucene.search.Query;
@@ -74,7 +75,13 @@
       IndexSearcher searcher = new IndexSearcher(ir);
       QueryMaker queryMaker = getQueryMaker();
       Query q = queryMaker.makeQuery();
-      Hits hits = searcher.search(q);
+//      Hits hits = searcher.search(q);
+      Hits hits = null;
+      searcher.search(q, new HitCollector() {
+        public void collect(int docId, float socre) {
+          //
+        }
+      });
       //System.out.println("searched: "+q);
       
       if (withTraverse() && hits!=null) {