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.management
org.apache.ignite.internal.management.cache
org.apache.ignite.internal.management.cdc
org.apache.ignite.internal.management.consistency
org.apache.ignite.internal.management.defragmentation
org.apache.ignite.internal.management.diagnostic
org.apache.ignite.internal.management.encryption
org.apache.ignite.internal.management.kill
org.apache.ignite.internal.management.meta
org.apache.ignite.internal.management.property
org.apache.ignite.internal.management.snapshot
org.apache.ignite.internal.management.tx
org.apache.ignite.internal.management.wal
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.compute
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	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	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.internal

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

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

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

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

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

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

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

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

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

Modifier and Type	Method	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	VerifyBackupPartitionsTaskV2.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.management.cache with type arguments of type ComputeJobResult

Modifier and Type	Method	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 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.
protected @Nullable Map<String,CacheConfiguration>	CacheConfigurationCollectorTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable ContentionTaskResult	ContentionTask.reduce0(List<ComputeJobResult> list)	Actual reduce logic.
protected @Nullable FindAndDeleteGarbageInPersistenceTaskResult	FindAndDeleteGarbageInPersistenceTask.reduce0(List<ComputeJobResult> list)	Actual reduce logic.
protected Map<UUID,IndexForceRebuildTaskRes>	IndexForceRebuildTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable Map<UUID,Set<IndexRebuildStatusInfoContainer>>	IndexRebuildStatusTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected ScheduleIndexRebuildTaskRes	ScheduleIndexRebuildTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable ValidateIndexesTaskResult	ValidateIndexesTask.reduce0(List<ComputeJobResult> list)	Actual reduce logic.
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	VerifyBackupPartitionsTaskV2.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.management.cdc

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

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

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

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

Modifier and Type	Method	Description
protected ConsistencyTaskResult	AbstractConsistencyTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected ConsistencyTaskResult	ConsistencyStatusTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.

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

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

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

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

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

Modifier and Type	Method	Description
protected @Nullable Map<ClusterNode,ConnectivityResult>	ConnectivityTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable Map<ClusterNode,PageLocksResult>	PageLocksTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.

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

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

Modifier and Type	Method	Description
protected @Nullable CacheGroupEncryptionTaskResult<T>	CacheGroupEncryptionTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable CacheGroupEncryptionTaskResult<Double>	ReencryptionRateTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.management.kill

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

Modifier and Type	Method	Description
protected Void	ClientConnectionDropTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable Void	ComputeCancelSessionTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected Void	ConsistencyCancelTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable Map<ClusterNode,TxTaskResult>	KillTransactionTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable Void	QueryCancelOnInitiatorTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.

Uses of ComputeJobResult in org.apache.ignite.internal.management.meta

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

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

Uses of ComputeJobResult in org.apache.ignite.internal.management.property

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

Modifier and Type	Method	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.management.snapshot

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

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

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

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

Modifier and Type	Method	Description
protected GridCacheVersion	FetchNearXidVersionTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected @Nullable Map<ClusterNode,TxTaskResult>	TxTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
static Map<ClusterNode,TxTaskResult>	TxTask.reduce0(List<ComputeJobResult> results, boolean detailedInfo)

Uses of ComputeJobResult in org.apache.ignite.internal.management.wal

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

Modifier and Type	Method	Description
protected @Nullable WalTaskResult	WalTask.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	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	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	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	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	Description
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	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.
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.
@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.
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	Description
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	RetrieveConflictPartitionValuesTask.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.verify with type arguments of type ComputeJobResult

Modifier and Type	Method	Description
@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 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.
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	RetrieveConflictPartitionValuesTask.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	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	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	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	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	Description
@Nullable VisorTaskResult<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 abstract R	VisorMultiNodeTask.reduce0(List<ComputeJobResult> results)	Actual reduce logic.
protected R	VisorOneNodeTask.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.compute

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

Modifier and Type	Method	Description
protected @Nullable Void	VisorComputeCancelSessionsTask.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	Description
ComputeJobResult	FailoverContext.getJobResult()	Gets failed result of job execution.