<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.affinityCall(Collection<String> cacheNames,
int partId,
Callable<R> job,
Collection<ClusterNode> nodes,
String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.affinityRun(Collection<String> cacheNames,
int partId,
Runnable job,
Collection<ClusterNode> nodes,
String execName) |
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
Collection<ClusterNode> nodes) |
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
Collection<ClusterNode> nodes,
boolean sys,
String execName) |
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
Collection<ClusterNode> nodes,
String execName) |
<R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<ClusterNode> nodes) |
<R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<ClusterNode> nodes,
boolean sys,
String execName) |
<R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
Collection<ClusterNode> nodes,
String execName) |
<T,R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
Collection<? extends T> args,
Collection<ClusterNode> nodes,
String execName) |
<T,R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
T arg,
Collection<ClusterNode> nodes,
String execName) |
<T,R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.callAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc,
Collection<ClusterNode> nodes,
String execName) |
<R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode,
Collection<? extends Callable<R1>> jobs,
IgniteReducer<R1,R2> rdc,
Collection<ClusterNode> nodes,
String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
Collection<ClusterNode> nodes,
boolean sys,
String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
Collection<ClusterNode> nodes,
String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
Collection<ClusterNode> nodes) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
Collection<ClusterNode> nodes,
boolean sys,
String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
Collection<ClusterNode> nodes,
String execName) |