Package org.apache.ignite.internal.visor

Class VisorJob<A,R>

java.lang.Object

org.apache.ignite.compute.ComputeJobAdapter

org.apache.ignite.internal.visor.VisorJob<A,R>

Type Parameters:

A - Job argument type.

R - Job result type.

All Implemented Interfaces:

Serializable, Callable<Object>, ComputeJob, PublicAccessJob

Direct Known Subclasses:

CacheConfigurationCollectorJob, CacheGroupEncryptionTask.ReencryptionBaseJob, SnapshotJob, TxTask.TxJob

public abstract class VisorJob<A,R>
extends ComputeJobAdapter
implements PublicAccessJob

Base class for Visor jobs.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	debug	Debug flag.
protected IgniteEx	ignite	Auto-injected grid instance.
protected long	start	Job start time.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	VisorJob(A arg, boolean debug)	Create job with specified argument.

Method Summary

Modifier and Type	Method	Description
@Nullable Object	execute()	Executes this job.
SecurityPermissionSet	requiredPermissions()
protected abstract R	run(A arg)	Execution logic of concrete job.

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, toString, wait, wait, wait

Field Detail

ignite

@IgniteInstanceResource
protected transient IgniteEx ignite

Auto-injected grid instance.

start

protected transient long start

Job start time.

debug

protected boolean debug

Debug flag.

Constructor Detail

VisorJob

protected VisorJob(@Nullable
                   A arg,
                   boolean debug)

Create job with specified argument.

Parameters:

arg - Job argument.

debug - Flag indicating whether debug information should be printed into node log.

Method Detail

execute

@Nullable
public @Nullable Object execute()

Executes this job.

Specified by:

execute in interface ComputeJob

Returns:

Job execution result (possibly null). This result will be returned in ComputeJobResult.getData() method passed into ComputeTask.result(ComputeJobResult, List) task method on caller node.

run

protected abstract R run(@Nullable
                         A arg)
                  throws IgniteException

Execution logic of concrete job.

Parameters:

arg - Task argument.

Returns:

Result.

Throws:

IgniteException - In case of error.

requiredPermissions

public SecurityPermissionSet requiredPermissions()

Specified by:

requiredPermissions in interface PublicAccessJob

Returns:

Set of permissions to be authorized before job execution.