Package org.apache.ignite.internal.processors.cache

Class GridCacheAdapter.TopologyVersionAwareJob

java.lang.Object

org.apache.ignite.compute.ComputeJobAdapter

org.apache.ignite.internal.processors.cache.GridCacheAdapter.TopologyVersionAwareJob

All Implemented Interfaces:

Serializable, Callable<Object>, ComputeJob

Direct Known Subclasses:

GridDistributedCacheAdapter.GlobalRemoveAllJob

Enclosing class:

GridCacheAdapter<K,V>

public abstract static class GridCacheAdapter.TopologyVersionAwareJob
extends ComputeJobAdapter

Delayed callable class.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected String	cacheName	Cache name.
protected IgniteEx	ignite	Injected grid instance.
protected ComputeJobContext	jobCtx	Injected job context.
protected AffinityTopologyVersion	topVer	Affinity topology version.

Constructor Summary

Constructors

Constructor	Description
TopologyVersionAwareJob(String cacheName, AffinityTopologyVersion topVer)

Method Summary

Modifier and Type	Method	Description
@Nullable Object	execute()	Executes this job.
protected abstract @Nullable Object	localExecute(@Nullable IgniteInternalCache cache)

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

jobCtx

@JobContextResource
protected ComputeJobContext jobCtx

Injected job context.

ignite

@IgniteInstanceResource
protected IgniteEx ignite

Injected grid instance.

topVer

protected final AffinityTopologyVersion topVer

Affinity topology version.

cacheName

protected final String cacheName

Cache name.

Constructor Detail

TopologyVersionAwareJob

public TopologyVersionAwareJob(String cacheName,
                               AffinityTopologyVersion topVer)

Parameters:

cacheName - Cache name.

topVer - Affinity topology version.

Method Detail

execute

@Nullable
public final @Nullable Object execute()

Executes this job.

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.

localExecute

@Nullable
protected abstract @Nullable Object localExecute(@Nullable
                                                 @Nullable IgniteInternalCache cache)

Parameters:

cache - Cache.

Returns:

Local execution result.