org.apache.ignite.internal.visor.cache

Class VisorFindAndDeleteGarbageInPersistenceTask

java.lang.Object

org.apache.ignite.internal.visor.VisorMultiNodeTask<VisorFindAndDeleteGarbageInPersistenceTaskArg,VisorFindAndDeleteGarbageInPersistenceTaskResult,VisorFindAndDeleteGarbageInPersistenceJobResult>

org.apache.ignite.internal.visor.cache.VisorFindAndDeleteGarbageInPersistenceTask

All Implemented Interfaces:

Serializable, ComputeTask<VisorTaskArgument<VisorFindAndDeleteGarbageInPersistenceTaskArg>,VisorFindAndDeleteGarbageInPersistenceTaskResult>

@GridInternal
public class VisorFindAndDeleteGarbageInPersistenceTask
extends VisorMultiNodeTask<VisorFindAndDeleteGarbageInPersistenceTaskArg,VisorFindAndDeleteGarbageInPersistenceTaskResult,VisorFindAndDeleteGarbageInPersistenceJobResult>

Compute task which are part of 'find and delete garbage' functionality.

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.ignite.internal.visor.VisorMultiNodeTask

debug, ignite, start, taskArg

Constructor Summary

Constructors

Constructor and Description
VisorFindAndDeleteGarbageInPersistenceTask()

Method Summary

Modifier and Type	Method and Description
protected VisorJob<VisorFindAndDeleteGarbageInPersistenceTaskArg,VisorFindAndDeleteGarbageInPersistenceJobResult>	job(VisorFindAndDeleteGarbageInPersistenceTaskArg arg)
protected Collection<UUID>	jobNodes(VisorTaskArgument<VisorFindAndDeleteGarbageInPersistenceTaskArg> arg)
protected @Nullable VisorFindAndDeleteGarbageInPersistenceTaskResult	reduce0(List<ComputeJobResult> list) Actual reduce logic.

Methods inherited from class org.apache.ignite.internal.visor.VisorMultiNodeTask

map, map0, reduce, result

Methods inherited from class java.lang.Object

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

Constructor Detail

VisorFindAndDeleteGarbageInPersistenceTask

public VisorFindAndDeleteGarbageInPersistenceTask()

Method Detail

reduce0

@Nullable
protected @Nullable VisorFindAndDeleteGarbageInPersistenceTaskResult reduce0(List<ComputeJobResult> list)
                                                                                throws IgniteException

Actual reduce logic.

Specified by:

reduce0 in class VisorMultiNodeTask<VisorFindAndDeleteGarbageInPersistenceTaskArg,VisorFindAndDeleteGarbageInPersistenceTaskResult,VisorFindAndDeleteGarbageInPersistenceJobResult>

Parameters:

list - Job results.

Returns:

Task result.

Throws:

IgniteException - If reduction or results caused an error.

job

protected VisorJob<VisorFindAndDeleteGarbageInPersistenceTaskArg,VisorFindAndDeleteGarbageInPersistenceJobResult> job(VisorFindAndDeleteGarbageInPersistenceTaskArg arg)

Specified by:

job in class VisorMultiNodeTask<VisorFindAndDeleteGarbageInPersistenceTaskArg,VisorFindAndDeleteGarbageInPersistenceTaskResult,VisorFindAndDeleteGarbageInPersistenceJobResult>

Parameters:

arg - Task arg.

Returns:

New job.

jobNodes

protected Collection<UUID> jobNodes(VisorTaskArgument<VisorFindAndDeleteGarbageInPersistenceTaskArg> arg)

Overrides:

jobNodes in class VisorMultiNodeTask<VisorFindAndDeleteGarbageInPersistenceTaskArg,VisorFindAndDeleteGarbageInPersistenceTaskResult,VisorFindAndDeleteGarbageInPersistenceJobResult>

Returns:

Collection of nodes IDs where jobs should be mapped.