Uses of Interface
org.apache.ignite.lang.IgniteCallable

Packages that use IgniteCallable

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.processors.cache	This package contain cache-related processors & persistence implementation.
org.apache.ignite.internal.processors.cache.persistence.migration
org.apache.ignite.internal.processors.cache.verify
org.apache.ignite.internal.processors.datastructures
org.apache.ignite.internal.processors.igfs.client
org.apache.ignite.internal.processors.igfs.client.meta
org.apache.ignite.internal.util.lang
org.apache.ignite.internal.util.lang.gridfunc	Contains utilities classes for GridFunc.
org.apache.ignite.internal.visor.cache

Uses of IgniteCallable in org.apache.ignite

Methods in org.apache.ignite with parameters of type IgniteCallable

Modifier and Type	Method and Description
<R> R	IgniteCompute.affinityCall(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job) Executes given job on the node where partition is located (the partition is primary on the node) It's guaranteed that the data of all the partitions of all participating caches, the affinity key belongs to, will present on the destination node throughout the job execution.
<R> R	IgniteCompute.affinityCall(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> R	IgniteSet.affinityCall(IgniteCallable<R> job) Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).
<R> R	IgniteQueue.affinityCall(IgniteCallable<R> job) Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).
<R> R	IgniteCompute.affinityCall(String cacheName, Object affKey, IgniteCallable<R> job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> IgniteFuture<R>	IgniteCompute.affinityCallAsync(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job) Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.
<R> IgniteFuture<R>	IgniteCompute.affinityCallAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> IgniteFuture<R>	IgniteCompute.affinityCallAsync(String cacheName, Object affKey, IgniteCallable<R> job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> Collection<R>	IgniteCompute.broadcast(IgniteCallable<R> job) Broadcasts given job to all nodes in cluster group.
<R> IgniteFuture<Collection<R>>	IgniteCompute.broadcastAsync(IgniteCallable<R> job) Broadcasts given job asynchronously to all nodes in cluster group.
<R> R	IgniteCompute.call(IgniteCallable<R> job) Executes provided job on a node within the underlying cluster group.
<R> IgniteFuture<R>	IgniteCompute.callAsync(IgniteCallable<R> job) Executes provided job asynchronously on a node within the underlying cluster group.

Method parameters in org.apache.ignite with type arguments of type IgniteCallable

Modifier and Type	Method and Description
<R> Collection<R>	IgniteCompute.call(Collection<? extends IgniteCallable<R>> jobs) Executes collection of jobs on nodes within the underlying cluster group.
<R1,R2> R2	IgniteCompute.call(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc) Executes collection of jobs on nodes within the underlying cluster group.
<R> IgniteFuture<Collection<R>>	IgniteCompute.callAsync(Collection<? extends IgniteCallable<R>> jobs) Executes collection of jobs asynchronously on nodes within the underlying cluster group.
<R1,R2> IgniteFuture<R2>	IgniteCompute.callAsync(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc) Executes collection of jobs asynchronously on nodes within the underlying cluster group.

Uses of IgniteCallable in org.apache.ignite.internal

Methods in org.apache.ignite.internal with parameters of type IgniteCallable

Modifier and Type	Method and Description
<R> R	IgniteComputeImpl.affinityCall(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job) Executes given job on the node where partition is located (the partition is primary on the node) It's guaranteed that the data of all the partitions of all participating caches, the affinity key belongs to, will present on the destination node throughout the job execution.
<R> R	IgniteComputeImpl.affinityCall(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> R	IgniteComputeImpl.affinityCall(String cacheName, Object affKey, IgniteCallable<R> job) Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> IgniteFuture<R>	IgniteComputeImpl.affinityCallAsync(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job) Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.
<R> IgniteFuture<R>	IgniteComputeImpl.affinityCallAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> IgniteFuture<R>	IgniteComputeImpl.affinityCallAsync(String cacheName, Object affKey, IgniteCallable<R> job) Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).
<R> Collection<R>	IgniteComputeImpl.broadcast(IgniteCallable<R> job) Broadcasts given job to all nodes in cluster group.
<R> IgniteFuture<Collection<R>>	IgniteComputeImpl.broadcastAsync(IgniteCallable<R> job) Broadcasts given job asynchronously to all nodes in cluster group.
<R> R	IgniteComputeImpl.call(IgniteCallable<R> job) Executes provided job on a node within the underlying cluster group.
<R> IgniteFuture<R>	IgniteComputeImpl.callAsync(IgniteCallable<R> job) Executes provided job asynchronously on a node within the underlying cluster group.

Method parameters in org.apache.ignite.internal with type arguments of type IgniteCallable

Modifier and Type	Method and Description
<R> Collection<R>	IgniteComputeImpl.call(Collection<? extends IgniteCallable<R>> jobs) Executes collection of jobs on nodes within the underlying cluster group.
<R1,R2> R2	IgniteComputeImpl.call(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc) Executes collection of jobs on nodes within the underlying cluster group.
<R> IgniteFuture<Collection<R>>	IgniteComputeImpl.callAsync(Collection<? extends IgniteCallable<R>> jobs) Executes collection of jobs asynchronously on nodes within the underlying cluster group.
<R1,R2> IgniteFuture<R2>	IgniteComputeImpl.callAsync(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc) Executes collection of jobs asynchronously on nodes within the underlying cluster group.

Uses of IgniteCallable in org.apache.ignite.internal.processors.cache

Classes in org.apache.ignite.internal.processors.cache that implement IgniteCallable

Modifier and Type	Class and Description
class	FetchActiveTxOwnerTraceClosure Closure that is computed on near node to get the stack trace of active transaction owner thread.

Uses of IgniteCallable in org.apache.ignite.internal.processors.cache.persistence.migration

Classes in org.apache.ignite.internal.processors.cache.persistence.migration that implement IgniteCallable

Modifier and Type	Class and Description
class	UpgradePendingTreeToPerPartitionTask Ignite native persistence migration task upgrades existed PendingTrees to per-partition basis.

Uses of IgniteCallable in org.apache.ignite.internal.processors.cache.verify

Classes in org.apache.ignite.internal.processors.cache.verify that implement IgniteCallable

Modifier and Type	Class and Description
class	ContentionClosure
class	ViewCacheClosure View cache closure.

Uses of IgniteCallable in org.apache.ignite.internal.processors.datastructures

Methods in org.apache.ignite.internal.processors.datastructures with parameters of type IgniteCallable

Modifier and Type	Method and Description
<R> R	GridCacheQueueProxy.affinityCall(IgniteCallable<R> job) Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).
<R> R	GridCacheSetImpl.affinityCall(IgniteCallable<R> job) Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).
<R> R	GridCacheSetProxy.affinityCall(IgniteCallable<R> job) Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).
<R> R	GridCacheQueueAdapter.affinityCall(IgniteCallable<R> job) Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).

