Package org.apache.ignite.internal.processors.closure

Class GridClosureProcessor.C1<T,R>

java.lang.Object

org.apache.ignite.internal.processors.closure.GridClosureProcessor.C1<T,R>

All Implemented Interfaces:

Serializable, Binarylizable, ComputeJob, GridInternalWrapper<IgniteClosure>, GridNoImplicitInjection

Direct Known Subclasses:

GridClosureProcessor.C1MLA

Enclosing class:

GridClosureProcessor

public static class GridClosureProcessor.C1<T,R>
extends Object
implements ComputeJob, Binarylizable, GridNoImplicitInjection, GridInternalWrapper<IgniteClosure>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected T	arg
protected IgniteClosure<T,R>	job

Constructor Summary

Constructors

Constructor	Description
C1()

Method Summary

Modifier and Type	Method	Description
void	cancel()	This method is called when system detects that completion of this job can no longer alter the overall outcome (for example, when parent task has already reduced the results).
@Nullable Object	execute()	Executes this job.
void	readBinary(BinaryReader reader)	Reads fields from provided reader.
String	toString()
IgniteClosure	userObject()	Get user object where resources must be injected.
void	writeBinary(BinaryWriter writer)	Writes fields to provided writer.

Methods inherited from class java.lang.Object

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

Field Detail

job

@GridToStringInclude
protected IgniteClosure<T,R> job

arg

@GridToStringInclude(sensitive=true)
protected T arg

Constructor Detail

C1

public C1()

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.

cancel

public void cancel()

This method is called when system detects that completion of this job can no longer alter the overall outcome (for example, when parent task has already reduced the results). Job is also cancelled when IgniteFuture.cancel() is called.

Note that job cancellation is only a hint, and just like with Thread.interrupt() method, it is really up to the actual job instance to gracefully finish execution and exit.

Specified by:

cancel in interface ComputeJob

writeBinary

public void writeBinary(BinaryWriter writer)
                 throws BinaryObjectException

Writes fields to provided writer.

Specified by:

writeBinary in interface Binarylizable

Parameters:

writer - Binary object writer.

Throws:

BinaryObjectException - In case of error.

readBinary

public void readBinary(BinaryReader reader)
                throws BinaryObjectException

Reads fields from provided reader.

Specified by:

readBinary in interface Binarylizable

Parameters:

reader - Binary object reader.

Throws:

BinaryObjectException - In case of error.

userObject

public IgniteClosure userObject()

Get user object where resources must be injected.

Specified by:

userObject in interface GridInternalWrapper<T>

Returns:

User object.

toString

public String toString()

Overrides:

toString in class Object