org.apache.ignite.internal.visor.node

Class VisorNodeDataCollectorJob

java.lang.Object

org.apache.ignite.compute.ComputeJobAdapter

org.apache.ignite.internal.visor.VisorJob<VisorNodeDataCollectorTaskArg,VisorNodeDataCollectorJobResult>

org.apache.ignite.internal.visor.node.VisorNodeDataCollectorJob

All Implemented Interfaces:

Serializable, Callable<Object>, ComputeJob

public class VisorNodeDataCollectorJob
extends VisorJob<VisorNodeDataCollectorTaskArg,VisorNodeDataCollectorJobResult>

Job that collects data from node.

See Also:

Serialized Form

Field Summary

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

debug, ignite, start

Constructor Summary

Constructors

Constructor and Description
VisorNodeDataCollectorJob(VisorNodeDataCollectorTaskArg arg, boolean debug) Create job with given argument.

Method Summary

Modifier and Type	Method and Description
protected void	caches(VisorNodeDataCollectorJobResult res, VisorNodeDataCollectorTaskArg arg) Collect caches.
protected boolean	compatibleWith(IgniteProductVersion ver)
protected void	events(VisorNodeDataCollectorJobResult res, VisorNodeDataCollectorTaskArg arg) Collect events.
protected void	events0(VisorNodeDataCollectorJobResult res, String evtOrderKey, String evtThrottleCntrKey, boolean all) Collect events.
protected void	igfs(VisorNodeDataCollectorJobResult res) Collect IGFSs.
protected void	memoryMetrics(VisorNodeDataCollectorJobResult res) Collect memory metrics.
protected void	persistenceMetrics(VisorNodeDataCollectorJobResult res) Collect persistence metrics.
protected VisorNodeDataCollectorJobResult	run(VisorNodeDataCollectorJobResult res, VisorNodeDataCollectorTaskArg arg) Execution logic of concrete job.
protected VisorNodeDataCollectorJobResult	run(VisorNodeDataCollectorTaskArg arg) Execution logic of concrete job.
String	toString()

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

execute

Methods inherited from class org.apache.ignite.compute.ComputeJobAdapter

argument, arguments, call, cancel, isCancelled, setArguments

Methods inherited from class java.lang.Object

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

Constructor Detail

VisorNodeDataCollectorJob

public VisorNodeDataCollectorJob(VisorNodeDataCollectorTaskArg arg,
                                 boolean debug)

Create job with given argument.

Parameters:

arg - Job argument.

debug - Debug flag.

Method Detail

events0

protected void events0(VisorNodeDataCollectorJobResult res,
                       String evtOrderKey,
                       String evtThrottleCntrKey,
                       boolean all)

Collect events.

Parameters:

res - Job result.

evtOrderKey - Unique key to take last order key from node local map.

evtThrottleCntrKey - Unique key to take throttle count from node local map.

all - If true then collect all events otherwise collect only non task events.

events

protected void events(VisorNodeDataCollectorJobResult res,
                      VisorNodeDataCollectorTaskArg arg)

Collect events.

Parameters:

res - Job result.

arg - Task argument.

compatibleWith

protected boolean compatibleWith(IgniteProductVersion ver)

Parameters:

ver - Version to check.

Returns:

true if found at least one compatible node with specified version.

memoryMetrics

protected void memoryMetrics(VisorNodeDataCollectorJobResult res)

Collect memory metrics.

Parameters:

res - Job result.

caches

protected void caches(VisorNodeDataCollectorJobResult res,
                      VisorNodeDataCollectorTaskArg arg)

Collect caches.

Parameters:

res - Job result.

arg - Task argument.

igfs

protected void igfs(VisorNodeDataCollectorJobResult res)

Collect IGFSs.

Parameters:

res - Job result.

persistenceMetrics

protected void persistenceMetrics(VisorNodeDataCollectorJobResult res)

Collect persistence metrics.

Parameters:

res - Job result.

run

protected VisorNodeDataCollectorJobResult run(VisorNodeDataCollectorTaskArg arg)

Execution logic of concrete job.

Specified by:

run in class VisorJob<VisorNodeDataCollectorTaskArg,VisorNodeDataCollectorJobResult>

Parameters:

arg - Task argument.

Returns:

Result.

run

protected VisorNodeDataCollectorJobResult run(VisorNodeDataCollectorJobResult res,
                                              VisorNodeDataCollectorTaskArg arg)

Execution logic of concrete job.

Parameters:

res - Result response.

arg - Job argument.

Returns:

Job result.

toString

public String toString()

Overrides:

toString in class Object