Uses of Interface
org.openspaces.core.executor.DistributedTask

Packages that use DistributedTask

Package	Description
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.extensions
org.openspaces.remoting	A package including OpenSpaces support for Sync and Async remoting inspired by other Spring remoting integrations.

Uses of DistributedTask in org.openspaces.core

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

Modifier and Type	Method and Description
ExecutorBuilder<T,R>	ExecutorBuilder.add(DistributedTask<T,R> task) Adds a task to be executed similarly to GigaSpace.execute(org.openspaces.core.executor.DistributedTask)
ExecutorBuilder<T,R>	ExecutorBuilder.add(DistributedTask<T,R> task, Object... routing) Adds a task to be executed similarly to GigaSpace.execute(org.openspaces.core.executor.DistributedTask, Object[])
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.distExecute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.execute(DistributedTask<T,R> task)
<T extends Serializable,R> AsyncFuture<R>	GigaSpace.execute(DistributedTask<T,R> task) Executes the task on all the primary space nodes within the cluster (broadcast).
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.execute(DistributedTask<T,R> task, AsyncFutureListener<R> listener)
<T extends Serializable,R> AsyncFuture<R>	DefaultGigaSpace.execute(DistributedTask<T,R> task, Object... routings)
<T extends Serializable,R> AsyncFuture<R>	GigaSpace.execute(DistributedTask<T,R> task, Object... routing) Executes a task on all the nodes that correspond to the list of routing values.

Uses of DistributedTask in org.openspaces.core.executor

Methods in org.openspaces.core.executor that return DistributedTask

Modifier and Type	Method and Description
static <T extends Serializable,R> DistributedTask<T,R>	TaskExecutors.privilegedTask(DistributedTask<T,R> task) Constructs a new privileged task wrapping the actual task to execute.
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) 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.

Methods in org.openspaces.core.executor with parameters of type DistributedTask

Modifier and Type	Method and Description
static <T extends Serializable,R> DistributedTask<T,R>	TaskExecutors.privilegedTask(DistributedTask<T,R> task) Constructs a new privileged task wrapping the actual task to execute.
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.

Uses of DistributedTask in org.openspaces.core.executor.internal

Constructors in org.openspaces.core.executor.internal with parameters of type DistributedTask

Constructor and Description
InternalDistributedSpaceTaskWrapper(DistributedTask<T,R> task)

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

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

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.

Uses of DistributedTask in org.openspaces.core.executor.support

Classes in org.openspaces.core.executor.support that implement DistributedTask

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.

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

Constructor and Description
PrivilegedDistributedTask(DistributedTask<T,R> task) Constructs a new privileged task wrapping the actual task to execute.
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)
SimpleDelegatingDistributedTask(DistributedTask<T,R> task, AsyncResultFilter<T> filter)

Uses of DistributedTask in org.openspaces.events.support

Classes in org.openspaces.events.support that implement DistributedTask

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 DistributedTask in org.openspaces.extensions

Methods in org.openspaces.extensions with parameters of type DistributedTask

Modifier and Type	Method and Description
static <T extends Serializable,R> CompletableFuture<R>	AsyncExtension.execute(GigaSpace gigaSpace, DistributedTask<T,R> task)

Uses of DistributedTask in org.openspaces.remoting

Classes in org.openspaces.remoting that implement DistributedTask

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