Package | Description |
---|---|
org.apache.ignite.compute |
Contains Compute Grid functionality.
|
org.apache.ignite.compute.gridify.aop |
Contains common classes for different AOP providers.
|
org.apache.ignite.igfs.mapreduce |
Contains APIs for In-Memory MapReduce over IGFS.
|
org.apache.ignite.ml.genetic |
Root GA package (GA Grid)
|
org.apache.ignite.spi.failover |
Contains APIs for failover SPI.
|
Modifier and Type | Method and Description |
---|---|
ComputeJobResultPolicy |
ComputeTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
ComputeJobResultPolicy |
ComputeTaskAdapter.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
Modifier and Type | Method and Description |
---|---|
R |
ComputeTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
ComputeJobResultPolicy |
ComputeTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
ComputeJobResultPolicy |
ComputeTaskAdapter.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
Modifier and Type | Method and Description |
---|---|
Object |
GridifyDefaultTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
Collection<?> |
GridifyDefaultRangeTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
Modifier and Type | Method and Description |
---|---|
R |
IgfsTaskNoReduceAdapter.reduce(List<ComputeJobResult> results)
Default implementation which will ignore all results sent from execution nodes.
|
Modifier and Type | Method and Description |
---|---|
ComputeJobResultPolicy |
CrossOverTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
ComputeJobResultPolicy |
TruncateSelectionTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
ComputeJobResultPolicy |
FitnessTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
ComputeJobResultPolicy |
MutateTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
Modifier and Type | Method and Description |
---|---|
Boolean |
CrossOverTask.reduce(List<ComputeJobResult> list)
We return TRUE if success, else Exection is thrown.
|
Boolean |
TruncateSelectionTask.reduce(List<ComputeJobResult> list)
We return TRUE if success, else Exception is thrown.
|
Boolean |
FitnessTask.reduce(List<ComputeJobResult> list) |
Boolean |
MutateTask.reduce(List<ComputeJobResult> list)
We return TRUE if success, else Exection is thrown.
|
ComputeJobResultPolicy |
CrossOverTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
ComputeJobResultPolicy |
TruncateSelectionTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
ComputeJobResultPolicy |
FitnessTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
ComputeJobResultPolicy |
MutateTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd) |
Modifier and Type | Method and Description |
---|---|
ComputeJobResult |
FailoverContext.getJobResult()
Gets failed result of job execution.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019