Package org.apache.spark.partial
Class PartialResult<R>
Object
org.apache.spark.partial.PartialResult<R>
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionBlocking method to wait for and return the final value.boolean
<T> PartialResult<T>
Transform this PartialResult into a PartialResult of type T.onComplete
(scala.Function1<R, scala.runtime.BoxedUnit> handler) Set a handler to be called when this PartialResult completes.void
Set a handler to be called if this PartialResult's job fails.toString()
-
Constructor Details
-
PartialResult
-
-
Method Details
-
getFinalValue
Blocking method to wait for and return the final value.- Returns:
- (undocumented)
-
initialValue
-
isInitialValueFinal
public boolean isInitialValueFinal() -
map
Transform this PartialResult into a PartialResult of type T.- Parameters:
f
- (undocumented)- Returns:
- (undocumented)
-
onComplete
Set a handler to be called when this PartialResult completes. Only one completion handler is supported per PartialResult.- Parameters:
handler
- (undocumented)- Returns:
- (undocumented)
-
onFail
Set a handler to be called if this PartialResult's job fails. Only one failure handler is supported per PartialResult.- Parameters:
handler
- (undocumented)
-
toString
-