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

Packages that use DistributedTask

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

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

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

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

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.juc

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

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

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.

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

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

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.remoting

Classes in org.openspaces.remoting that implement DistributedTask

class

ExecutorRemotingTask<T extends Serializable> A Task that can be used to simulate remote invcation with SpaceRemotingServiceExporter.