Uses of Interface
com.gigaspaces.async.AsyncResultFilter

Packages that use AsyncResultFilter

Package	Description
com.gigaspaces.async	Provides GigaSpaces asynchronous operations related interfaces.
com.gigaspaces.async.internal
org.openspaces.core.executor
org.openspaces.core.executor.internal
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

Modifier and Type	Method and Description
static <T,R> AsyncFuture<R>	FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> moderator)

Uses of AsyncResultFilter in com.gigaspaces.async.internal

Constructors in com.gigaspaces.async.internal with parameters of type AsyncResultFilter

Constructor and Description
CompoundFuture(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

Modifier and Type	Method and Description
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.internal

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

Modifier and Type	Class and Description
class	InternalDistributedSpaceTaskWrapper<T extends Serializable,R> An internal implementation of DistributedSpaceTask that wraps the actual Task to be executed.

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

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

Modifier and Type	Class and Description
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

Constructor and Description
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

Modifier and Type	Class and Description
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 distrubuted 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 distrubuted 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 implementation of delegating distributed task that accepts the task to delegate to.
class	SumTask<T extends Number,R extends Number> A sum distrubuted 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

Modifier and Type	Method and Description
protected AsyncResultFilter<T>	AbstractDelegatingDistributedTask.getFilter()

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

Constructor and Description
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.