Uses of Interface
org.apache.ignite.compute.ComputeJobResult

Packages that use ComputeJobResult

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.internal	Contains main implementation.
org.apache.ignite.internal.managers.failover	TODO.
org.apache.ignite.internal.processors.cache.query.jdbc
org.apache.ignite.internal.processors.platform.compute
org.apache.ignite.internal.util.future	Future related classes.
org.apache.ignite.internal.visor
org.apache.ignite.internal.visor.cache
org.apache.ignite.internal.visor.compute
org.apache.ignite.internal.visor.log
org.apache.ignite.internal.visor.misc
org.apache.ignite.internal.visor.node
org.apache.ignite.internal.visor.query
org.apache.ignite.spi.failover	Contains APIs for failover SPI.

Uses of ComputeJobResult in org.apache.ignite.compute

Methods in org.apache.ignite.compute with parameters of type ComputeJobResult

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.

Method parameters in org.apache.ignite.compute with type arguments of type ComputeJobResult

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.

Uses of ComputeJobResult in org.apache.ignite.compute.gridify.aop

Method parameters in org.apache.ignite.compute.gridify.aop with type arguments of type ComputeJobResult

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.

Uses of ComputeJobResult in org.apache.ignite.igfs.mapreduce

Method parameters in org.apache.ignite.igfs.mapreduce with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
R	IgfsTaskNoReduceAdapter.reduce(List<ComputeJobResult> results) Default implementation which will ignore all results sent from execution nodes.

Uses of ComputeJobResult in org.apache.ignite.internal

Classes in org.apache.ignite.internal that implement ComputeJobResult

Modifier and Type	Class and Description
class	GridJobResultImpl Class provides implementation for job result.

Uses of ComputeJobResult in org.apache.ignite.internal.managers.failover

Methods in org.apache.ignite.internal.managers.failover that return ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResult	GridFailoverContextImpl.getJobResult() Gets failed result of job execution.

Methods in org.apache.ignite.internal.managers.failover with parameters of type ComputeJobResult

Modifier and Type	Method and Description
ClusterNode	GridFailoverManager.failover(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, List<ClusterNode> top, int affPartId, String affCacheName, AffinityTopologyVersion topVer)

Constructors in org.apache.ignite.internal.managers.failover with parameters of type ComputeJobResult

Constructor and Description
GridFailoverContextImpl(GridTaskSessionImpl taskSes, ComputeJobResult jobRes, GridLoadBalancerManager loadMgr, int partId, String affCacheName, AffinityTopologyVersion topVer) Initializes failover context.

Uses of ComputeJobResult in org.apache.ignite.internal.processors.cache.query.jdbc

Methods in org.apache.ignite.internal.processors.cache.query.jdbc with parameters of type ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResultPolicy	GridCacheQueryJdbcTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.

Method parameters in org.apache.ignite.internal.processors.cache.query.jdbc with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
Boolean	GridCacheQueryJdbcValidationTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
byte[]	GridCacheQueryJdbcMetadataTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
byte[]	GridCacheQueryJdbcTask.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	GridCacheQueryJdbcTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.

Uses of ComputeJobResult in org.apache.ignite.internal.processors.platform.compute

Methods in org.apache.ignite.internal.processors.platform.compute with parameters of type ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResultPolicy	PlatformAbstractTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Method parameters in org.apache.ignite.internal.processors.platform.compute with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
Void	PlatformAbstractTask.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	PlatformAbstractTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Uses of ComputeJobResult in org.apache.ignite.internal.util.future

Method parameters in org.apache.ignite.internal.util.future with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
R	IgniteRemoteMapTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.

Uses of ComputeJobResult in org.apache.ignite.internal.visor

Methods in org.apache.ignite.internal.visor with parameters of type ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResultPolicy	VisorMultiNodeTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Method parameters in org.apache.ignite.internal.visor with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
R	VisorMultiNodeTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
protected R	VisorOneNodeTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected abstract R	VisorMultiNodeTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
ComputeJobResultPolicy	VisorMultiNodeTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Uses of ComputeJobResult in org.apache.ignite.internal.visor.cache

Method parameters in org.apache.ignite.internal.visor.cache with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
protected Iterable<VisorCacheAggregatedMetrics>	VisorCacheMetricsCollectorTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Map<UUID,IgniteException>	VisorCacheStartTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Map<UUID,VisorCachePartitions>	VisorCachePartitionsTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.visor.compute

Methods in org.apache.ignite.internal.visor.compute with parameters of type ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResultPolicy	VisorGatewayTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Method parameters in org.apache.ignite.internal.visor.compute with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
Object	VisorGatewayTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
protected Void	VisorComputeCancelSessionsTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Boolean	VisorComputeToggleMonitoringTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
ComputeJobResultPolicy	VisorGatewayTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Uses of ComputeJobResult in org.apache.ignite.internal.visor.log

Method parameters in org.apache.ignite.internal.visor.log with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
protected VisorLogSearchTaskResult	VisorLogSearchTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.visor.misc

Methods in org.apache.ignite.internal.visor.misc with parameters of type ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResultPolicy	VisorNopTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Method parameters in org.apache.ignite.internal.visor.misc with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
Void	VisorNopTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
protected Void	VisorAckTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
ComputeJobResultPolicy	VisorNopTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

Uses of ComputeJobResult in org.apache.ignite.internal.visor.node

Method parameters in org.apache.ignite.internal.visor.node with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
protected VisorNodeDataCollectorTaskResult	VisorNodeDataCollectorTask.reduce(VisorNodeDataCollectorTaskResult taskRes, List<ComputeJobResult> results)
protected Void	VisorNodeRestartTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Void	VisorNodeStopTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected VisorNodePingTaskResult	VisorNodePingTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected VisorNodeDataCollectorTaskResult	VisorNodeDataCollectorTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Map<UUID,VisorNodeSuppressedErrors>	VisorNodeSuppressedErrorsTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Iterable<? extends VisorGridEvent>	VisorNodeEventsCollectorTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Map<UUID,VisorNodeGcTaskResult>	VisorNodeGcTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.visor.query

Method parameters in org.apache.ignite.internal.visor.query with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
protected Map<UUID,Collection<VisorRunningQuery>>	VisorRunningQueriesCollectorTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Collection<VisorQueryDetailMetrics>	VisorQueryDetailMetricsCollectorTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Void	VisorQueryCancelTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.spi.failover

Methods in org.apache.ignite.spi.failover that return ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResult	FailoverContext.getJobResult() Gets failed result of job execution.