GigaSpaces XAP 7.0 API

Uses of Interface
com.gigaspaces.async.AsyncResultsReducer

Packages that use AsyncResultsReducer
com.gigaspaces.async Provides GigaSpaces asynchronous operations related interfaces. 
org.openspaces.core Top level core package holding main OpenSpaces API for Space (GigaSpace) and Map (GigaMap) and the ability to create it. 
org.openspaces.core.executor   
org.openspaces.core.executor.juc   
org.openspaces.core.executor.support   
org.openspaces.events.support   
org.openspaces.remoting A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting integrations. 
 

Uses of AsyncResultsReducer in com.gigaspaces.async
 

Methods in com.gigaspaces.async with parameters of type AsyncResultsReducer
static
<T,R> AsyncFuture<R>
FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer)
           
static
<T,R> AsyncFuture<R>
FutureFactory.create(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> moderator)
           
 

Uses of AsyncResultsReducer in org.openspaces.core
 

Methods in org.openspaces.core with parameters of type AsyncResultsReducer
<T extends Serializable,R>
ExecutorBuilder<T,R>
DefaultGigaSpace.executorBuilder(AsyncResultsReducer<T,R> reducer)
           
<T extends Serializable,R>
ExecutorBuilder<T,R>
GigaSpace.executorBuilder(AsyncResultsReducer<T,R> reducer)
          Constructs an executor builder allowing to accumulate different tasks required to be executed into a single execute mechanism with all the results reduced by the reducer provided.
 

Uses of AsyncResultsReducer in org.openspaces.core.executor
 

Subinterfaces of AsyncResultsReducer in org.openspaces.core.executor
 interface DistributedTask<T extends Serializable,R>
          A distributed task is a Task that is executed on several space nodes, requiring to reduce(java.util.List) the list of AsyncResults.
 

Methods in org.openspaces.core.executor with parameters of type AsyncResultsReducer
static
<T extends Serializable,R>
DistributedTask<T,R>
TaskExecutors.task(Callable<T> callable, AsyncResultsReducer<T,R> reducer)
          Constructs a new callable distributed task adapter with a separate reducer.
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)
          Constructs a new runnable distributed task adapter with a separate reducer.
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)
          Constructs a new runnable distributed task adapter with a separate reducer.
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 AsyncResultsReducer in org.openspaces.core.executor.juc
 

Classes in org.openspaces.core.executor.juc that implement AsyncResultsReducer
 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 AsyncResultsReducer
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.
RunnableDistributedTaskAdapter(Runnable runnable, AsyncResultsReducer<T,R> reducer)
          Constructs a new runnable distributed task adapter with a separate reducer.
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)
          Constructs a new runnable distributed task adapter with a separate reducer.
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 AsyncResultsReducer in org.openspaces.core.executor.support
 

Classes in org.openspaces.core.executor.support that implement AsyncResultsReducer
 class AbstractDelegatingDistributedTask<T extends Serializable,R>
          A base class for delegating tasks that are also distributed tasks
 class AvgReducer<T extends Number,R extends Number>
          A default implementation of a reducer that averages all types T into a result R.
 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 MaxReducer<T extends Number>
          A default implementation of a reducer that returnt the maximum of T.
 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 MinReducer<T extends Number>
          A default implementation of a reducer that returnt the minimum of T.
 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 SumReducer<T extends Number,R extends Number>
          A default implementation of a reducer that sums all types T into a result R.
 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.
 

Uses of AsyncResultsReducer in org.openspaces.events.support
 

Classes in org.openspaces.events.support that implement AsyncResultsReducer
 class RegisterDistributedEventContainerTask
          A task that registers a dynamically added event container in a distributed manner.
 class UnregisterDistributedEventContainerTask
          A task that unregisters (stops and disposes it) a dynamically added event container in a distributed manner.
 

Uses of AsyncResultsReducer in org.openspaces.remoting
 

Classes in org.openspaces.remoting that implement AsyncResultsReducer
 class ExecutorRemotingTask<T extends Serializable>
          A Task that can be used to simulate remote invcation with SpaceRemotingServiceExporter.
 


GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.