Uses of Class
org.apache.ignite.compute.ComputeJobResultPolicy
-
Packages that use ComputeJobResultPolicy Package Description org.apache.ignite.compute Contains Compute Grid functionality.org.apache.ignite.events Contains Event Subscription functionality together with various events emitted by Ignite.org.apache.ignite.internal Contains main implementation.org.apache.ignite.internal.management.cache 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.visor -
-
Uses of ComputeJobResultPolicy in org.apache.ignite.compute
Methods in org.apache.ignite.compute that return ComputeJobResultPolicy Modifier and Type Method Description static @Nullable ComputeJobResultPolicyComputeJobResultPolicy. fromOrdinal(byte ord)Efficiently gets enumerated value from its ordinal.ComputeJobResultPolicyComputeTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Asynchronous callback invoked every time a result from remote execution is received.ComputeJobResultPolicyComputeTaskAdapter. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.static ComputeJobResultPolicyComputeJobResultPolicy. valueOf(String name)Returns the enum constant of this type with the specified name.static ComputeJobResultPolicy[]ComputeJobResultPolicy. values()Returns an array containing the constants of this enum type, in the order they are declared. -
Uses of ComputeJobResultPolicy in org.apache.ignite.events
Methods in org.apache.ignite.events that return ComputeJobResultPolicy Modifier and Type Method Description @Nullable ComputeJobResultPolicyJobEvent. resultPolicy()Gets job result policy.Methods in org.apache.ignite.events with parameters of type ComputeJobResultPolicy Modifier and Type Method Description voidJobEvent. resultPolicy(@Nullable ComputeJobResultPolicy resPlc)Sets job result policy. -
Uses of ComputeJobResultPolicy in org.apache.ignite.internal
Methods in org.apache.ignite.internal that return ComputeJobResultPolicy Modifier and Type Method Description ComputeJobResultPolicyCheckCpHistTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method. -
Uses of ComputeJobResultPolicy in org.apache.ignite.internal.management.cache
Methods in org.apache.ignite.internal.management.cache that return ComputeJobResultPolicy Modifier and Type Method Description ComputeJobResultPolicyVerifyBackupPartitionsDumpTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.ComputeJobResultPolicyVerifyBackupPartitionsTaskV2. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method. -
Uses of ComputeJobResultPolicy in org.apache.ignite.internal.processors.cache.persistence.snapshot
Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot that return ComputeJobResultPolicy Modifier and Type Method Description ComputeJobResultPolicyAbstractSnapshotVerificationTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.ComputeJobResultPolicySnapshotMetadataVerificationTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method. -
Uses of ComputeJobResultPolicy in org.apache.ignite.internal.processors.cache.verify
Methods in org.apache.ignite.internal.processors.cache.verify that return ComputeJobResultPolicy Modifier and Type Method Description ComputeJobResultPolicyCollectConflictPartitionKeysTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.ComputeJobResultPolicyRetrieveConflictPartitionValuesTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method. -
Uses of ComputeJobResultPolicy in org.apache.ignite.internal.processors.platform.compute
Methods in org.apache.ignite.internal.processors.platform.compute that return ComputeJobResultPolicy Modifier and Type Method Description ComputeJobResultPolicyPlatformAbstractTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Asynchronous callback invoked every time a result from remote execution is received. -
Uses of ComputeJobResultPolicy in org.apache.ignite.internal.visor
Methods in org.apache.ignite.internal.visor that return ComputeJobResultPolicy Modifier and Type Method Description ComputeJobResultPolicyVisorMultiNodeTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Asynchronous callback invoked every time a result from remote execution is received.
-