| Package | Description |
|---|---|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.closure |
TODO.
|
| org.apache.ignite.internal.processors.task |
TODO.
|
| Modifier and Type | Method and Description |
|---|---|
<T,R> ComputeTaskInternalFuture<R> |
IgniteComputeImpl.executeAsync0(ComputeTask<T,R> task,
T arg)
Execute implementation.
|
static <R> ComputeTaskInternalFuture<R> |
ComputeTaskInternalFuture.finishedFuture(GridKernalContext ctx,
Class<?> taskCls,
IgniteCheckedException e) |
| Modifier and Type | Method and Description |
|---|---|
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.affinityCall(@NotNull Collection<String> cacheNames,
int partId,
Callable<R> job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.affinityRun(@NotNull Collection<String> cacheNames,
int partId,
Runnable job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
@Nullable Callable<R> job,
@Nullable Collection<ClusterNode> nodes) |
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Callable<R> job,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
@Nullable Callable<R> job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
@Nullable Collection<? extends Callable<R>> jobs,
@Nullable Collection<ClusterNode> nodes) |
<R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
Collection<? extends Callable<R>> jobs,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
<R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(GridClosureCallMode mode,
@Nullable Collection<? extends Callable<R>> jobs,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<T,R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
@Nullable Collection<? extends T> args,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<T,R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
T arg,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<T,R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.callAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode,
Collection<? extends Callable<R1>> jobs,
IgniteReducer<R1,R2> rdc,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Collection<? extends Runnable> jobs,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
@Nullable Collection<? extends Runnable> jobs,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
@Nullable Collection<ClusterNode> nodes) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
@Nullable Collection<ClusterNode> nodes,
boolean sys,
@Nullable String execName) |
ComputeTaskInternalFuture<?> |
GridClosureProcessor.runAsync(GridClosureCallMode mode,
Runnable job,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
| Modifier and Type | Method and Description |
|---|---|
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(Class<? extends ComputeTask<T,R>> taskCls,
T arg) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(Class<? extends ComputeTask<T,R>> taskCls,
T arg,
@Nullable String execName) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg,
boolean sys) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg,
boolean sys,
@Nullable String execName) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(ComputeTask<T,R> task,
T arg,
String execName) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(String taskName,
T arg) |
<T,R> ComputeTaskInternalFuture<R> |
GridTaskProcessor.execute(String taskName,
T arg,
@Nullable String execName) |
<R> @Nullable ComputeTaskInternalFuture<R> |
GridTaskProcessor.taskFuture(IgniteUuid sesId) |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.1 Release Date : December 20 2021