Package org.apache.solr.analytics.function

Class MergingReductionCollectionManager

java.lang.Object

org.apache.solr.analytics.function.ReductionCollectionManager

org.apache.solr.analytics.function.MergingReductionCollectionManager

public class MergingReductionCollectionManager
extends ReductionCollectionManager

The ReductionCollectionManager used for distributed requests.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.solr.analytics.function.ReductionCollectionManager

ReductionCollectionManager.ReductionDataCollection

Field Summary

Fields inherited from class org.apache.solr.analytics.function.ReductionCollectionManager

reductionDataCollectors

Constructor Summary

Constructors

Constructor	Description
MergingReductionCollectionManager()
MergingReductionCollectionManager(ReductionDataCollector<?>[] reductionDataCollectors, Iterable<AnalyticsField> fields)

Method Summary

Modifier and Type	Method	Description
protected ReductionCollectionManager	createNewManager(ReductionDataCollector<?>[] reductionDataCollectors, Iterable<AnalyticsField> fields)	Create an ReductionCollectionManager to manage the given collectors and fields.
void	setData(ReductionCollectionManager.ReductionDataCollection dataCollection)	Finalize the reductions with the collected data stored in the parameter.

Methods inherited from class org.apache.solr.analytics.function.ReductionCollectionManager

addCollectTarget, addLastingCollectTarget, apply, clearLastingCollectTargets, collect, doSetNextReader, exportData, getUsedFields, merge, mergeData, needsCollection, newDataCollection, newDataCollectionIO, newDataCollectionTarget, prepareReductionDataIO, setShardInput, setShardOutput

Methods inherited from class java.lang.Object

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

Constructor Detail

MergingReductionCollectionManager

public MergingReductionCollectionManager()

MergingReductionCollectionManager

public MergingReductionCollectionManager(ReductionDataCollector<?>[] reductionDataCollectors,
                                         Iterable<AnalyticsField> fields)

Method Detail

createNewManager

protected ReductionCollectionManager createNewManager(ReductionDataCollector<?>[] reductionDataCollectors,
                                                      Iterable<AnalyticsField> fields)

Description copied from class: ReductionCollectionManager

Create an ReductionCollectionManager to manage the given collectors and fields.

Overrides:

createNewManager in class ReductionCollectionManager

Parameters:

reductionDataCollectors - Reduction collectors

fields - fields used by the reductions

Returns:

a collection manager

setData

public void setData(ReductionCollectionManager.ReductionDataCollection dataCollection)

Description copied from class: ReductionCollectionManager

Finalize the reductions with the collected data stored in the parameter. Once the data is finalized, the ReductionFunctions that use these ReductionDataCollectors act like regular AnalyticsValue classes that can be accessed through their get<value-type> methods.

Overrides:

setData in class ReductionCollectionManager

Parameters:

dataCollection - the collection of reduction data to compute results for