org.apache.spark.partial

Class CountEvaluator

Object

org.apache.spark.partial.CountEvaluator

All Implemented Interfaces:

ApproximateEvaluator<Object,BoundedDouble>

public class CountEvaluator
extends Object
implements ApproximateEvaluator<Object,BoundedDouble>

An ApproximateEvaluator for counts.

TODO: There's currently a lot of shared code between this and GroupedCountEvaluator. It might be best to make this a special case of GroupedCountEvaluator with one group.

Constructor Summary

Constructors

Constructor and Description
CountEvaluator(int totalOutputs, double confidence)

Method Summary

Methods

Modifier and Type	Method and Description
BoundedDouble	currentResult()
void	merge(int outputId, long taskResult)
int	outputsMerged()
long	sum()

Methods inherited from class Object

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

Methods inherited from interface org.apache.spark.partial.ApproximateEvaluator

merge

Constructor Detail

CountEvaluator

public CountEvaluator(int totalOutputs,
              double confidence)

Method Detail

outputsMerged

public int outputsMerged()

sum

public long sum()

merge

public void merge(int outputId,
         long taskResult)

currentResult

public BoundedDouble currentResult()

Specified by:

currentResult in interface ApproximateEvaluator<Object,BoundedDouble>