| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.util.lang |
| Modifier and Type | Method and Description |
|---|---|
<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 grid projection.
|
<R> R |
IgniteCompute.call(IgniteCallable<R> job)
Executes provided job on a node in this grid projection.
|
| Modifier and Type | Method and Description |
|---|---|
<R> Collection<R> |
IgniteCompute.call(Collection<? extends IgniteCallable<R>> jobs)
Executes collection of jobs on nodes within this grid projection.
|
<R1,R2> R2 |
IgniteCompute.call(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs on nodes within this grid projection.
|
| 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 grid projection.
|
<R> R |
IgniteComputeImpl.call(IgniteCallable<R> job)
Executes provided job on a node in this grid projection.
|
| Modifier and Type | Method and Description |
|---|---|
<R> Collection<R> |
IgniteComputeImpl.call(Collection<? extends IgniteCallable<R>> jobs)
Executes collection of jobs on nodes within this grid projection.
|
<R1,R2> R2 |
IgniteComputeImpl.call(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs on nodes within this grid projection.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteCallable<AtomicBoolean> |
GridFunc.newAtomicBoolean()
Returns a factory closure that creates new
AtomicBoolean instance
initialized to false. |
static IgniteCallable<AtomicInteger> |
GridFunc.newAtomicInt()
Returns a factory closure that creates new
AtomicInteger instance
initialized to zero. |
static IgniteCallable<AtomicLong> |
GridFunc.newAtomicLong()
Returns a factory closure that creates new
AtomicLong instance
initialized to zero. |
static <T> IgniteCallable<AtomicReference<T>> |
GridFunc.newAtomicRef()
Returns a factory closure that creates new
AtomicReference instance
initialized to null. |
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()
Returns a factory closure that creates new
LinkedList instance. |
static <T> IgniteCallable<List<T>> |
GridFunc.newList()
Returns a factory closure that creates new
List instance. |
static <K,V> IgniteCallable<Map<K,V>> |
GridFunc.newMap()
Returns a factory closure that creates new
Map instance. |
static <T> IgniteCallable<Set<T>> |
GridFunc.newSet()
Returns a factory closure that creates new
Set instance. |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015