| Package | Description |
|---|---|
| org.gridgain.grid.compute |
Contains Compute Grid functionality.
|
| org.gridgain.grid.kernal.processors.cache.query.jdbc | |
| org.gridgain.grid.kernal.processors.streamer.task | |
| org.gridgain.grid.kernal.visor.cmd |
| Modifier and Type | Method and Description |
|---|---|
static GridComputeJobResultPolicy |
GridComputeJobResultPolicy.fromOrdinal(byte ord)
Efficiently gets enumerated value from its ordinal.
|
GridComputeJobResultPolicy |
GridComputeTaskAdapter.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
GridComputeJobResultPolicy |
GridComputeTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
static GridComputeJobResultPolicy |
GridComputeJobResultPolicy.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static GridComputeJobResultPolicy[] |
GridComputeJobResultPolicy.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJobResultPolicy |
GridCacheQueryJdbcTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
| Modifier and Type | Method and Description |
|---|---|
GridComputeJobResultPolicy |
GridStreamerReduceTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
GridComputeJobResultPolicy |
GridStreamerBroadcastTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
GridComputeJobResultPolicy |
GridStreamerQueryTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
GridComputeTask.reduce(List) method. |
| Modifier and Type | Method and Description |
|---|---|
GridComputeJobResultPolicy |
VisorMultiNodeTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
Copyright © 2014. All rights reserved.