| Package | Description |
|---|---|
| org.gridgain.grid.compute |
Contains Compute Grid functionality.
|
| org.gridgain.grid.compute.gridify.aop |
Contains common classes for different AOP providers.
|
| org.gridgain.grid.ggfs.mapreduce |
Contains APIs for In-Memory MapReduce over GGFS.
|
| org.gridgain.grid.kernal |
Contains main implementation.
|
| org.gridgain.grid.kernal.managers.failover |
TODO.
|
| org.gridgain.grid.kernal.processors.cache.query.jdbc | |
| org.gridgain.grid.kernal.processors.streamer.task | |
| org.gridgain.grid.kernal.visor.cmd | |
| org.gridgain.grid.kernal.visor.cmd.tasks | |
| org.gridgain.grid.spi.failover |
Contains APIs for failover SPI.
|
| org.gridgain.grid.util.lang |
| Modifier and Type | Method and Description |
|---|---|
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.
|
| Modifier and Type | Method and Description |
|---|---|
R |
GridComputeTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
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.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<?> |
GridifyDefaultRangeTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Object |
GridifyDefaultTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
| Modifier and Type | Method and Description |
|---|---|
R |
GridGgfsTaskNoReduceAdapter.reduce(List<GridComputeJobResult> results)
Default implementation which will ignore all results sent from execution nodes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridJobResultImpl
Class provides implementation for job result.
|
| Modifier and Type | Method and Description |
|---|---|
GridComputeJobResult |
GridFailoverContextImpl.getJobResult()
Gets failed result of job execution.
|
| Modifier and Type | Method and Description |
|---|---|
GridNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
GridComputeJobResult jobRes,
List<GridNode> top) |
| Constructor and Description |
|---|
GridFailoverContextImpl(GridTaskSessionImpl taskSes,
GridComputeJobResult jobRes,
GridLoadBalancerManager loadMgr)
Initializes failover context.
|
| 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 |
|---|---|
byte[] |
GridCacheQueryJdbcMetadataTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Boolean |
GridCacheQueryJdbcValidationTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
byte[] |
GridCacheQueryJdbcTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
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 |
|---|---|
R2 |
GridStreamerReduceTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Void |
GridStreamerBroadcastTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Collection<R> |
GridStreamerQueryTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
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.
|
| Modifier and Type | Method and Description |
|---|---|
R |
VisorOneNodeTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
GridComputeJobResultPolicy |
VisorMultiNodeTask.result(GridComputeJobResult res,
List<GridComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
| Modifier and Type | Method and Description |
|---|---|
Iterable<GridBiTuple<UUID,VisorLicense>> |
VisorLicenseCollectTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Iterable<VisorCacheAggregatedMetrics> |
VisorCacheCollectMetricsTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Map<UUID,GridBiTuple<Long,Long>> |
VisorGcTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Iterable<? extends VisorGridEvent> |
VisorEventsCollectTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
Void |
VisorAckTask.reduce(List<GridComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
GridComputeTaskFuture.get() method. |
| Modifier and Type | Method and Description |
|---|---|
GridComputeJobResult |
GridFailoverContext.getJobResult()
Gets failed result of job execution.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> Collection<T> |
GridFunc.jobResults(Collection<? extends GridComputeJobResult> res)
Gets collections of data items from grid job res casted to specified type.
|
Copyright © 2014. All rights reserved.