Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
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 |
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