Package org.apache.spark.partial

Interface ApproximateEvaluator<U,R>

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

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

  • Method Details

    • currentResult

      R currentResult()

    • merge

      void merge(int outputId, U taskResult)