Uses of Interface
com.gigaspaces.async.AsyncResultFilter

Packages that use AsyncResultFilter

com.gigaspaces.async	Provides GigaSpaces asynchronous operations related interfaces.
org.openspaces.core.executor
org.openspaces.core.executor.juc
org.openspaces.core.executor.support

Uses of AsyncResultFilter in com.gigaspaces.async

Methods in com.gigaspaces.async with parameters of type AsyncResultFilter

static <T,R> AsyncFuture<R>

FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> moderator)

Uses of AsyncResultFilter in org.openspaces.core.executor

Methods in org.openspaces.core.executor with parameters of type AsyncResultFilter

static <T extends Serializable,R> DistributedTask<T,R>	TaskExecutors.privilegedTask(DistributedTask<T,R> task, AsyncResultFilter<T> filter) Constructs a new privileged task wrapping the actual task and filter to execute.
static <T extends Serializable,R> DistributedTask<T,R>	TaskExecutors.task(Callable<T> callable, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter) Constructs a new callable distributed task adapter with a separate reducer and filter.
static <T extends Serializable,R> DistributedTask<T,R>	TaskExecutors.task(Runnable runnable, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter) Constructs a new runnable distributed task adapter with a separate reducer and filter.
static <T extends Serializable,R> DistributedTask<T,R>	TaskExecutors.task(Runnable runnable, T result, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter) Constructs a new runnable distributed task adapter with a separate reducer and filter.

Uses of AsyncResultFilter in org.openspaces.core.executor.juc

Classes in org.openspaces.core.executor.juc that implement AsyncResultFilter

class	CallableDistributedTaskAdapter<T extends Serializable,R> An adapter allowing to execute a Callable in a distributed fashion.
class	RunnableDistributedTaskAdapter<T extends Serializable,R> An adapter allowing to execute a Runnable in a distributed fashion.

Constructors in org.openspaces.core.executor.juc with parameters of type AsyncResultFilter

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

RunnableDistributedTaskAdapter(Runnable runnable, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter)
Constructs a new runnable distributed task adapter with a separate reducer and filter.

RunnableDistributedTaskAdapter(Runnable runnable, T result, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> filter)
Constructs a new runnable distributed task adapter with a separate reducer and filter.

Uses of AsyncResultFilter in org.openspaces.core.executor.support

Classes in org.openspaces.core.executor.support that implement AsyncResultFilter

class	AbstractDelegatingDistributedTask<T extends Serializable,R> A base class for delegating tasks that are also distributed tasks
class	AvgTask<T extends Number,R extends Number> A sum distrubted task that accepts a Task to delegate the actual execution to and implements the AvgTask.reduce(java.util.List) operation.
class	MaxTask<T extends Number> A max distrubted task that accepts a Task to delegate the actual execution to and implements the MaxTask.reduce(java.util.List) operation.
class	MinTask<T extends Number> A min distrubted task that accepts a Task to delegate the actual execution to and implements the MinTask.reduce(java.util.List) operation.
class	PrivilegedDistributedTask<T extends Serializable,R> A delegating distrubuted task (with an optional filter) that runs under established access control settings.
class	SimpleDelegatingDistributedTask<T extends Serializable,R> A simple impelemntation of delegating distributed task that accepts the task to delegate to.
class	SumTask<T extends Number,R extends Number> A sum distrubted task that accepts a Task to delegate the actual execution to and implements the SumTask.reduce(java.util.List) operation.

Methods in org.openspaces.core.executor.support that return AsyncResultFilter

protected AsyncResultFilter<T>

AbstractDelegatingDistributedTask.getFilter()

Constructors in org.openspaces.core.executor.support with parameters of type AsyncResultFilter

AbstractDelegatingDistributedTask(Task<T> task, AsyncResultFilter<T> filter)

AvgTask(Class<R> reduceType, Task<T> task, AsyncResultFilter<T> filter)
Constructs a new sum distributed task that delegates the actual execution to th provided task.

MaxTask(Class<T> reduceType, Task<T> task, AsyncResultFilter<T> filter)
Constructs a new sum distributed task that delegates the actual execution to th provided task.

MinTask(Class<T> reduceType, Task<T> task, AsyncResultFilter<T> filter)
Constructs a new sum distributed task that delegates the actual execution to th provided task.

PrivilegedDistributedTask(DistributedTask<T,R> task, AsyncResultFilter<T> filter)
Constructs a new privileged task wrapping the actual task and filter to execute.

SimpleDelegatingDistributedTask(DistributedTask<T,R> task, AsyncResultFilter<T> filter)

SumTask(Class<R> reduceType, Task<T> task, AsyncResultFilter<T> filter)
Constructs a new sum distributed task that delegates the actual execution to th provided task.