<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.affinityCall(@NotNull Collection<String> cacheNames,
int partId,
Callable<R> job,
TaskExecutionOptions opts) |
|
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.affinityCall(Collection<String> cacheNames,
Object affKey,
IgniteCallable<R> job,
TaskExecutionOptions opts) |
|
ComputeTaskInternalFuture<?> |
GridClosureProcessor.affinityRun(@NotNull Collection<String> cacheNames,
int partId,
Runnable job,
TaskExecutionOptions opts) |
|
ComputeTaskInternalFuture<?> |
GridClosureProcessor.affinityRun(@NotNull Collection<String> cacheNames,
Object affKey,
Runnable job,
TaskExecutionOptions opts) |
|
<T,R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
@Nullable Collection<? extends T> args,
TaskExecutionOptions opts) |
|
<T,R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
T arg,
TaskExecutionOptions opts) |
|
<T,R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.callAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc,
TaskExecutionOptions opts) |
|
<R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode,
Collection<? extends Callable<R1>> jobs,
IgniteReducer<R1,R2> rdc,
TaskExecutionOptions opts) |
|
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
TaskExecutionOptions opts) |
|
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
TaskExecutionOptions opts) |
|