Package org.openspaces.core.executor.juc

Class CallableDistributedTaskAdapter<T extends Serializable,R>

java.lang.Object

org.openspaces.core.executor.juc.CallableTaskAdapter<T>

org.openspaces.core.executor.juc.CallableDistributedTaskAdapter<T,R>

All Implemented Interfaces:

AsyncResultFilter<T>, AsyncResultsReducer<T,R>, SmartExternalizable, Externalizable, Serializable, DistributedTask<T,R>, ProcessObjectsProvider, Task<T>, TaskRoutingProvider

public class CallableDistributedTaskAdapter<T extends Serializable,R>
extends CallableTaskAdapter<T>
implements DistributedTask<T,R>, AsyncResultFilter<T>

An adapter allowing to execute a Callable in a distributed fashion. In such a case, a AsyncResultsReducer must be implemented or provided (see the different constructors). An optional AsyncResultFilter can be also implemented or provided.

Author:

kimchy

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface com.gigaspaces.async.AsyncResultFilter

AsyncResultFilter.Decision

Constructor Summary

Constructors

Constructor	Description
CallableDistributedTaskAdapter()	Here just for externalizable.
CallableDistributedTaskAdapter(Callable<T> callable)	Constructs a new callable distributed task adapter.
CallableDistributedTaskAdapter(Callable<T> callable, AsyncResultsReducer<T,R> reducer)	Constructs a new callable distributed task adapter with a separate reducer.
CallableDistributedTaskAdapter(Callable<T> callable, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter)	Constructs a new callable distributed task adapter with a separate reducer and filter.

Method Summary

Modifier and Type	Method	Description
AsyncResultFilter.Decision	onResult(AsyncResultFilterEvent<T> event)	If a filter is provided in one of the constructor methods, will delegate the call to it.
void	readExternal(ObjectInput in)
R	reduce(List<AsyncResult<T>> results)	Delegates the call to the provided reducer.
void	writeExternal(ObjectOutput out)

Methods inherited from class org.openspaces.core.executor.juc.CallableTaskAdapter

execute, getCallable, getObjectsToProcess, getRouting

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Methods inherited from interface org.openspaces.core.executor.Task

execute

Constructor Details

CallableDistributedTaskAdapter

public CallableDistributedTaskAdapter()

Here just for externalizable.

CallableDistributedTaskAdapter

public CallableDistributedTaskAdapter(Callable<T> callable)
                               throws IllegalArgumentException

Constructs a new callable distributed task adapter. The callable in this case must implements {link AsyncResultReducer} and optionally can implement AsyncResultFilter.

Throws:

IllegalArgumentException

CallableDistributedTaskAdapter

public CallableDistributedTaskAdapter(Callable<T> callable,
 AsyncResultsReducer<T,R> reducer)
                               throws IllegalArgumentException

Constructs a new callable distributed task adapter with a separate reducer. The reducer or the callable can optionally implement AsyncResultFilter.

Throws:

IllegalArgumentException

CallableDistributedTaskAdapter

public CallableDistributedTaskAdapter(Callable<T> callable,
 AsyncResultsReducer<T,R> reducer,
 AsyncResultFilter<T> filter)
                               throws IllegalArgumentException

Constructs a new callable distributed task adapter with a separate reducer and filter.

Throws:

IllegalArgumentException

Method Details

reduce

public R reduce(List<AsyncResult<T>> results)
         throws Exception

Delegates the call to the provided reducer.

Specified by:

reduce in interface AsyncResultsReducer<T extends Serializable,R>

Throws:

Exception

onResult

public AsyncResultFilter.Decision onResult(AsyncResultFilterEvent<T> event)

If a filter is provided in one of the constructor methods, will delegate the call to it. Otherwise it will return the default AsyncResultFilter.Decision.CONTINUE.

Specified by:

onResult in interface AsyncResultFilter<T extends Serializable>

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Overrides:

writeExternal in class CallableTaskAdapter<T extends Serializable>

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Overrides:

readExternal in class CallableTaskAdapter<T extends Serializable>

Throws:

IOException

ClassNotFoundException