| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
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. |
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. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridJobResultImpl
Class provides implementation for job result.
|
| 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. |
| 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. |
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable CheckIndexInlineSizesResult |
CheckIndexInlineSizesTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable CacheDistributionTaskResult |
CacheDistributionTask.reduce0(List<ComputeJobResult> list)
Actual reduce logic.
|
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable Boolean |
JdbcConnectionValidationTask.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. |
| Modifier and Type | Method and Description |
|---|---|
ComputeJobResult |
GridFailoverContextImpl.getJobResult()
Gets failed result of job execution.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridFailoverManager.failover(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
List<ClusterNode> top,
int affPartId,
@Nullable String affCacheName,
@Nullable AffinityTopologyVersion topVer) |
| Constructor and Description |
|---|
GridFailoverContextImpl(GridTaskSessionImpl taskSes,
ComputeJobResult jobRes,
GridLoadBalancerManager loadMgr,
int partId,
@Nullable String affCacheName,
@Nullable AffinityTopologyVersion topVer)
Initializes failover context.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeJobResultPolicy |
SnapshotPartitionsVerifyTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
ComputeJobResultPolicy |
SnapshotMetadataCollectorTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
| Modifier and Type | Method and Description |
|---|---|
@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 Map<ClusterNode,List<SnapshotMetadata>> |
SnapshotMetadataCollectorTask.reduce(List<ComputeJobResult> results) |
ComputeJobResultPolicy |
SnapshotPartitionsVerifyTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
ComputeJobResultPolicy |
SnapshotMetadataCollectorTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
| 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. |
| Modifier and Type | Method and Description |
|---|---|
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. |
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. |
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. |
ComputeJobResultPolicy |
GridCacheQueryJdbcTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
| Modifier and Type | Method and 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. |
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 |
VerifyBackupPartitionsDumpTask.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. |
| Modifier and Type | Method and 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. |
@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 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<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 |
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. |
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 |
VerifyBackupPartitionsDumpTask.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. |
| 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.
|
| 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.
|
| 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. |
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<UUID,IgniteException> |
VisorCacheStartTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Map<UUID,VisorCachePartitions> |
VisorCachePartitionsTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Map<String,VisorCacheConfiguration> |
VisorCacheConfigurationCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Iterable<VisorCacheAggregatedMetrics> |
VisorCacheMetricsCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable VisorFindAndDeleteGarbageInPersistenceTaskResult |
VisorFindAndDeleteGarbageInPersistenceTask.reduce0(List<ComputeJobResult> list)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<UUID,Set<IndexRebuildStatusInfoContainer>> |
IndexRebuildStatusTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable 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 @Nullable Boolean |
VisorComputeToggleMonitoringTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Void |
VisorComputeCancelSessionsTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Void |
VisorComputeCancelSessionTask.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.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable VisorDefragmentationTaskResult |
VisorDefragmentationTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<ClusterNode,VisorPageLocksResult> |
VisorPageLocksTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<ClusterNode,VisorConnectivityResult> |
VisorConnectivityTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable VisorLogSearchTaskResult |
VisorLogSearchTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable 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 @Nullable VisorWalTaskResult |
VisorWalTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected VisorCacheRebalanceCollectorTaskResult |
VisorCacheRebalanceCollectorTask.reduce(VisorCacheRebalanceCollectorTaskResult taskRes,
List<ComputeJobResult> results) |
protected VisorNodeDataCollectorTaskResult |
VisorNodeDataCollectorTask.reduce(VisorNodeDataCollectorTaskResult taskRes,
List<ComputeJobResult> results) |
protected @Nullable VisorNodeDataCollectorTaskResult |
VisorNodeDataCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Map<UUID,VisorNodeSuppressedErrors> |
VisorNodeSuppressedErrorsTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable VisorNodePingTaskResult |
VisorNodePingTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Void |
VisorNodeStopTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected Iterable<? extends VisorGridEvent> |
VisorNodeEventsCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable VisorCacheRebalanceCollectorTaskResult |
VisorCacheRebalanceCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Map<UUID,VisorNodeGcTaskResult> |
VisorNodeGcTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Void |
VisorNodeRestartTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<UUID,Collection<VisorRunningQuery>> |
VisorRunningQueriesCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Collection<VisorQueryDetailMetrics> |
VisorQueryDetailMetricsCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Void |
VisorQueryCancelOnInitiatorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Void |
VisorQueryCancelTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable VisorContentionTaskResult |
VisorContentionTask.reduce0(List<ComputeJobResult> list)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
ComputeJobResult |
FailoverContext.getJobResult()
Gets failed result of job execution.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.11.1 Release Date : December 20 2021