org.apache.lucene.search.grouping.function

Class FunctionAllGroupHeadsCollector

java.lang.Object

org.apache.lucene.search.SimpleCollector

org.apache.lucene.search.grouping.AbstractAllGroupHeadsCollector<FunctionAllGroupHeadsCollector.GroupHead>

org.apache.lucene.search.grouping.function.FunctionAllGroupHeadsCollector

All Implemented Interfaces:

Collector, LeafCollector

public class FunctionAllGroupHeadsCollector
extends AbstractAllGroupHeadsCollector<FunctionAllGroupHeadsCollector.GroupHead>

An implementation of AbstractAllGroupHeadsCollector for retrieving the most relevant groups when grouping by ValueSource.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	FunctionAllGroupHeadsCollector.GroupHead Holds current head document for a single group.

Nested classes/interfaces inherited from class org.apache.lucene.search.grouping.AbstractAllGroupHeadsCollector

AbstractAllGroupHeadsCollector.TemporalResult

Field Summary

Fields

Modifier and Type	Field and Description
private FunctionValues.ValueFiller	filler
private ValueSource	groupBy
private java.util.Map<MutableValue,FunctionAllGroupHeadsCollector.GroupHead>	groups
private MutableValue	mval
private LeafReaderContext	readerContext
private Scorer	scorer
private Sort	sortWithinGroup
private java.util.Map<?,?>	vsContext

Fields inherited from class org.apache.lucene.search.grouping.AbstractAllGroupHeadsCollector

compIDXEnd, reversed, temporalResult

Constructor Summary

Constructors

Constructor and Description
FunctionAllGroupHeadsCollector(ValueSource groupBy, java.util.Map<?,?> vsContext, Sort sortWithinGroup) Constructs a FunctionAllGroupHeadsCollector instance.

Method Summary

Modifier and Type	Method and Description
protected void	doSetNextReader(LeafReaderContext context) This method is called before collecting context.
protected java.util.Collection<FunctionAllGroupHeadsCollector.GroupHead>	getCollectedGroupHeads() Returns the collected group heads.
boolean	needsScores() Indicates if document scores are needed by this collector.
protected void	retrieveGroupHeadAndAddIfNotExist(int doc) Returns the group head and puts it into AbstractAllGroupHeadsCollector.temporalResult.
void	setScorer(Scorer scorer) Called before successive calls to LeafCollector.collect(int).

Methods inherited from class org.apache.lucene.search.grouping.AbstractAllGroupHeadsCollector

collect, groupHeadsSize, retrieveGroupHeads, retrieveGroupHeads

Methods inherited from class org.apache.lucene.search.SimpleCollector

getLeafCollector

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

groupBy

private final ValueSource groupBy

vsContext

private final java.util.Map<?,?> vsContext

groups

private final java.util.Map<MutableValue,FunctionAllGroupHeadsCollector.GroupHead> groups

sortWithinGroup

private final Sort sortWithinGroup

filler

private FunctionValues.ValueFiller filler

mval

private MutableValue mval

readerContext

private LeafReaderContext readerContext

scorer

private Scorer scorer

Constructor Detail

FunctionAllGroupHeadsCollector

public FunctionAllGroupHeadsCollector(ValueSource groupBy,
                                      java.util.Map<?,?> vsContext,
                                      Sort sortWithinGroup)

Constructs a FunctionAllGroupHeadsCollector instance.

Parameters:

groupBy - The ValueSource to group by

vsContext - The ValueSource context

sortWithinGroup - The sort within a group

Method Detail

retrieveGroupHeadAndAddIfNotExist

protected void retrieveGroupHeadAndAddIfNotExist(int doc)
                                          throws java.io.IOException

Description copied from class: AbstractAllGroupHeadsCollector

Returns the group head and puts it into AbstractAllGroupHeadsCollector.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.

Specified by:

retrieveGroupHeadAndAddIfNotExist in class AbstractAllGroupHeadsCollector<FunctionAllGroupHeadsCollector.GroupHead>

Parameters:

doc - The document to retrieve the group head for.

Throws:

java.io.IOException - If I/O related errors occur

getCollectedGroupHeads

protected java.util.Collection<FunctionAllGroupHeadsCollector.GroupHead> getCollectedGroupHeads()

Description copied from class: AbstractAllGroupHeadsCollector

Returns the collected group heads. Subsequent calls should return the same group heads.

Specified by:

getCollectedGroupHeads in class AbstractAllGroupHeadsCollector<FunctionAllGroupHeadsCollector.GroupHead>

Returns:

the collected group heads

setScorer

public void setScorer(Scorer scorer)
               throws java.io.IOException

Description copied from interface: LeafCollector

Called before successive calls to LeafCollector.collect(int). Implementations that need the score of the current document (passed-in to LeafCollector.collect(int)), should save the passed-in Scorer and call scorer.score() when needed.

Specified by:

setScorer in interface LeafCollector

Overrides:

setScorer in class SimpleCollector

Throws:

java.io.IOException

doSetNextReader

protected void doSetNextReader(LeafReaderContext context)
                        throws java.io.IOException

Description copied from class: SimpleCollector

This method is called before collecting context.

Overrides:

doSetNextReader in class SimpleCollector

Throws:

java.io.IOException

needsScores

public boolean needsScores()

Description copied from interface: Collector

Indicates if document scores are needed by this collector.

Returns:

true if scores are needed.