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

Class IncrementalSnapshotVerificationTask

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.IncrementalSnapshotVerificationTask

All Implemented Interfaces:

Serializable, ComputeTask<SnapshotPartitionsVerifyTaskArg,SnapshotPartitionsVerifyTaskResult>

@GridInternal
public class IncrementalSnapshotVerificationTask
extends AbstractSnapshotVerificationTask

See Also:

Serialized Form

Field Summary

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

metas

Constructor Summary

Constructors

Constructor and Description
IncrementalSnapshotVerificationTask()

Method Summary

Modifier and Type	Method and Description
protected ComputeJob	createJob(String name, @Nullable String path, int incIdx, String constId, Collection<String> groups, boolean check)
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

checkMissedMetadata, map, result

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementalSnapshotVerificationTask

public IncrementalSnapshotVerificationTask()

Method Detail

reduce

public 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.

createJob

protected ComputeJob createJob(String name,
                               @Nullable
                               @Nullable String path,
                               int incIdx,
                               String constId,
                               Collection<String> groups,
                               boolean check)

Specified by:

createJob in class AbstractSnapshotVerificationTask

Parameters:

name - Snapshot name.

path - Snapshot directory path.

incIdx - Incremental snapshot index.

constId - Snapshot metadata file name.

groups - Cache groups to be restored from the snapshot. May be empty if all cache groups are being restored.

check - If true check snapshot before restore.

Returns:

Compute job.