public class IEvaluationReduceFunction<T extends IEvaluation>
extends java.lang.Object
implements org.apache.spark.api.java.function.Function2<T,T,T>
IEvaluateFlatMapFunction
for distributed evaluationConstructor and Description |
---|
IEvaluationReduceFunction() |
Modifier and Type | Method and Description |
---|---|
T |
call(T eval1,
T eval2) |
public T call(T eval1, T eval2) throws java.lang.Exception
call
in interface org.apache.spark.api.java.function.Function2<T extends IEvaluation,T extends IEvaluation,T extends IEvaluation>
java.lang.Exception