org.apache.spark.partial

Interface ApproximateEvaluator<U,R>

All Known Implementing Classes:

CountEvaluator, GroupedCountEvaluator, GroupedMeanEvaluator, GroupedSumEvaluator, MeanEvaluator, SumEvaluator

public interface ApproximateEvaluator<U,R>

An object that computes a function incrementally by merging in results of type U from multiple tasks. Allows partial evaluation at any point by calling currentResult().

Method Summary

Methods

Modifier and Type	Method and Description
R	currentResult()
void	merge(int outputId, U taskResult)

Method Detail

merge

void merge(int outputId,
         U taskResult)

currentResult

R currentResult()