org.apache.spark.partial

Class GroupedCountEvaluator<T>

Object

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

All Implemented Interfaces:

ApproximateEvaluator<org.apache.spark.util.collection.OpenHashMap<T,Object>,scala.collection.Map<T,BoundedDouble>>

public class GroupedCountEvaluator<T>
extends Object
implements ApproximateEvaluator<org.apache.spark.util.collection.OpenHashMap<T,Object>,scala.collection.Map<T,BoundedDouble>>

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

Constructor Summary

Constructors

Constructor and Description
GroupedCountEvaluator(int totalOutputs, double confidence, scala.reflect.ClassTag<T> evidence$1)

Method Summary

Methods

Modifier and Type	Method and Description
scala.collection.Map<T,BoundedDouble>	currentResult()
void	merge(int outputId, org.apache.spark.util.collection.OpenHashMap<T,Object> taskResult)
int	outputsMerged()
org.apache.spark.util.collection.OpenHashMap<T,Object>	sums()

Methods inherited from class Object

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

Constructor Detail

GroupedCountEvaluator

public GroupedCountEvaluator(int totalOutputs,
                     double confidence,
                     scala.reflect.ClassTag<T> evidence$1)

Method Detail

outputsMerged

public int outputsMerged()

sums

public org.apache.spark.util.collection.OpenHashMap<T,Object> sums()

merge

public void merge(int outputId,
         org.apache.spark.util.collection.OpenHashMap<T,Object> taskResult)

Specified by:

merge in interface ApproximateEvaluator<org.apache.spark.util.collection.OpenHashMap<T,Object>,scala.collection.Map<T,BoundedDouble>>

currentResult

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

Specified by:

currentResult in interface ApproximateEvaluator<org.apache.spark.util.collection.OpenHashMap<T,Object>,scala.collection.Map<T,BoundedDouble>>