Interface CollectorManager<C extends Collector,T>
- All Known Implementing Classes:
public interface CollectorManager<C extends Collector,T>A manager of collectors. This class is useful to parallelize execution of search requests and has two main methods:
newCollector()which must return a NEW collector which will be used to collect a certain set of leaves.
reduce(Collection)which will be used to reduce the results of individual collections into a meaningful result. This method is only called after all leaves have been fully collected.
- See Also:
- WARNING: This API is experimental and might change in incompatible ways in the next release.
All Methods Instance Methods Abstract Methods Modifier and Type Method Description
newCollector()Return a new
reduce(Collection<C> collectors)Reduce the results of individual collectors into a meaningful result.
C newCollector() throws IOExceptionReturn a new
Collector. This must return a different instance on each call.
T reduce(Collection<C> collectors) throws IOExceptionReduce the results of individual collectors into a meaningful result. For instance a
TopDocsCollectorwould compute the
top docsof each collector and then merge them using
TopDocs.merge(int, TopDocs). This method must be called after collection is finished on all provided collectors.