Uses of IgniteCallable in org.apache.ignite.internal.processors.igfs.client

Classes in org.apache.ignite.internal.processors.igfs.client that implement IgniteCallable

Modifier and Type	Class and Description
class	IgfsClientAbstractCallable<T> Abstract callable for IGFS tasks initiated on client node and passed to data node.
class	IgfsClientAffinityCallable IGFS client affinity callable.
class	IgfsClientDeleteCallable IGFS client delete callable.
class	IgfsClientExistsCallable IGFS client exists callable.
class	IgfsClientInfoCallable IGFS client info callable.
class	IgfsClientListFilesCallable IGFS client list files callable.
class	IgfsClientListPathsCallable IGFS client list paths callable.
class	IgfsClientMkdirsCallable IGFS client mkdirs callable.
class	IgfsClientRenameCallable IGFS client rename callable.
class	IgfsClientSetTimesCallable IGFS client set times callable.
class	IgfsClientSizeCallable IGFS client size callable.
class	IgfsClientSummaryCallable IGFS client summary callable.
class	IgfsClientUpdateCallable IGFS client update callable.

Uses of IgniteCallable in org.apache.ignite.internal.processors.igfs.client.meta

Classes in org.apache.ignite.internal.processors.igfs.client.meta that implement IgniteCallable

Modifier and Type	Class and Description
class	IgfsClientMetaIdsForPathCallable Get entry info for the given path.
class	IgfsClientMetaInfoForPathCallable Get entry info for the given path.
class	IgfsClientMetaUnlockCallable IGFS client unlock callable.

Uses of IgniteCallable in org.apache.ignite.internal.util.lang

Methods in org.apache.ignite.internal.util.lang that return IgniteCallable

Modifier and Type	Method and Description
static IgniteCallable<AtomicInteger>	GridFunc.newAtomicInt() Deprecated.
static <K,V> IgniteCallable<ConcurrentMap<K,V>>	GridFunc.newCMap() Returns a factory closure that creates new ConcurrentMap instance.
static <E> IgniteCallable<Set<E>>	GridFunc.newCSet() Returns a factory closure that creates new GridConcurrentHashSet instance.
static <K,V> IgniteCallable<Map<K,V>>	GridFunc.newMap() Deprecated.
static <T> IgniteCallable<Set<T>>	GridFunc.newSet() Returns a factory closure that creates new Set instance.

Uses of IgniteCallable in org.apache.ignite.internal.util.lang.gridfunc

Classes in org.apache.ignite.internal.util.lang.gridfunc that implement IgniteCallable

Modifier and Type	Class and Description
class	AtomicIntegerFactoryCallable Atomic integer factory.
class	ConcurrentHashSetFactoryCallable Concurrent hash set factory.
class	ConcurrentMapFactoryCallable Concurrent hash map factory.
class	MapFactoryCallable Hash map factory.
class	SetFactoryCallable Hash set factory.

Uses of IgniteCallable in org.apache.ignite.internal.visor.cache

Classes in org.apache.ignite.internal.visor.cache that implement IgniteCallable

Modifier and Type	Class and Description
class	VisorFindAndDeleteGarbageInPersistenceClosure Class contains logic of finding data of already destroyed caches in running cache groups.