org.openspaces.core.executor.support
Class AbstractDelegatingDistributedTask<T extends Serializable,R>

java.lang.Object
  org.openspaces.core.executor.support.SimpleDelegatingTask<T>
      org.openspaces.core.executor.support.AbstractDelegatingDistributedTask<T,R>

All Implemented Interfaces:

com.gigaspaces.async.AsyncResultFilter<T>, com.gigaspaces.async.AsyncResultsReducer<T,R>, Serializable, DistributedTask<T,R>, DelegatingTask<T>, Task<T>, TaskRoutingProvider

Direct Known Subclasses:

AvgTask, MaxTask, MinTask, PrivilegedDistributedTask, SimpleDelegatingDistributedTask, SumTask

public abstract class AbstractDelegatingDistributedTask<T extends Serializable,R>
extends SimpleDelegatingTask<T>
implements DistributedTask<T,R>, com.gigaspaces.async.AsyncResultFilter<T>

A base class for delegating tasks that are also distributed tasks

Author:

kimchy

See Also:

Serialized Form

Nested Class Summary

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

com.gigaspaces.async.AsyncResultFilter.Decision

Constructor Summary

protected	AbstractDelegatingDistributedTask()
	AbstractDelegatingDistributedTask(Task<T> task)
	AbstractDelegatingDistributedTask(Task<T> task, com.gigaspaces.async.AsyncResultFilter<T> filter)

Method Summary

protected void	_readExternal(ObjectInput input)
protected void	_writeExternal(ObjectOutput output)
protected com.gigaspaces.async.AsyncResultFilter<T>	getFilter()
com.gigaspaces.async.AsyncResultFilter.Decision	onResult(com.gigaspaces.async.AsyncResultFilterEvent<T> event)

Methods inherited from class org.openspaces.core.executor.support.SimpleDelegatingTask

execute, getDelegatedTask, getRouting

Methods inherited from class java.lang.Object

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

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

execute

Methods inherited from interface com.gigaspaces.async.AsyncResultsReducer

reduce

Constructor Detail

AbstractDelegatingDistributedTask

protected AbstractDelegatingDistributedTask()

AbstractDelegatingDistributedTask

public AbstractDelegatingDistributedTask(Task<T> task)

AbstractDelegatingDistributedTask

public AbstractDelegatingDistributedTask(Task<T> task,
                                         com.gigaspaces.async.AsyncResultFilter<T> filter)

Method Detail

onResult

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

Specified by:

onResult in interface com.gigaspaces.async.AsyncResultFilter<T extends Serializable>

getFilter

protected com.gigaspaces.async.AsyncResultFilter<T> getFilter()

_writeExternal

protected void _writeExternal(ObjectOutput output)
                       throws IOException

Overrides:

_writeExternal in class SimpleDelegatingTask<T extends Serializable>

Throws:

IOException

_readExternal

protected void _readExternal(ObjectInput input)
                      throws IOException,
                             ClassNotFoundException

Overrides:

_readExternal in class SimpleDelegatingTask<T extends Serializable>

Throws:

IOException

ClassNotFoundException