Searched refs:collector (Results 1 - 25 of 40) sorted by relevance

12

/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/
H A DDocSetDelegateCollector.java31 final Collector collector; field in class:DocSetDelegateCollector
33 public DocSetDelegateCollector(int smallSetSize, int maxDoc, Collector collector) { argument
35 this.collector = collector;
40 collector.collect(doc);
76 collector.setScorer(scorer);
81 collector.setNextReader(indexReader, docBase);
H A DGrouping.java37 import org.apache.solr.search.grouping.collector.FilterCollector;
266 Collector collector = cmd.createFirstPassCollector();
267 if (collector != null) {
268 collectors.add(collector);
312 Collector collector = cmd.createSecondPassCollector();
313 if (collector != null)
314 collectors.add(collector);
357 * Invokes search with the specified filter and collector.
358 * If a time limit has been specified, wrap the collector in a TimeLimitingCollector
360 private void searchWithTimeLimiter(final Filter luceneFilter, Collector collector) throw argument
773 FilterCollector collector; field in class:Grouping.CommandQuery
[all...]
H A DSolrIndexSearcher.java685 Collector collector = setCollector;
687 pf.postFilter.setLastDelegate(collector);
688 collector = pf.postFilter;
708 collector.setNextReader(subReader, baseDoc);
715 collector.collect(docid);
720 collector.collect(docid);
839 DocSetCollector collector = new DocSetCollector(maxDoc()>>6, maxDoc());
851 collector.setNextReader(sir, offset);
857 collector.collect(arr[j]);
863 super.search(query,null,collector);
[all...]
/lucene-3.6.0/lucene/core/src/java/org/apache/lucene/search/
H A DTimeLimitingCollector.java63 private Collector collector; field in class:TimeLimitingCollector
71 * @param collector the wrapped {@link Collector}
76 public TimeLimitingCollector(final Collector collector, Counter clock, final long ticksAllowed ) { argument
77 this.collector = collector;
83 * Sets the baseline for this collector. By default the collectors baseline is
84 * initialized once the first reader is passed to the collector.
93 * TimeLimitingCollector collector = new TimeLimitingCollector(c, clock, numTicks);
94 * collector.setBaseline(baseline);
95 * indexSearcher.search(query, collector);
183 setCollector(Collector collector) argument
[all...]
H A DScoreCachingWrappingScorer.java29 * if the collector requests it. Some collectors may need to use the score in
46 protected boolean score(Collector collector, int max, int firstDocID) throws IOException { argument
47 return scorer.score(collector, max, firstDocID);
77 public void score(Collector collector) throws IOException { argument
78 scorer.score(collector);
H A DScorer.java84 * @param collector The collector to which all matching documents are passed.
86 public void score(Collector collector) throws IOException { argument
87 collector.setScorer(this);
90 collector.collect(doc);
105 * @param collector
106 * The collector to which all matching documents are passed.
114 protected boolean score(Collector collector, int max, int firstDocID) throws IOException { argument
115 collector.setScorer(this);
118 collector
[all...]
H A DDisjunctionSumScorer.java109 * @param collector The collector to which all matching documents are passed through.
112 public void score(Collector collector) throws IOException { argument
113 collector.setScorer(this);
115 collector.collect(currentDoc);
122 * @param collector The collector to which all matching documents are passed through.
127 protected boolean score(Collector collector, int max, int firstDocID) throws IOException { argument
129 collector.setScorer(this);
131 collector
[all...]
H A DTermCollectingRewrite.java33 protected final void collectTerms(IndexReader reader, MultiTermQuery query, TermCollector collector) throws IOException { argument
38 if (t == null || !collector.collect(t, enumerator.difference()))
H A DConstantScoreQuery.java209 private Collector wrapCollector(final Collector collector) { argument
214 collector.setScorer(new ConstantScorer(ConstantScorer.this.getSimilarity(),
220 collector.collect(doc);
225 collector.setNextReader(reader, docBase);
230 return collector.acceptsDocsOutOfOrder();
237 public void score(Collector collector) throws IOException { argument
239 ((Scorer) docIdSetIterator).score(wrapCollector(collector));
241 super.score(collector);
249 protected boolean score(Collector collector, int max, int firstDocID) throws IOException { argument
251 return ((Scorer) docIdSetIterator).score(wrapCollector(collector), ma
[all...]
H A DBooleanScorer.java177 public Collector collector; field in class:BooleanScorer.SubScorer
181 Collector collector, SubScorer next)
190 this.collector = collector;
235 protected boolean score(Collector collector, int max, int firstDocID) throws IOException { argument
243 collector.setScorer(bs);
269 collector.collect(current.doc);
288 more |= sub.scorer.score(sub.collector, end, subScorerDocID);
319 public void score(Collector collector) throws IOException { argument
320 score(collector, Intege
180 SubScorer(Scorer scorer, boolean required, boolean prohibited, Collector collector, SubScorer next) argument
[all...]
H A DBooleanScorer2.java275 * @param collector The collector to which all matching documents are passed through.
278 public void score(Collector collector) throws IOException { argument
279 collector.setScorer(this);
281 collector.collect(doc);
286 protected boolean score(Collector collector, int max, int firstDocID) throws IOException { argument
288 collector.setScorer(this);
290 collector.collect(doc);
H A DParallelMultiSearcher.java164 * @param collector to receive hits
167 public void search(final Weight weight, final Filter filter, final Collector collector) argument
176 collector.setScorer(scorer);
181 collector.collect(doc);
186 collector.setNextReader(reader, start + docBase);
191 return collector.acceptsDocsOutOfOrder();
H A DSearchable.java67 * @param collector
71 void search(Weight weight, Filter filter, Collector collector) throws IOException; argument
/lucene-3.6.0/lucene/contrib/benchmark/src/java/org/apache/lucene/benchmark/byTask/tasks/
H A DSearchWithCollectorTask.java26 * Does search w/ a custom collector
42 clnName = config.get("collector.class", "");
54 Collector collector = null;
56 collector = TopScoreDocCollector.create(numHits(), true);
58 collector = TopScoreDocCollector.create(numHits(), false);
60 collector = Class.forName(clnName).asSubclass(Collector.class).newInstance();
63 collector = super.createCollector();
65 return collector;
H A DReadTask.java114 TopFieldCollector collector = TopFieldCollector.create(sort, numHits,
118 searcher.search(w, null, collector);
119 hits = collector.topDocs();
124 Collector collector = createCollector();
125 searcher.search(q, null, collector);
126 //hits = collector.topDocs();
/lucene-3.6.0/lucene/contrib/instantiated/src/test/org/apache/lucene/store/instantiated/
H A DTestRealTime.java43 Collector collector;
50 collector = new Collector();
51 searcher.search(new TermQuery(new Term("f", "a")), collector);
52 assertEquals(1, collector.hits);
59 collector = new Collector();
60 searcher.search(new TermQuery(new Term("f", "a")), collector);
61 assertEquals(2, collector.hits);
/lucene-3.6.0/lucene/contrib/grouping/src/java/org/apache/lucene/search/grouping/
H A DAbstractSecondPassGroupingCollector.java69 final TopDocsCollector<?> collector;
72 collector = TopScoreDocCollector.create(maxDocsPerGroup, true);
75 collector = TopFieldCollector.create(withinGroupSort, maxDocsPerGroup, fillSortFields, getScores, getMaxScores, true);
79 collector));
86 group.collector.setScorer(scorer);
96 group.collector.collect(doc);
113 group.collector.setNextReader(reader, docBase);
129 final TopDocs topDocs = groupDocs.collector.topDocs(withinGroupOffset, maxDocsPerGroup);
149 public final TopDocsCollector<?> collector; field in class:AbstractSecondPassGroupingCollector.SearchGroupDocs
151 public SearchGroupDocs(GROUP_VALUE_TYPE groupValue, TopDocsCollector<?> collector) { argument
[all...]
H A DBlockGroupingCollector.java41 * single pass collector, as long as you are grouping by a
50 * indexed as a block. This collector also fills in
52 * {@link TermAllGroupsCollector}. However, this collector does
56 * <p><b>NOTE</b>: this collector makes no effort to verify
233 * Create the single pass collector.
289 * <p><b>NOTE</b>: This collector is unable to compute
329 final TopDocsCollector<?> collector;
335 collector = TopScoreDocCollector.create(maxDocsPerGroup, true);
338 collector = TopFieldCollector.create(withinGroupSort, maxDocsPerGroup, fillSortFields, needsScores, needsScores, true);
341 collector
[all...]
/lucene-3.6.0/lucene/core/src/test/org/apache/lucene/search/
H A DTestBoolean2.java135 TopScoreDocCollector collector = TopScoreDocCollector.create(1000, false);
136 searcher.search(query, null, collector);
137 ScoreDoc[] hits1 = collector.topDocs().scoreDocs;
139 collector = TopScoreDocCollector.create(1000, true);
140 searcher.search(query, null, collector);
141 ScoreDoc[] hits2 = collector.topDocs().scoreDocs;
143 assertEquals(mulFactor * collector.totalHits,
251 TopFieldCollector collector = TopFieldCollector.create(sort, 1000,
254 searcher.search(q1, null, collector);
255 ScoreDoc[] hits1 = collector
[all...]
/lucene-3.6.0/lucene/backwards/src/test/org/apache/lucene/search/
H A DTestBoolean2.java135 TopScoreDocCollector collector = TopScoreDocCollector.create(1000, false);
136 searcher.search(query, null, collector);
137 ScoreDoc[] hits1 = collector.topDocs().scoreDocs;
139 collector = TopScoreDocCollector.create(1000, true);
140 searcher.search(query, null, collector);
141 ScoreDoc[] hits2 = collector.topDocs().scoreDocs;
143 assertEquals(mulFactor * collector.totalHits,
251 TopFieldCollector collector = TopFieldCollector.create(sort, 1000,
254 searcher.search(q1, null, collector);
255 ScoreDoc[] hits1 = collector
[all...]
/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/distributed/command/
H A DQueryCommand.java27 import org.apache.solr.search.grouping.collector.FilterCollector;
115 private TopDocsCollector collector; field in class:QueryCommand
129 collector = TopScoreDocCollector.create(docsToCollect, true);
131 collector = TopFieldCollector.create(sort, docsToCollect, true, needScores, needScores, true);
133 filterCollector = new FilterCollector(docSet, collector);
138 return new QueryCommandResult(collector.topDocs(), filterCollector.getMatches());
/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/
H A DCommandHandler.java191 * Invokes search with the specified filter and collector.
192 * If a time limit has been specified then wrap the collector in the TimeLimitingCollector
194 private void searchWithTimeLimiter(final Query query, final Filter luceneFilter, Collector collector) throws IOException { argument
196 collector = new TimeLimitingCollector(collector, TimeLimitingCollector.getGlobalCounter(), queryCommand.getTimeAllowed());
201 collector = MultiCollector.wrap(collector, hitCountCollector);
205 searcher.search(query, luceneFilter, collector);
/lucene-3.6.0/lucene/contrib/facet/src/test/org/apache/lucene/facet/index/
H A DFacetsPayloadProcessorProviderTest.java75 FacetsCollector collector = new FacetsCollector(fsp, reader1, taxReader);
76 searcher.search(new MatchAllDocsQuery(), collector);
77 FacetResult result = collector.getFacetResults().get(0);
/lucene-3.6.0/lucene/contrib/pruning/src/java/org/apache/lucene/index/pruning/
H A DCarmelUniformTermPruningPolicy.java128 TopScoreDocCollector collector = TopScoreDocCollector.create(count, true);
130 is.search(tq, collector);
131 docs = collector.topDocs().scoreDocs;
/lucene-3.6.0/solr/core/src/java/org/apache/solr/search/grouping/collector/
H A DFilterCollector.java1 package org.apache.solr.search.grouping.collector;
28 * A collector that filters incoming doc ids that are not in the filter.
69 * Returns the delegate collector
71 * @return the delegate collector

Completed in 1020 milliseconds

12