| 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.processors.igfs.client | |
| org.apache.ignite.internal.processors.igfs.client.meta | |
| org.apache.ignite.internal.util.lang |
| Modifier and Type | Method and Description |
|---|---|
<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 |
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 |
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.
|
| 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.
|
| 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.
|
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
<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 |
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 |
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 |
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).
|
| 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.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgfsClientMetaIdsForPathCallable
Get entry info for the given path.
|
class |
IgfsClientMetaInfoForPathCallable
Get entry info for the given path.
|
| 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. |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.7.0 Release Date : August 1 2016