Uses of Interface
com.gigaspaces.async.AsyncResultsReducer

Packages that use AsyncResultsReducer

Package	Description
com.gigaspaces.async	Provides GigaSpaces asynchronous operations related interfaces.
com.gigaspaces.async.internal
com.gigaspaces.executor
com.gigaspaces.internal.client.spaceproxy.executors
com.gigaspaces.internal.server.space.repartitioning
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.internal
org.openspaces.core.executor.juc
org.openspaces.core.executor.support
org.openspaces.events.support
org.openspaces.pu.container.jee.jetty.session
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

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

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

Constructor and Description
CompoundFuture(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer)
CompoundFuture(AsyncFuture<T>[] futures, AsyncResultsReducer<T,R> reducer, AsyncResultFilter<T> moderator)

Uses of AsyncResultsReducer in com.gigaspaces.executor

Subinterfaces of AsyncResultsReducer in com.gigaspaces.executor

Modifier and Type	Interface and Description
interface	DistributedSpaceTask<T extends Serializable,R> an extended SpaceTask that is being used in broadcast.

Uses of AsyncResultsReducer in com.gigaspaces.internal.client.spaceproxy.executors

Classes in com.gigaspaces.internal.client.spaceproxy.executors that implement AsyncResultsReducer

Modifier and Type	Class and Description
class	AddReplicationGatewayTargetTask
class	AddTypeIndexesTask
class	BroadcastTableSpaceTask
class	CloseIteratorDistributedSpaceTask
class	CollocatedJoinSpaceTask
class	GetBatchForIteratorDistributedSpaceTask
class	GetTypeDescriptorTask
class	RegisterTypeDescriptorTask
class	RemoveReplicationGatewayTargetTask
class	RenewIteratorLeaseDistributedSpaceTask
class	SpaceDataSourceLoadTask
class	SystemDistributedTask<T extends Serializable>
class	UnregisterTypeDescriptorTask

Uses of AsyncResultsReducer in com.gigaspaces.internal.server.space.repartitioning

Classes in com.gigaspaces.internal.server.space.repartitioning that implement AsyncResultsReducer

Modifier and Type	Class and Description
class	CopyChunksTask
class	DeleteChunksTask

Uses of AsyncResultsReducer in org.openspaces.core

Methods in org.openspaces.core with parameters of type AsyncResultsReducer

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

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

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

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

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 AsyncResultsReducer in org.openspaces.core.executor.juc

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

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 AsyncResultsReducer

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

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

Modifier and Type	Class and Description
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.pu.container.jee.jetty.session

Classes in org.openspaces.pu.container.jee.jetty.session that implement AsyncResultsReducer

Modifier and Type	Class and Description
class	FindNonExpiredSessionsTask

Uses of AsyncResultsReducer in org.openspaces.remoting

Classes in org.openspaces.remoting that implement AsyncResultsReducer

Modifier and Type	Class and Description
class	ExecutorRemotingTask<T extends Serializable> A Task that can be used to simulate remote invocation with SpaceRemotingServiceExporter.