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.datastructures
org.apache.ignite.internal.util.lang

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	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> Collection<R>	IgniteCompute.broadcast(IgniteCallable<R> job) Broadcasts given job to all nodes in cluster group.
<R> R	IgniteCompute.call(IgniteCallable<R> job) Executes provided job 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.

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(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> Collection<R>	IgniteComputeImpl.broadcast(IgniteCallable<R> job) Broadcasts given job to all nodes in cluster group.
<R> R	IgniteComputeImpl.call(IgniteCallable<R> job) Executes provided job 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.

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	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).
<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).

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<AtomicBoolean>	GridFunc.newAtomicBoolean() Deprecated.
static IgniteCallable<AtomicInteger>	GridFunc.newAtomicInt() Deprecated.
static IgniteCallable<AtomicLong>	GridFunc.newAtomicLong() Deprecated.
static <T> IgniteCallable<AtomicReference<T>>	GridFunc.newAtomicRef() 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 <T> IgniteCallable<ConcurrentLinkedDeque8<T>>	GridFunc.newDeque() Returns a factory closure that creates new ConcurrentLinkedDeque8 instance.
static <T> IgniteCallable<LinkedList<T>>	GridFunc.newLinkedList() Deprecated.
static <T> IgniteCallable<List<T>>	GridFunc.newList() Deprecated.
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.