Package org.apache.solr.search.facet

Class UniqueBlockAgg.UniqueBlockSlotAcc

java.lang.Object

org.apache.solr.search.facet.SlotAcc

org.apache.solr.search.facet.UniqueBlockAgg.UniqueBlockSlotAcc

All Implemented Interfaces:

Closeable, AutoCloseable

Enclosing class:

UniqueBlockAgg

protected static class UniqueBlockAgg.UniqueBlockSlotAcc
extends SlotAcc

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.search.facet.SlotAcc

SlotAcc.DoubleFuncSlotAcc, SlotAcc.FuncSlotAcc, SlotAcc.IntSlotAcc, SlotAcc.LongFuncSlotAcc, SlotAcc.Resizer, SlotAcc.SlotContext

Field Summary

Fields

Modifier and Type	Field	Description
protected int[]	lastSeenValuesPerSlot

Fields inherited from class org.apache.solr.search.facet.SlotAcc

currentDocBase, currentReaderContext, fcontext

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	UniqueBlockSlotAcc(FacetContext fcontext, SchemaField field, int numSlots)

Method Summary

Modifier and Type	Method	Description
void	calcCounts()
void	collect(int doc, int slotNum, IntFunction<SlotAcc.SlotContext> slotContext)	All subclasses must override this method to collect documents.
protected void	collectOrdToSlot(int slotNum, int ord)
int	compare(int slotA, int slotB)
long	getNonShardValue(int slot)	Returns the current slot value as long This is used to get non-sharded value
Object	getValue(int slot)
protected org.apache.lucene.util.BytesRef	lookupOrd(int ord)
void	reset()	Called to reset the acc to a fresh state, ready for reuse
void	resetIterators()	Typically called from setNextReader to reset docValue iterators
void	resize(SlotAcc.Resizer resizer)
void	setNextReader(org.apache.lucene.index.LeafReaderContext readerContext)	NOTE: this currently detects when it is being reused and calls resetIterators by comparing reader ords with previous calls to setNextReader.

Methods inherited from class org.apache.solr.search.facet.SlotAcc

close, collect, setValues, toString

Methods inherited from class java.lang.Object

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

Field Detail

lastSeenValuesPerSlot

protected int[] lastSeenValuesPerSlot

Constructor Detail

UniqueBlockSlotAcc

protected UniqueBlockSlotAcc(FacetContext fcontext,
                             SchemaField field,
                             int numSlots)
                      throws IOException

Throws:

IOException

Method Detail

collectOrdToSlot

protected void collectOrdToSlot(int slotNum,
                                int ord)

calcCounts

public void calcCounts()

reset

public void reset()
           throws IOException

Description copied from class: SlotAcc

Called to reset the acc to a fresh state, ready for reuse

Throws:

IOException

resize

public void resize(SlotAcc.Resizer resizer)

getValue

public Object getValue(int slot)
                throws IOException

Throws:

IOException

getNonShardValue

public long getNonShardValue(int slot)

Returns the current slot value as long This is used to get non-sharded value

resetIterators

public void resetIterators()
                    throws IOException

Description copied from class: SlotAcc

Typically called from setNextReader to reset docValue iterators

Overrides:

resetIterators in class SlotAcc

Throws:

IOException

lookupOrd

protected org.apache.lucene.util.BytesRef lookupOrd(int ord)
                                             throws IOException

Throws:

IOException

setNextReader

public void setNextReader(org.apache.lucene.index.LeafReaderContext readerContext)
                   throws IOException

Description copied from class: SlotAcc

NOTE: this currently detects when it is being reused and calls resetIterators by comparing reader ords with previous calls to setNextReader. For this reason, current users must call setNextReader in segment order. Failure to do so will cause worse performance.

Overrides:

setNextReader in class SlotAcc

Throws:

IOException

collect

public void collect(int doc,
                    int slotNum,
                    IntFunction<SlotAcc.SlotContext> slotContext)
             throws IOException

Description copied from class: SlotAcc

All subclasses must override this method to collect documents. This method is called by the default impl of SlotAcc.collect(DocSet, int, IntFunction) but it's also neccessary if this accumulator is used for sorting.

Specified by:

collect in class SlotAcc

Parameters:

doc - Single Segment docId (relative to the current LeafReaderContext to collect

slotNum - The slot number to collect this document in

slotContext - A callback that can be used for Accumulators that would like additional info about the current slot -- the IntFunction is only garunteed to be valid for the current slot, and the SlotAcc.SlotContext returned is only valid for the duration of the collect() call.

Throws:

IOException

compare

public int compare(int slotA,
                   int slotB)

Specified by:

compare in class SlotAcc