org.apache.spark.partial

Class PartialResult<R>

Object

org.apache.spark.partial.PartialResult<R>

public class PartialResult<R>
extends Object

Constructor Summary

Constructors

Constructor and Description
PartialResult(R initialVal, boolean isFinal)

Method Summary

Methods

Modifier and Type	Method and Description
R	getFinalValue() Blocking method to wait for and return the final value.
R	initialValue()
boolean	isInitialValueFinal()
<T> PartialResult<T>	map(scala.Function1<R,T> f) Transform this PartialResult into a PartialResult of type T.
PartialResult<R>	onComplete(scala.Function1<R,scala.runtime.BoxedUnit> handler) Set a handler to be called when this PartialResult completes.
void	onFail(scala.Function1<Exception,scala.runtime.BoxedUnit> handler) Set a handler to be called if this PartialResult's job fails.
String	toString()

Methods inherited from class Object

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

Constructor Detail

PartialResult

public PartialResult(R initialVal,
             boolean isFinal)

Method Detail

initialValue

public R initialValue()

isInitialValueFinal

public boolean isInitialValueFinal()

getFinalValue

public R getFinalValue()

Blocking method to wait for and return the final value.

onComplete

public PartialResult<R> onComplete(scala.Function1<R,scala.runtime.BoxedUnit> handler)

Set a handler to be called when this PartialResult completes. Only one completion handler is supported per PartialResult.

onFail

public void onFail(scala.Function1<Exception,scala.runtime.BoxedUnit> handler)

Set a handler to be called if this PartialResult's job fails. Only one failure handler is supported per PartialResult.

map

public <T> PartialResult<T> map(scala.Function1<R,T> f)

Transform this PartialResult into a PartialResult of type T.

toString

public String toString()

Overrides:

toString in class Object