org.apache.ignite.internal.visor.node

Class VisorNodeDataCollectorTask

java.lang.Object

org.apache.ignite.internal.visor.VisorMultiNodeTask<VisorNodeDataCollectorTaskArg,VisorNodeDataCollectorTaskResult,VisorNodeDataCollectorJobResult>

org.apache.ignite.internal.visor.node.VisorNodeDataCollectorTask

All Implemented Interfaces:

Serializable, ComputeTask<VisorTaskArgument<VisorNodeDataCollectorTaskArg>,VisorNodeDataCollectorTaskResult>

@GridInternal
public class VisorNodeDataCollectorTask
extends VisorMultiNodeTask<VisorNodeDataCollectorTaskArg,VisorNodeDataCollectorTaskResult,VisorNodeDataCollectorJobResult>

Collects current Grid state mostly topology and metrics.

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

Method Summary

Modifier and Type	Method and Description
protected VisorNodeDataCollectorJob	job(VisorNodeDataCollectorTaskArg arg)
protected VisorNodeDataCollectorTaskResult	reduce(VisorNodeDataCollectorTaskResult taskRes, List<ComputeJobResult> results)
protected VisorNodeDataCollectorTaskResult	reduce0(List<ComputeJobResult> results) Actual reduce logic.
protected void	reduceJobResult(VisorNodeDataCollectorTaskResult taskRes, VisorNodeDataCollectorJobResult jobRes, UUID nid) Reduce job result.

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

VisorNodeDataCollectorTask

public VisorNodeDataCollectorTask()

Method Detail

job

protected VisorNodeDataCollectorJob job(VisorNodeDataCollectorTaskArg arg)

Specified by:

job in class VisorMultiNodeTask<VisorNodeDataCollectorTaskArg,VisorNodeDataCollectorTaskResult,VisorNodeDataCollectorJobResult>

Parameters:

arg - Task arg.

Returns:

New job.

reduce0

@Nullable
protected VisorNodeDataCollectorTaskResult reduce0(List<ComputeJobResult> results)

Actual reduce logic.

Specified by:

reduce0 in class VisorMultiNodeTask<VisorNodeDataCollectorTaskArg,VisorNodeDataCollectorTaskResult,VisorNodeDataCollectorJobResult>

Parameters:

results - Job results.

Returns:

Task result.

reduce

protected VisorNodeDataCollectorTaskResult reduce(VisorNodeDataCollectorTaskResult taskRes,
                                                  List<ComputeJobResult> results)

Parameters:

taskRes - Task result.

results - Results.

Returns:

Data collector task result.

reduceJobResult

protected void reduceJobResult(VisorNodeDataCollectorTaskResult taskRes,
                               VisorNodeDataCollectorJobResult jobRes,
                               UUID nid)

Reduce job result.

Parameters:

taskRes - Task result.

jobRes - Job result.

nid - Node ID.