Package org.apache.ignite.internal.processors.cache.persistence.snapshot

Class SnapshotPartitionsVerifyTask

java.lang.Object

org.apache.ignite.compute.ComputeTaskAdapter<SnapshotPartitionsVerifyTaskArg,SnapshotPartitionsVerifyTaskResult>

org.apache.ignite.internal.processors.cache.persistence.snapshot.AbstractSnapshotVerificationTask

org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotPartitionsVerifyTask

All Implemented Interfaces:

Serializable, ComputeTask<SnapshotPartitionsVerifyTaskArg,SnapshotPartitionsVerifyTaskResult>

@GridInternal
public class SnapshotPartitionsVerifyTask
extends AbstractSnapshotVerificationTask

Task for checking snapshot partitions consistency the same way as VerifyBackupPartitionsTaskV2 does. Since a snapshot partitions already stored apart on disk the is no requirement for a cluster upcoming updates to be hold on.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.ignite.internal.processors.cache.persistence.snapshot.AbstractSnapshotVerificationTask

AbstractSnapshotVerificationTask.AbstractSnapshotVerificationJob

Field Summary

Fields inherited from class org.apache.ignite.internal.processors.cache.persistence.snapshot.AbstractSnapshotVerificationTask

ignite, log, metas

Constructor Summary

Constructors

Constructor	Description
SnapshotPartitionsVerifyTask()

Method Summary

Modifier and Type	Method	Description
protected org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotPartitionsVerifyTask.VerifySnapshotPartitionsJob	createJob(String name, String consId, SnapshotPartitionsVerifyTaskArg args)
@Nullable SnapshotPartitionsVerifyTaskResult	reduce(List<ComputeJobResult> results)	Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.

Methods inherited from class org.apache.ignite.internal.processors.cache.persistence.snapshot.AbstractSnapshotVerificationTask

map, result

Methods inherited from class java.lang.Object

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

Constructor Detail

SnapshotPartitionsVerifyTask

public SnapshotPartitionsVerifyTask()

Method Detail

createJob

protected org.apache.ignite.internal.processors.cache.persistence.snapshot.SnapshotPartitionsVerifyTask.VerifySnapshotPartitionsJob createJob(String name,
                                                                                                                                              String consId,
                                                                                                                                              SnapshotPartitionsVerifyTaskArg args)

Specified by:

createJob in class AbstractSnapshotVerificationTask

Parameters:

name - Snapshot name.

consId - Consistent id of the related node.

args - Check snapshot parameters.

Returns:

Compute job.

reduce

@Nullable
public @Nullable SnapshotPartitionsVerifyTaskResult reduce(List<ComputeJobResult> results)
                                                    throws IgniteException

Reduces (or aggregates) results received so far into one compound result to be returned to caller via ComputeTaskFuture.get() method.

Note, that if some jobs did not succeed and could not be failed over then the list of results passed into this method will include the failed results. Otherwise, failed results will not be in the list.

Parameters:

results - Received results of broadcasted remote executions. Note that if task class has ComputeTaskNoResultCache annotation, then this list will be empty.

Returns:

Grid job result constructed from results of remote executions.

Throws:

IgniteException - If reduction or results caused an error. This exception will be thrown out of ComputeTaskFuture.get() method.