GigaSpaces XAP 7.0 API

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.
 


GigaSpaces XAP 7.0 API

Copyright © GigaSpaces.