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.internal	Contains main implementation.
org.apache.ignite.internal.commandline.cache.check_indexes_inline_size
org.apache.ignite.internal.commandline.cache.distribution
org.apache.ignite.internal.commandline.meta.tasks
org.apache.ignite.internal.commandline.property.tasks
org.apache.ignite.internal.managers.failover	TODO.
org.apache.ignite.internal.processors.cache.persistence.snapshot
org.apache.ignite.internal.processors.cache.verify
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.cache.index
org.apache.ignite.internal.visor.cdc
org.apache.ignite.internal.visor.client
org.apache.ignite.internal.visor.compute
org.apache.ignite.internal.visor.consistency
org.apache.ignite.internal.visor.defragmentation
org.apache.ignite.internal.visor.diagnostic
org.apache.ignite.internal.visor.diagnostic.availability
org.apache.ignite.internal.visor.encryption
org.apache.ignite.internal.visor.misc
org.apache.ignite.internal.visor.query
org.apache.ignite.internal.visor.snapshot
org.apache.ignite.internal.visor.systemview
org.apache.ignite.internal.visor.tx
org.apache.ignite.internal.visor.verify
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	ComputeTaskAdapter.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	ComputeTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Asynchronous callback invoked every time a result from remote execution is received.

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	ComputeTaskAdapter.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	ComputeTask.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

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

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

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

Modifier and Type	Method and Description
ComputeJobResultPolicy	CheckCpHistTask.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 with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
Boolean	CheckCpHistTask.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	CheckCpHistTask.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.commandline.cache.check_indexes_inline_size

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

Modifier and Type	Method and Description
protected @Nullable CheckIndexInlineSizesResult	CheckIndexInlineSizesTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.commandline.cache.distribution

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

Modifier and Type	Method and Description
protected @Nullable CacheDistributionTaskResult	CacheDistributionTask.reduce0(List<ComputeJobResult> list) Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.commandline.meta.tasks

Method parameters in org.apache.ignite.internal.commandline.meta.tasks with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
protected @Nullable MetadataMarshalled	MetadataRemoveTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable MetadataMarshalled	MetadataUpdateTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable MetadataListResult	MetadataInfoTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.commandline.property.tasks

Method parameters in org.apache.ignite.internal.commandline.property.tasks with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
protected @Nullable PropertiesListResult	PropertiesListTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable PropertyOperationResult	PropertyTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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, @Nullable String affCacheName, @Nullable 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, @Nullable String affCacheName, @Nullable AffinityTopologyVersion topVer) Initializes failover context.

Uses of ComputeJobResult in org.apache.ignite.internal.processors.cache.persistence.snapshot

Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot with parameters of type ComputeJobResult

Modifier and Type	Method and Description
ComputeJobResultPolicy	AbstractSnapshotVerificationTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	SnapshotMetadataVerificationTask.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.persistence.snapshot with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
@Nullable SnapshotMetadataVerificationTaskResult	SnapshotMetadataVerificationTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
SnapshotPartitionsVerifyTaskResult	IncrementalSnapshotVerificationTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
@Nullable SnapshotPartitionsVerifyTaskResult	SnapshotPartitionsVerifyTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
@Nullable SnapshotPartitionsVerifyTaskResult	SnapshotHandlerRestoreTask.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	AbstractSnapshotVerificationTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	SnapshotMetadataVerificationTask.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.cache.verify

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

Modifier and Type	Method and Description
ComputeJobResultPolicy	VerifyBackupPartitionsDumpTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	RetrieveConflictPartitionValuesTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	CollectConflictPartitionKeysTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	VerifyBackupPartitionsTaskV2.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	VerifyBackupPartitionsTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Deprecated. 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.verify with type arguments of type ComputeJobResult

Modifier and Type	Method and Description
@Nullable String	VerifyBackupPartitionsDumpTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
@Nullable Map<PartitionHashRecord,List<PartitionEntryHashRecord>>	RetrieveConflictPartitionValuesTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
@Nullable Map<PartitionHashRecord,List<PartitionEntryHashRecord>>	CollectConflictPartitionKeysTask.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
@Nullable IdleVerifyResultV2	VerifyBackupPartitionsTaskV2.reduce(List<ComputeJobResult> results) Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
@Nullable Map<PartitionKey,List<PartitionHashRecord>>	VerifyBackupPartitionsTask.reduce(List<ComputeJobResult> results) Deprecated. Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.
static IdleVerifyResultV2	VerifyBackupPartitionsTaskV2.reduce0(List<ComputeJobResult> results)
ComputeJobResultPolicy	VerifyBackupPartitionsDumpTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	RetrieveConflictPartitionValuesTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	CollectConflictPartitionKeysTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	VerifyBackupPartitionsTaskV2.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Default implementation which will wait for all jobs to complete before calling ComputeTask.reduce(List) method.
ComputeJobResultPolicy	VerifyBackupPartitionsTask.result(ComputeJobResult res, List<ComputeJobResult> rcvd) Deprecated. 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
@Nullable 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 @Nullable VisorFindAndDeleteGarbageInPersistenceTaskResult	VisorFindAndDeleteGarbageInPersistenceTask.reduce0(List<ComputeJobResult> list) Actual reduce logic.
protected @Nullable Map<String,VisorCacheConfiguration>	VisorCacheConfigurationCollectorTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable Map<UUID,Set<IndexRebuildStatusInfoContainer>>	IndexRebuildStatusTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable ScheduleIndexRebuildTaskRes	ScheduleIndexRebuildTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable Void	VisorCdcCacheDataResendTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable Void	VisorCdcDeleteLostSegmentsTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

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

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

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

Modifier and Type	Method and Description
protected @Nullable Void	VisorComputeCancelSessionTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable Void	VisorComputeCancelSessionsTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected VisorConsistencyTaskResult	VisorConsistencyStatusTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected VisorConsistencyTaskResult	AbstractConsistencyTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected Void	VisorConsistencyCancelTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable VisorDefragmentationTaskResult	VisorDefragmentationTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable Map<ClusterNode,VisorPageLocksResult>	VisorPageLocksTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable Map<ClusterNode,VisorConnectivityResult>	VisorConnectivityTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable VisorCacheGroupEncryptionTaskResult<T>	VisorCacheGroupEncryptionTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable VisorCacheGroupEncryptionTaskResult<Double>	VisorReencryptionRateTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable VisorWalTaskResult	VisorWalTask.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 @Nullable Void	VisorQueryCancelOnInitiatorTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable VisorSnapshotTaskResult	VisorSnapshotOneNodeTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable VisorSnapshotTaskResult	VisorSnapshotStatusTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable VisorSystemViewTaskResult	VisorSystemViewTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected GridCacheVersion	FetchNearXidVersionTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected @Nullable Map<ClusterNode,VisorTxTaskResult>	VisorTxTask.reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

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

Modifier and Type	Method and Description
protected @Nullable VisorValidateIndexesTaskResult	VisorValidateIndexesTask.reduce0(List<ComputeJobResult> list) Actual reduce logic.
protected @Nullable VisorContentionTaskResult	VisorContentionTask.reduce0(List<ComputeJobResult> list) 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.