org.apache.ignite.internal.visor.node

Class VisorNodeEventsCollectorTask

java.lang.Object

org.apache.ignite.internal.visor.VisorMultiNodeTask<VisorNodeEventsCollectorTaskArg,Iterable<? extends VisorGridEvent>,Collection<? extends VisorGridEvent>>

org.apache.ignite.internal.visor.node.VisorNodeEventsCollectorTask

All Implemented Interfaces:

Serializable, ComputeTask<VisorTaskArgument<VisorNodeEventsCollectorTaskArg>,Iterable<? extends VisorGridEvent>>

@GridInternal
public class VisorNodeEventsCollectorTask
extends VisorMultiNodeTask<VisorNodeEventsCollectorTaskArg,Iterable<? extends VisorGridEvent>,Collection<? extends VisorGridEvent>>

Task that runs on specified node and returns events data.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	VisorNodeEventsCollectorTask.VisorNodeEventsCollectorJob Job for task returns events data.

Field Summary

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

debug, ignite, start, taskArg

Constructor Summary

Constructors

Constructor and Description
VisorNodeEventsCollectorTask()

Method Summary

Modifier and Type	Method and Description
protected VisorNodeEventsCollectorTask.VisorNodeEventsCollectorJob	job(VisorNodeEventsCollectorTaskArg arg)
protected Iterable<? extends VisorGridEvent>	reduce0(List<ComputeJobResult> results) Actual reduce logic.

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

jobNodes, map, map0, reduce, result

Methods inherited from class java.lang.Object

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

Constructor Detail

VisorNodeEventsCollectorTask

public VisorNodeEventsCollectorTask()

Method Detail

job

protected VisorNodeEventsCollectorTask.VisorNodeEventsCollectorJob job(VisorNodeEventsCollectorTaskArg arg)

Specified by:

job in class VisorMultiNodeTask<VisorNodeEventsCollectorTaskArg,Iterable<? extends VisorGridEvent>,Collection<? extends VisorGridEvent>>

Parameters:

arg - Task arg.

Returns:

New job.

reduce0

protected Iterable<? extends VisorGridEvent> reduce0(List<ComputeJobResult> results)

Actual reduce logic.

Specified by:

reduce0 in class VisorMultiNodeTask<VisorNodeEventsCollectorTaskArg,Iterable<? extends VisorGridEvent>,Collection<? extends VisorGridEvent>>

Parameters:

results - Job results.

Returns:

Task result.