| Package | Description |
|---|---|
| org.apache.ignite.spi |
Contains common classes and interfaces for SPI implementations.
|
| org.apache.ignite.spi.checkpoint |
Contains APIs for checkpoint SPI.
|
| org.apache.ignite.spi.checkpoint.cache |
Contains cache-based implementation for checkpoint SPI.
|
| org.apache.ignite.spi.checkpoint.jdbc |
Contains JDBC implementation for checkpoint SPI.
|
| org.apache.ignite.spi.checkpoint.noop |
Contains default no-op checkpoint SPI implementation.
|
| org.apache.ignite.spi.checkpoint.s3 |
Contains S3-based implementation for checkpoint SPI.
|
| org.apache.ignite.spi.checkpoint.sharedfs |
Contains shared file system implementation for checkpoint SPI.
|
| org.apache.ignite.spi.collision.fifoqueue |
Contains FIFO based collision SPI implementation.
|
| org.apache.ignite.spi.collision.jobstealing |
Contains job stealing collision SPI implementation.
|
| org.apache.ignite.spi.collision.noop |
Contains default no-op collision SPI implementation.
|
| org.apache.ignite.spi.collision.priorityqueue |
Contains priority based collision SPI implementation.
|
| 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.
|
| org.apache.ignite.spi.deployment |
Contains APIs for deployment SPI.
|
| org.apache.ignite.spi.deployment.local |
Contains default local deployment SPI implementation.
|
| org.apache.ignite.spi.deployment.uri |
Contains URI-based deployment SPI implementation.
|
| org.apache.ignite.spi.discovery |
Contains APIs for topology manager SPI.
|
| org.apache.ignite.spi.discovery.tcp |
Contains default TCP/IP implementation for discovery SPI.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder |
Contains IP finder interface and adapter.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.cloud |
Contains Apache jclouds based IP finder.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.elb |
Contains AWS ELB-based IP finder.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.gce |
Contains Google Cloud Storage IP finder.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.jdbc |
Contains JDBC IP finder implementation.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.kubernetes |
Contains Kubernetes IP finder implementation.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.multicast |
Contains multicast-based IP finder.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.s3 |
Contains AWS S3-based IP finder.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.sharedfs |
Contains shared filesystem-based IP finder.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.vm |
Contains local JVM-based IP finder.
|
| org.apache.ignite.spi.discovery.tcp.ipfinder.zk |
Contains TCP Discovery IP Finder uses Apache ZooKeeper (ZK) to locate peer nodes.
|
| org.apache.ignite.spi.discovery.zk |
Contains Zookeeper Discovery Spi classes and interfaces.
|
| org.apache.ignite.spi.encryption.keystore |
Contains encryption SPI implementation based on standard jdk keystore.
|
| org.apache.ignite.spi.encryption.noop |
Contains no-op encryption SPI implementation.
|
| org.apache.ignite.spi.eventstorage |
Contains APIs for event storage SPI.
|
| org.apache.ignite.spi.eventstorage.memory |
Contains default in-memory implementation for event storage SPI.
|
| org.apache.ignite.spi.failover.always |
Contains default "always" failover SPI.
|
| org.apache.ignite.spi.failover.jobstealing |
Contains job stealing failover SPI.
|
| org.apache.ignite.spi.failover.never |
Contains "never" failover SPI.
|
| org.apache.ignite.spi.indexing |
Contains APIs for indexing SPI.
|
| org.apache.ignite.spi.indexing.noop |
Contains default no-op indexing SPI implementation.
|
| org.apache.ignite.spi.loadbalancing.adaptive |
Contains adaptive load balancing SPI.
|
| org.apache.ignite.spi.loadbalancing.roundrobin |
Contains default round-robin implementation for load balancing SPI.
|
| org.apache.ignite.spi.loadbalancing.weightedrandom |
Contains weighted random-base implementation for load balancing SPI.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteSpiMultiException
Grid SPI exception which may contain more than one failure.
|
class |
IgniteSpiVersionCheckException
Grid SPI exception for version check failure.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
IgniteSpiAdapter.assertParameter(boolean cond,
String condDesc)
Throws exception with uniform error message if given parameter's assertion condition
is
false. |
protected void |
IgniteSpiAdapter.checkConfigurationConsistency0(IgniteSpiContext spiCtx,
ClusterNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
Map<String,Object> |
IgniteSpi.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
Map<String,Object> |
IgniteSpiAdapter.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
void |
IgniteSpi.onContextInitialized(IgniteSpiContext spiCtx)
Callback invoked when SPI context is initialized.
|
void |
IgniteSpiAdapter.onContextInitialized(IgniteSpiContext spiCtx)
Callback invoked when SPI context is initialized.
|
protected void |
IgniteSpiAdapter.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
protected <T extends IgniteSpiManagementMBean> |
IgniteSpiAdapter.registerMBean(String igniteInstanceName,
T impl,
Class<T> mbeanItf)
Registers SPI MBean.
|
void |
IgniteSpiContext.send(ClusterNode node,
Serializable msg,
String topic)
Sends a message to a remote node.
|
void |
IgniteSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
IgniteSpi.spiStop()
This method is called to stop SPI.
|
protected void |
IgniteSpiAdapter.unregisterMBean()
Unregisters MBean.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable byte[] |
CheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
CheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable byte[] |
CacheCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
protected void |
CacheCheckpointSpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
boolean |
CacheCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
CacheCheckpointSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
CacheCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
JdbcCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
JdbcCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
JdbcCheckpointSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
JdbcCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable byte[] |
NoopCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
void |
NoopCheckpointSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
NoopCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
S3CheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
S3CheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
S3CheckpointSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
S3CheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
SharedFsCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
SharedFsCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
SharedFsCheckpointSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
SharedFsCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FifoQueueCollisionSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
FifoQueueCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
JobStealingCollisionSpi.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
protected void |
JobStealingCollisionSpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
JobStealingCollisionSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
JobStealingCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NoopCollisionSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
NoopCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
PriorityQueueCollisionSpi.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
void |
PriorityQueueCollisionSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
PriorityQueueCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CommunicationSpi.sendMessage(ClusterNode destNode,
T msg)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
TcpCommunicationSpi.checkConfigurationConsistency0(IgniteSpiContext spiCtx,
ClusterNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
Map<String,Object> |
TcpCommunicationSpi.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
void |
TcpCommunicationSpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg)
Sends given message to destination node.
|
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg,
IgniteInClosure<IgniteException> ackC)
Sends given message to destination node.
|
void |
TcpCommunicationSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
TcpCommunicationSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
DeploymentSpi.register(ClassLoader ldr,
Class<?> rsrc)
Registers a class loader with this SPI.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
LocalDeploymentSpi.register(ClassLoader ldr,
Class<?> rsrc)
Registers a class loader with this SPI.
|
void |
LocalDeploymentSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
LocalDeploymentSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
UriDeploymentSpi.register(ClassLoader ldr,
Class<?> rsrc)
Registers a class loader with this SPI.
|
void |
UriDeploymentSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
UriDeploymentSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable Serializable |
DiscoverySpi.consistentId()
Gets consistent ID.
|
void |
DiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteSpiException |
TcpDiscoverySpi.authenticationFailedError(org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryAuthFailedMessage msg) |
protected IgniteSpiException |
TcpDiscoverySpi.checkFailedError(org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryCheckFailedMessage msg) |
protected IgniteSpiException |
TcpDiscoverySpi.duplicateIdError(org.apache.ignite.spi.discovery.tcp.messages.TcpDiscoveryDuplicateIdMessage msg) |
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoverySpi.clientReconnect() |
@Nullable Serializable |
TcpDiscoverySpi.consistentId()
Gets consistent ID.
|
void |
TcpDiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
protected void |
TcpDiscoverySpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
protected Collection<InetSocketAddress> |
TcpDiscoverySpi.registeredAddresses()
Gets addresses registered in the IP finder, initializes addresses having no
port (or 0 port) with
TcpDiscoverySpi.DFLT_PORT. |
protected Collection<InetSocketAddress> |
TcpDiscoverySpi.resolvedAddresses()
Resolves addresses registered in the IP finder, removes duplicates and local host
address and returns the collection of.
|
void |
TcpDiscoverySpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
TcpDiscoverySpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryIpFinderAdapter.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
void |
TcpDiscoveryIpFinder.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
void |
TcpDiscoveryIpFinderAdapter.onSpiContextInitialized(IgniteSpiContext spiCtx)
Callback invoked when SPI context is initialized after
TcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
void |
TcpDiscoveryIpFinder.onSpiContextInitialized(IgniteSpiContext spiCtx)
Callback invoked when SPI context is initialized after
TcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
void |
TcpDiscoveryIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryCloudIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryCloudIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryCloudIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryElbIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryElbIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryElbIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryGoogleStorageIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryGoogleStorageIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryGoogleStorageIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryJdbcIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryJdbcIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryJdbcIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryKubernetesIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryKubernetesIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryKubernetesIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoveryMulticastIpFinder.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
void |
TcpDiscoveryMulticastIpFinder.onSpiContextInitialized(IgniteSpiContext spiCtx)
Callback invoked when SPI context is initialized after
TcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryS3IpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryS3IpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryS3IpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoverySharedFsIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoverySharedFsIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoverySharedFsIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
TcpDiscoveryVmIpFinder |
TcpDiscoveryVmIpFinder.setAddresses(Collection<String> addrs)
Parses provided values and initializes the internal collection of addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
TcpDiscoveryZookeeperIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
TcpDiscoveryZookeeperIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryZookeeperIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable Serializable |
ZookeeperDiscoverySpi.consistentId()
Gets consistent ID.
|
void |
ZookeeperDiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
void |
ZookeeperDiscoverySpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
ZookeeperDiscoverySpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
KeystoreEncryptionSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
KeystoreEncryptionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NoopEncryptionSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
NoopEncryptionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NoopEventStorageSpi.record(Event evt)
Records single event.
|
void |
EventStorageSpi.record(Event evt)
Records single event.
|
void |
NoopEventStorageSpi.spiStart(@Nullable String gridName)
This method is called to start SPI.
|
void |
NoopEventStorageSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MemoryEventStorageSpi.record(Event evt)
Records single event.
|
void |
MemoryEventStorageSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
MemoryEventStorageSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
AlwaysFailoverSpi.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
void |
AlwaysFailoverSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
AlwaysFailoverSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
JobStealingFailoverSpi.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
void |
JobStealingFailoverSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
JobStealingFailoverSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NeverFailoverSpi.spiStart(String igniteInstanceName)
This method is called to start SPI.
|
void |
NeverFailoverSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Iterator<javax.cache.Cache.Entry<?,?>> |
IndexingSpi.query(@Nullable String cacheName,
Collection<Object> params,
@Nullable IndexingQueryFilter filters)
Executes query.
|
void |
IndexingSpi.remove(@Nullable String cacheName,
Object key)
Removes index entry by key.
|
void |
IndexingSpi.store(@Nullable String cacheName,
Object key,
Object val,
long expirationTime)
Updates index.
|
| Modifier and Type | Method and Description |
|---|---|
Iterator<javax.cache.Cache.Entry<?,?>> |
NoopIndexingSpi.query(@Nullable String cacheName,
Collection<Object> params,
@Nullable IndexingQueryFilter filters)
Executes query.
|
void |
NoopIndexingSpi.remove(@Nullable String cacheName,
Object key)
Removes index entry by key.
|
void |
NoopIndexingSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
NoopIndexingSpi.spiStop()
This method is called to stop SPI.
|
void |
NoopIndexingSpi.store(@Nullable String cacheName,
Object key,
Object val,
long expirationTime)
Updates index.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
AdaptiveLoadBalancingSpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
AdaptiveLoadBalancingSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
AdaptiveLoadBalancingSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
RoundRobinLoadBalancingSpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
RoundRobinLoadBalancingSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
RoundRobinLoadBalancingSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
WeightedRandomLoadBalancingSpi.getNodeAttributes()
This method is called before SPI starts (before method
IgniteSpi.spiStart(String)
is called). |
protected void |
WeightedRandomLoadBalancingSpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
WeightedRandomLoadBalancingSpi.spiStart(@Nullable String igniteInstanceName)
This method is called to start SPI.
|
void |
WeightedRandomLoadBalancingSpi.spiStop()
This method is called to stop SPI.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019