org.apache.spark.partial

Class GroupedSumEvaluator<T>

Object

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

All Implemented Interfaces:

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

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

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

Constructor Summary

Constructors

Constructor and Description
GroupedSumEvaluator(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

GroupedSumEvaluator

public GroupedSumEvaluator(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>>