org.apache.spark.partial

Class GroupedMeanEvaluator<T>

Object

org.apache.spark.partial.GroupedMeanEvaluator<T>

All Implemented Interfaces:

ApproximateEvaluator<java.util.HashMap<T,StatCounter>,scala.collection.Map<T,BoundedDouble>>

public class GroupedMeanEvaluator<T>
extends Object
implements ApproximateEvaluator<java.util.HashMap<T,StatCounter>,scala.collection.Map<T,BoundedDouble>>

An ApproximateEvaluator for means by key. Returns a map of key to confidence interval.

Constructor Summary

Constructors

Constructor and Description
GroupedMeanEvaluator(int totalOutputs, double confidence)

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.Map<T,BoundedDouble>	currentResult()
void	merge(int outputId, java.util.HashMap<T,StatCounter> taskResult)
int	outputsMerged()
java.util.HashMap<T,StatCounter>	sums()

Methods inherited from class Object

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

Constructor Detail

GroupedMeanEvaluator

public GroupedMeanEvaluator(int totalOutputs,
                    double confidence)

Method Detail

outputsMerged

public int outputsMerged()

sums

public java.util.HashMap<T,StatCounter> sums()

merge

public void merge(int outputId,
         java.util.HashMap<T,StatCounter> taskResult)

Specified by:

merge in interface ApproximateEvaluator<java.util.HashMap<T,StatCounter>,scala.collection.Map<T,BoundedDouble>>

currentResult

public scala.collection.Map<T,BoundedDouble> currentResult()

Specified by:

currentResult in interface ApproximateEvaluator<java.util.HashMap<T,StatCounter>,scala.collection.Map<T,BoundedDouble>>