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

Modifier and Type	Field and Description
protected static IgniteProductVersion	VER_1_7_2

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

Methods

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 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, call, cancel, isCancelled, setArguments

Methods inherited from class java.lang.Object

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

Field Detail

VER_1_7_2

protected static final IgniteProductVersion VER_1_7_2

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.

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.

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