public class FunctionAllGroupHeadsCollector extends AbstractAllGroupHeadsCollector<FunctionAllGroupHeadsCollector.GroupHead>
AbstractAllGroupHeadsCollector for retrieving the most relevant groups when grouping
by ValueSource.| Modifier and Type | Class and Description |
|---|---|
class |
FunctionAllGroupHeadsCollector.GroupHead
Holds current head document for a single group.
|
AbstractAllGroupHeadsCollector.TemporalResultcompIDXEnd, reversed, temporalResult| Constructor and Description |
|---|
FunctionAllGroupHeadsCollector(ValueSource groupBy,
Map<?,?> vsContext,
Sort sortWithinGroup)
Constructs a
FunctionAllGroupHeadsCollector instance. |
| Modifier and Type | Method and Description |
|---|---|
protected Collection<FunctionAllGroupHeadsCollector.GroupHead> |
getCollectedGroupHeads()
Returns the collected group heads.
|
protected void |
retrieveGroupHeadAndAddIfNotExist(int doc)
Returns the group head and puts it into
AbstractAllGroupHeadsCollector.temporalResult. |
void |
setNextReader(AtomicReaderContext context) |
void |
setScorer(Scorer scorer) |
acceptsDocsOutOfOrder, collect, groupHeadsSize, retrieveGroupHeads, retrieveGroupHeadspublic FunctionAllGroupHeadsCollector(ValueSource groupBy, Map<?,?> vsContext, Sort sortWithinGroup)
FunctionAllGroupHeadsCollector instance.groupBy - The ValueSource to group byvsContext - The ValueSource contextsortWithinGroup - The sort within a groupprotected void retrieveGroupHeadAndAddIfNotExist(int doc)
throws IOException
AbstractAllGroupHeadsCollectorAbstractAllGroupHeadsCollector.temporalResult.
If the group head wasn't encountered before then it will be added to the collected group heads.
The AbstractAllGroupHeadsCollector.TemporalResult.stop property will be true if the group head wasn't encountered before
otherwise false.retrieveGroupHeadAndAddIfNotExist in class AbstractAllGroupHeadsCollector<FunctionAllGroupHeadsCollector.GroupHead>doc - The document to retrieve the group head for.IOException - If I/O related errors occurprotected Collection<FunctionAllGroupHeadsCollector.GroupHead> getCollectedGroupHeads()
AbstractAllGroupHeadsCollectorgetCollectedGroupHeads in class AbstractAllGroupHeadsCollector<FunctionAllGroupHeadsCollector.GroupHead>public void setScorer(Scorer scorer) throws IOException
setScorer in class CollectorIOExceptionpublic void setNextReader(AtomicReaderContext context) throws IOException
setNextReader in class CollectorIOExceptionCopyright © 2000-2014 Apache Software Foundation. All Rights Reserved.