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.jdbc |
Contains JDBC 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.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 | |
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.
|
org.apache.ignite.spi.swapspace |
Contains APIs for swap space SPI.
|
org.apache.ignite.spi.swapspace.file |
Contains file-based swap space SPI.
|
org.apache.ignite.spi.swapspace.noop |
Contains default no-op swap space SPI implementation.
|
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 gridName,
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(String gridName)
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 |
---|---|
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 |
---|---|
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(String gridName)
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 gridName)
This method is called to start SPI.
|
void |
JdbcCheckpointSpi.spiStop()
This method is called to stop SPI.
|
Modifier and Type | Method and Description |
---|---|
byte[] |
NoopCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
NoopCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
NoopCheckpointSpi.spiStart(String gridName)
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 gridName)
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 gridName)
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 gridName)
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 gridName)
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(String gridName)
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 gridName)
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.spiStart(String gridName)
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(String gridName)
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 gridName)
This method is called to start SPI.
|
void |
UriDeploymentSpi.spiStop()
This method is called to stop SPI.
|
Modifier and Type | Method and Description |
---|---|
void |
DiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
Modifier and Type | Method and Description |
---|---|
void |
TcpDiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
void |
TcpClientDiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
void |
TcpDiscoverySpi.onContextInitialized0(IgniteSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
TcpDiscoverySpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
TcpClientDiscoverySpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
TcpDiscoverySpi.spiStop()
This method is called to stop SPI.
|
void |
TcpClientDiscoverySpi.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 |
TcpDiscoveryIpFinder.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
void |
TcpDiscoveryIpFinderAdapter.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
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 |
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.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
TcpDiscoveryIpFinder.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 |
---|---|
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 |
---|---|
void |
TcpDiscoveryVmIpFinder.setAddresses(Collection<String> addrs)
Parses provided values and initializes the internal collection of addresses.
|
Modifier and Type | Method and Description |
---|---|
void |
EventStorageSpi.record(Event evt)
Records single event.
|
Modifier and Type | Method and Description |
---|---|
void |
MemoryEventStorageSpi.record(Event evt)
Records single event.
|
void |
MemoryEventStorageSpi.spiStart(String gridName)
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 gridName)
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 gridName)
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 gridName)
This method is called to start SPI.
|
void |
NeverFailoverSpi.spiStop()
This method is called to stop SPI.
|
Modifier and Type | Method and Description |
---|---|
void |
IndexingSpi.onSwap(String spaceName,
Object key)
Will be called when entry with given key is swapped.
|
void |
IndexingSpi.onUnswap(String spaceName,
Object key,
Object val)
Will be called when entry with given key is unswapped.
|
Iterator<javax.cache.Cache.Entry<?,?>> |
IndexingSpi.query(String spaceName,
Collection<Object> params,
IndexingQueryFilter filters)
Executes query.
|
void |
IndexingSpi.remove(String spaceName,
Object key)
Removes index entry by key.
|
void |
IndexingSpi.store(String spaceName,
Object key,
Object val,
long expirationTime)
Updates index.
|
Modifier and Type | Method and Description |
---|---|
void |
NoopIndexingSpi.onSwap(String spaceName,
Object key)
Will be called when entry with given key is swapped.
|
void |
NoopIndexingSpi.onUnswap(String spaceName,
Object key,
Object val)
Will be called when entry with given key is unswapped.
|
Iterator<javax.cache.Cache.Entry<?,?>> |
NoopIndexingSpi.query(String spaceName,
Collection<Object> params,
IndexingQueryFilter filters)
Executes query.
|
void |
NoopIndexingSpi.remove(String spaceName,
Object key)
Removes index entry by key.
|
void |
NoopIndexingSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
NoopIndexingSpi.spiStop()
This method is called to stop SPI.
|
void |
NoopIndexingSpi.store(String spaceName,
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(String gridName)
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(String gridName)
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(String gridName)
This method is called to start SPI.
|
void |
WeightedRandomLoadBalancingSpi.spiStop()
This method is called to stop SPI.
|
Modifier and Type | Method and Description |
---|---|
void |
SwapSpaceSpi.clear(String spaceName)
Entirely clears data space with given name, if any.
|
long |
SwapSpaceSpi.count(String spaceName)
Gets number of stored entries (keys) in data space with given name.
|
long |
SwapSpaceSpi.count(String spaceName,
Set<Integer> parts)
Gets number of stored entries (keys) in data space with given name.
|
<K> IgniteSpiCloseableIterator<K> |
SwapSpaceSpi.keyIterator(String spaceName,
SwapContext ctx)
Gets iterator over space keys.
|
Collection<Integer> |
SwapSpaceSpi.partitions(String spaceName)
Gets partitions IDs that are stored in the passed in space.
|
IgniteSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
SwapSpaceSpi.rawIterator(String spaceName)
Gets raw iterator over space entries.
|
IgniteSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
SwapSpaceSpi.rawIterator(String spaceName,
int part)
Gets raw iterator over space entries.
|
byte[] |
SwapSpaceSpi.read(String spaceName,
SwapKey key,
SwapContext ctx)
Reads stored value as array of bytes by key from data space with given name.
|
Map<SwapKey,byte[]> |
SwapSpaceSpi.readAll(String spaceName,
Iterable<SwapKey> keys,
SwapContext ctx)
Reads stored values as array of bytes by all passed keys from data space with
given name.
|
void |
SwapSpaceSpi.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
SwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
void |
SwapSpaceSpi.removeAll(String spaceName,
Collection<SwapKey> keys,
IgniteBiInClosure<SwapKey,byte[]> c,
SwapContext ctx)
Removes values stored in data space with given name corresponding to specified keys.
|
long |
SwapSpaceSpi.size(String spaceName)
Gets size in bytes for data space with given name.
|
void |
SwapSpaceSpi.store(String spaceName,
SwapKey key,
byte[] val,
SwapContext ctx)
Stores value as array of bytes with given key into data space with given name.
|
void |
SwapSpaceSpi.storeAll(String spaceName,
Map<SwapKey,byte[]> pairs,
SwapContext ctx)
Stores key-value pairs (both keys and values are arrays of bytes) into data
space with given name.
|
Modifier and Type | Method and Description |
---|---|
void |
FileSwapSpaceSpi.clear(String spaceName)
Entirely clears data space with given name, if any.
|
long |
FileSwapSpaceSpi.count(String spaceName)
Gets number of stored entries (keys) in data space with given name.
|
long |
FileSwapSpaceSpi.count(String spaceName,
Set<Integer> parts)
Gets number of stored entries (keys) in data space with given name.
|
<K> IgniteSpiCloseableIterator<K> |
FileSwapSpaceSpi.keyIterator(String spaceName,
SwapContext ctx)
Gets iterator over space keys.
|
Collection<Integer> |
FileSwapSpaceSpi.partitions(String spaceName)
Gets partitions IDs that are stored in the passed in space.
|
IgniteSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
FileSwapSpaceSpi.rawIterator(String spaceName)
Gets raw iterator over space entries.
|
IgniteSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
FileSwapSpaceSpi.rawIterator(String spaceName,
int part)
Gets raw iterator over space entries.
|
byte[] |
FileSwapSpaceSpi.read(String spaceName,
SwapKey key,
SwapContext ctx)
Reads stored value as array of bytes by key from data space with given name.
|
Map<SwapKey,byte[]> |
FileSwapSpaceSpi.readAll(String spaceName,
Iterable<SwapKey> keys,
SwapContext ctx)
Reads stored values as array of bytes by all passed keys from data space with
given name.
|
void |
FileSwapSpaceSpi.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
SwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
void |
FileSwapSpaceSpi.removeAll(String spaceName,
Collection<SwapKey> keys,
IgniteBiInClosure<SwapKey,byte[]> c,
SwapContext ctx)
Removes values stored in data space with given name corresponding to specified keys.
|
long |
FileSwapSpaceSpi.size(String spaceName)
Gets size in bytes for data space with given name.
|
void |
FileSwapSpaceSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
FileSwapSpaceSpi.spiStop()
This method is called to stop SPI.
|
void |
FileSwapSpaceSpi.store(String spaceName,
SwapKey key,
byte[] val,
SwapContext ctx)
Stores value as array of bytes with given key into data space with given name.
|
void |
FileSwapSpaceSpi.storeAll(String spaceName,
Map<SwapKey,byte[]> pairs,
SwapContext ctx)
Stores key-value pairs (both keys and values are arrays of bytes) into data
space with given name.
|
Modifier and Type | Method and Description |
---|---|
void |
NoopSwapSpaceSpi.clear(String space)
Entirely clears data space with given name, if any.
|
long |
NoopSwapSpaceSpi.count(String space)
Gets number of stored entries (keys) in data space with given name.
|
long |
NoopSwapSpaceSpi.count(String spaceName,
Set<Integer> parts)
Gets number of stored entries (keys) in data space with given name.
|
<K> IgniteSpiCloseableIterator<K> |
NoopSwapSpaceSpi.keyIterator(String spaceName,
SwapContext ctx)
Gets iterator over space keys.
|
Collection<Integer> |
NoopSwapSpaceSpi.partitions(String spaceName)
Gets partitions IDs that are stored in the passed in space.
|
IgniteSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
NoopSwapSpaceSpi.rawIterator(String spaceName)
Gets raw iterator over space entries.
|
IgniteSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
NoopSwapSpaceSpi.rawIterator(String spaceName,
int part)
Gets raw iterator over space entries.
|
byte[] |
NoopSwapSpaceSpi.read(String spaceName,
SwapKey key,
SwapContext ctx)
Reads stored value as array of bytes by key from data space with given name.
|
Map<SwapKey,byte[]> |
NoopSwapSpaceSpi.readAll(String spaceName,
Iterable<SwapKey> keys,
SwapContext ctx)
Reads stored values as array of bytes by all passed keys from data space with
given name.
|
void |
NoopSwapSpaceSpi.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
SwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
void |
NoopSwapSpaceSpi.removeAll(String spaceName,
Collection<SwapKey> keys,
IgniteBiInClosure<SwapKey,byte[]> c,
SwapContext ctx)
Removes values stored in data space with given name corresponding to specified keys.
|
long |
NoopSwapSpaceSpi.size(String space)
Gets size in bytes for data space with given name.
|
void |
NoopSwapSpaceSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
NoopSwapSpaceSpi.spiStop()
This method is called to stop SPI.
|
void |
NoopSwapSpaceSpi.store(String spaceName,
SwapKey key,
byte[] val,
SwapContext ctx)
Stores value as array of bytes with given key into data space with given name.
|
void |
NoopSwapSpaceSpi.storeAll(String spaceName,
Map<SwapKey,byte[]> pairs,
SwapContext ctx)
Stores key-value pairs (both keys and values are arrays of bytes) into data
space with given name.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015