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 distrubuted 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 return the minimum of T.
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	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 distrubuted 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 invocation with SpaceRemotingServiceExporter.