GigaSpaces XAP 7.0 API

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.
 


GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.