org.apache.ignite.internal.visor.query

Class VisorQueryCleanupTask

java.lang.Object

org.apache.ignite.internal.visor.VisorMultiNodeTask<VisorQueryCleanupTaskArg,Void,Void>

org.apache.ignite.internal.visor.query.VisorQueryCleanupTask

All Implemented Interfaces:

Serializable, ComputeTask<VisorTaskArgument<VisorQueryCleanupTaskArg>,Void>

@GridInternal
public class VisorQueryCleanupTask
extends VisorMultiNodeTask<VisorQueryCleanupTaskArg,Void,Void>

Task for cleanup not needed SCAN or SQL queries result futures from node local.

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
VisorQueryCleanupTask()

Method Summary

Modifier and Type	Method and Description
protected VisorJob<VisorQueryCleanupTaskArg,Void>	job(VisorQueryCleanupTaskArg arg)
protected Map<? extends ComputeJob,ClusterNode>	map0(List<ClusterNode> subgrid, VisorTaskArgument<VisorQueryCleanupTaskArg> arg) Actual map logic.
protected Void	reduce0(List list) Actual reduce logic.

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

jobNodes, map, reduce, result

Methods inherited from class java.lang.Object

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

Constructor Detail

VisorQueryCleanupTask

public VisorQueryCleanupTask()

Method Detail

job

protected VisorJob<VisorQueryCleanupTaskArg,Void> job(VisorQueryCleanupTaskArg arg)

Specified by:

job in class VisorMultiNodeTask<VisorQueryCleanupTaskArg,Void,Void>

Parameters:

arg - Task arg.

Returns:

New job.

map0

protected Map<? extends ComputeJob,ClusterNode> map0(List<ClusterNode> subgrid,
                                                     @Nullable
                                                     VisorTaskArgument<VisorQueryCleanupTaskArg> arg)

Actual map logic.

Overrides:

map0 in class VisorMultiNodeTask<VisorQueryCleanupTaskArg,Void,Void>

Parameters:

subgrid - Nodes available for this task execution.

arg - Task execution argument.

Returns:

Map of grid jobs assigned to subgrid node.

reduce0

@Nullable
protected Void reduce0(List list)

Actual reduce logic.

Specified by:

reduce0 in class VisorMultiNodeTask<VisorQueryCleanupTaskArg,Void,Void>

Parameters:

list - Job results.

Returns:

Task result.