Package org.apache.ignite.internal.processors.cache.verify

Class RetrieveConflictPartitionValuesTask.RetrieveConflictValuesJob

java.lang.Object

org.apache.ignite.compute.ComputeJobAdapter

org.apache.ignite.internal.processors.cache.verify.RetrieveConflictPartitionValuesTask.RetrieveConflictValuesJob

All Implemented Interfaces:

Serializable, Callable<Object>, ComputeJob

Enclosing class:

RetrieveConflictPartitionValuesTask

public static class RetrieveConflictPartitionValuesTask.RetrieveConflictValuesJob
extends ComputeJobAdapter

See Also:

Serialized Form

Method Summary

Modifier and Type	Method	Description
Map<PartitionHashRecord,List<PartitionEntryHashRecord>>	execute()	Executes this job.

Methods inherited from class org.apache.ignite.compute.ComputeJobAdapter

argument, arguments, call, cancel, isCancelled, setArguments

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

execute

public Map<PartitionHashRecord,List<PartitionEntryHashRecord>> execute()
                                                                      throws IgniteException

Executes this job.

Returns:

Job execution result (possibly null). This result will be returned in ComputeJobResult.getData() method passed into ComputeTask.result(ComputeJobResult, List) task method on caller node.

Throws:

IgniteException - If job execution caused an exception. This exception will be returned in ComputeJobResult.getException() method passed into ComputeTask.result(ComputeJobResult, List) task method on caller node. If execution produces a RuntimeException or Error, then it will be wrapped into IgniteCheckedException.