@IgniteSpiNoop @IgniteSpiMultipleInstancesSupport(value=true) public class NoopCollisionSpi extends IgniteSpiAdapter implements CollisionSpi
CollisionSpi
. This is default implementation
since 4.5.0
version. When grid is started with NoopCollisionSpi
jobs are activated immediately on arrival to mapped node. This approach suits well
for large amount of small jobs (which is a wide-spread use case). User still can
control the number of concurrent jobs by setting maximum thread pool size defined
by IgniteConfiguration.getPublicThreadPoolSize()
configuration property.ignite, igniteInstanceName, log
Constructor and Description |
---|
NoopCollisionSpi() |
Modifier and Type | Method and Description |
---|---|
void |
onCollision(CollisionContext ctx)
This is a callback called:
new grid job arrived
executing job finished its execution
topology changed
periodically (on
EventType.EVT_NODE_METRICS_UPDATED )
When new job arrives it is added to the end of the wait list and this
method is called. |
void |
setExternalCollisionListener(@Nullable CollisionExternalListener lsnr)
Listener to be set for notification of external collision events (e.g. job stealing).
|
NoopCollisionSpi |
setName(String name)
Sets SPI name.
|
void |
spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
spiStop()
This method is called to stop SPI.
|
String |
toString() |
addTimeoutObject, assertParameter, checkConfigurationConsistency0, clientFailureDetectionTimeout, configInfo, createSpiAttributeName, failureDetectionTimeout, failureDetectionTimeoutEnabled, failureDetectionTimeoutEnabled, getConsistentAttributeNames, getExceptionRegistry, getLocalNode, getName, getNodeAttributes, getSpiContext, ignite, initFailureDetectionTimeout, injectables, injectResources, isNodeStopping, onBeforeStart, onClientDisconnected, onClientReconnected, onContextDestroyed, onContextDestroyed0, onContextInitialized, onContextInitialized0, registerMBean, removeTimeoutObject, started, startInfo, startStopwatch, stopInfo, unregisterMBean
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getName, getNodeAttributes, onClientDisconnected, onClientReconnected, onContextDestroyed, onContextInitialized
public void spiStart(@Nullable @Nullable String igniteInstanceName) throws IgniteSpiException
spiStart
in interface IgniteSpi
igniteInstanceName
- Name of Ignite instance this SPI is being started for
(null
for default Ignite instance).IgniteSpiException
- Throws in case of any error during SPI start.public void spiStop() throws IgniteSpiException
Note that this method can be called at any point including during recovery of failed start. It should make no assumptions on what state SPI will be in when this method is called.
spiStop
in interface IgniteSpi
IgniteSpiException
- Thrown in case of any error during SPI stop.public void onCollision(CollisionContext ctx)
EventType.EVT_NODE_METRICS_UPDATED
)
Implementation of this method should act on all lists, each of which contains collision
job contexts that define a set of operations available during collision resolution. Refer
to CollisionContext
and CollisionJobContext
documentation for
more information.
onCollision
in interface CollisionSpi
ctx
- Collision context which contains all collision lists.public void setExternalCollisionListener(@Nullable @Nullable CollisionExternalListener lsnr)
Ignite uses this listener to enable job stealing from overloaded to underloaded nodes.
However, you can also utilize it, for instance, to provide time based collision
resolution. To achieve this, you most likely would mark some job by setting a certain
attribute in job context (see ComputeJobContext
) for a job that requires
time-based scheduling and set some timer in your SPI implementation that would wake up
after a certain period of time. Once this period is reached, you would notify this
listener that a collision resolution should take place. Then inside of your collision
resolution logic, you would find the marked waiting job and activate it.
Note that most collision SPI's might not have external collisions. In that case, they should simply ignore this method and do nothing when listener is set.
setExternalCollisionListener
in interface CollisionSpi
lsnr
- Listener for external collision events (null
to unset the listener).public NoopCollisionSpi setName(String name)
setName
in class IgniteSpiAdapter
name
- SPI name.this
for chaining.
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024