| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.util.lang | |
| org.apache.ignite.internal.util.nio |
NIO server interfaces and common utility classes for NIO.
|
| org.apache.ignite.internal.util.typedef |
Contains typedefs definitions for frequently used classes.
|
| org.apache.ignite.spi.communication |
Contains APIs for grid communication SPI.
|
| org.apache.ignite.spi.communication.tcp |
Contains default TCP/IP-based implementation for communication SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCompute.affinityRun(String cacheName,
Object affKey,
IgniteRunnable job)
Executes given job on the node where data for provided affinity key is located
(a.k.a. affinity co-location).
|
void |
IgniteCompute.broadcast(IgniteRunnable job)
Broadcasts given job to all nodes in the cluster group.
|
void |
IgniteCompute.run(IgniteRunnable job)
Executes provided job on a node within the underlying cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCompute.run(Collection<? extends IgniteRunnable> jobs)
Executes collection of jobs on grid nodes within the underlying cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteComputeImpl.affinityRun(String cacheName,
Object affKey,
IgniteRunnable job)
Executes given job on the node where data for provided affinity key is located
(a.k.a. affinity co-location).
|
void |
IgniteComputeImpl.broadcast(IgniteRunnable job)
Broadcasts given job to all nodes in the cluster group.
|
void |
IgniteComputeImpl.run(IgniteRunnable job)
Executes provided job on a node within the underlying cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteComputeImpl.run(Collection<? extends IgniteRunnable> jobs)
Executes collection of jobs on grid nodes within the underlying cluster group.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridAbsClosure
Defines a convenient absolute, i.e.
|
class |
GridAbsClosureX
Convenient abs-closure subclass that allows for thrown grid exception.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNioMessageTracker
Message tracker.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CA
Defines
alias for GridAbsClosure by extending it. |
class |
CAX
Defines
alias for GridAbsClosureX by extending it. |
| Modifier and Type | Method and Description |
|---|---|
void |
CommunicationListener.onMessage(UUID nodeId,
T msg,
IgniteRunnable msgC)
NOTE:
CommunicationSpi should ignore very first 4 bytes received from
sender node and pass the rest of the received message to the listener. |
| Modifier and Type | Method and Description |
|---|---|
protected void |
TcpCommunicationSpi.notifyListener(UUID sndId,
Message msg,
IgniteRunnable msgC) |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.2.0-incubating Release Date : June 16 2015