| Package | Description |
|---|---|
| org.gridgain.grid.kernal.managers.indexing |
Indexing manager classes.
|
| org.gridgain.grid.kernal.processors.cache.query | |
| org.gridgain.grid.spi |
Contains common classes and interfaces for SPI implementations.
|
| org.gridgain.grid.spi.authentication |
Contains APIs for authentication SPI.
|
| org.gridgain.grid.spi.authentication.noop |
Contains default no-op implementation for authentication SPI.
|
| org.gridgain.grid.spi.checkpoint |
Contains APIs for checkpoint SPI.
|
| org.gridgain.grid.spi.checkpoint.cache |
Contains cache-based implementation for checkpoint SPI.
|
| org.gridgain.grid.spi.checkpoint.jdbc |
Contains JDBC implementation for checkpoint SPI.
|
| org.gridgain.grid.spi.checkpoint.noop |
Contains default no-op checkpoint SPI implementation.
|
| org.gridgain.grid.spi.checkpoint.sharedfs |
Contains shared file system implementation for checkpoint SPI.
|
| org.gridgain.grid.spi.collision.fifoqueue |
Contains FIFO based collision SPI implementation.
|
| org.gridgain.grid.spi.collision.jobstealing |
Contains job stealing collision SPI implementation.
|
| org.gridgain.grid.spi.collision.noop |
Contains default no-op collision SPI implementation.
|
| org.gridgain.grid.spi.collision.priorityqueue |
Contains priority based collision SPI implementation.
|
| org.gridgain.grid.spi.communication |
Contains APIs for grid communication SPI.
|
| org.gridgain.grid.spi.communication.tcp |
Contains default TCP/IP-based implementation for communication SPI.
|
| org.gridgain.grid.spi.deployment |
Contains APIs for deployment SPI.
|
| org.gridgain.grid.spi.deployment.local |
Contains default local deployment SPI implementation.
|
| org.gridgain.grid.spi.discovery |
Contains APIs for topology manager SPI.
|
| org.gridgain.grid.spi.discovery.tcp |
Contains default TCP/IP implementation for discovery SPI.
|
| org.gridgain.grid.spi.discovery.tcp.ipfinder |
Contains IP finder interface and adapter.
|
| org.gridgain.grid.spi.discovery.tcp.ipfinder.jdbc |
Contains JDBC IP finder implementation.
|
| org.gridgain.grid.spi.discovery.tcp.ipfinder.multicast |
Contains multicast-based IP finder.
|
| org.gridgain.grid.spi.discovery.tcp.ipfinder.sharedfs |
Contains shared filesystem-based IP finder.
|
| org.gridgain.grid.spi.discovery.tcp.ipfinder.vm |
Contains local JVM-based IP finder.
|
| org.gridgain.grid.spi.discovery.tcp.metricsstore |
Contains metrics store interface.
|
| org.gridgain.grid.spi.discovery.tcp.metricsstore.jdbc |
Contains JDBC implementation of metrics store.
|
| org.gridgain.grid.spi.discovery.tcp.metricsstore.sharedfs |
Contains shared file system based implementation of metrics store.
|
| org.gridgain.grid.spi.discovery.tcp.metricsstore.vm |
Contains local VM metrics store implementation.
|
| org.gridgain.grid.spi.eventstorage |
Contains APIs for event storage SPI.
|
| org.gridgain.grid.spi.eventstorage.memory |
Contains default in-memory implementation for event storage SPI.
|
| org.gridgain.grid.spi.failover.always |
Contains default "always" failover SPI.
|
| org.gridgain.grid.spi.failover.jobstealing |
Contains job stealing failover SPI.
|
| org.gridgain.grid.spi.failover.never |
Contains "never" failover SPI.
|
| org.gridgain.grid.spi.indexing |
Contains APIs for indexing SPI.
|
| org.gridgain.grid.spi.loadbalancing.adaptive |
Contains adaptive load balancing SPI.
|
| org.gridgain.grid.spi.loadbalancing.roundrobin |
Contains default round-robin implementation for load balancing SPI.
|
| org.gridgain.grid.spi.loadbalancing.weightedrandom |
Contains weighted random-base implementation for load balancing SPI.
|
| org.gridgain.grid.spi.securesession |
Contains APIs for secure session SPI.
|
| org.gridgain.grid.spi.securesession.noop |
Contains default no-op implementation for secure session SPI.
|
| org.gridgain.grid.spi.swapspace |
Contains APIs for swap space SPI.
|
| org.gridgain.grid.spi.swapspace.file |
Contains file-based swap space SPI.
|
| org.gridgain.grid.spi.swapspace.noop |
Contains default no-op swap space SPI implementation.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIndexingManager.onSwap(String spi,
String spaceName,
String swapSpaceName,
Object key)
Will be called when entry for key will be swapped.
|
void |
GridIndexingManager.onUnswap(String spi,
String spaceName,
Object key,
Object val,
byte[] valBytes)
Will be called when entry for key will be unswapped.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueryManager.onSwap(String swapSpaceName,
K key)
Entry for given key unswapped.
|
void |
GridCacheQueryManager.onUnswap(K key,
V val,
byte[] valBytes)
Entry for given key unswapped.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridSpiMultiException
Grid SPI exception which may contain more than one failure.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridSpiAdapter.assertParameter(boolean cond,
String condDesc)
Throws exception with uniform error message if given parameter's assertion condition
is
false. |
protected void |
GridSpiAdapter.checkConfigurationConsistency0(GridSpiContext spiCtx,
GridNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
Map<String,Object> |
GridSpi.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
Map<String,Object> |
GridSpiAdapter.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
void |
GridSpi.onContextInitialized(GridSpiContext spiCtx)
Callback invoked when SPI context is initialized.
|
void |
GridSpiAdapter.onContextInitialized(GridSpiContext spiCtx)
Callback invoked when SPI context is initialized.
|
protected void |
GridSpiAdapter.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
protected <T extends GridSpiManagementMBean> |
GridSpiAdapter.registerMBean(String gridName,
T impl,
Class<T> mbeanItf)
Registers SPI MBean.
|
void |
GridSpiContext.send(GridNode node,
Serializable msg,
String topic)
Sends a message to a remote node.
|
void |
GridSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridSpi.spiStop()
This method is called to stop SPI.
|
protected void |
GridSpiAdapter.unregisterMBean()
Unregisters MBean.
|
| Modifier and Type | Method and Description |
|---|---|
GridSecuritySubject |
GridAuthenticationSpi.authenticate(GridAuthenticationContext authCtx)
Authenticates a given subject (either node or remote client).
|
| Modifier and Type | Method and Description |
|---|---|
GridSecuritySubject |
GridNoopAuthenticationSpi.authenticate(GridAuthenticationContext authCtx)
Authenticates a given subject (either node or remote client).
|
void |
GridNoopAuthenticationSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridNoopAuthenticationSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
GridCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridCacheCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
protected void |
GridCacheCheckpointSpi.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
boolean |
GridCacheCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
GridCacheCheckpointSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridCacheCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridJdbcCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
GridJdbcCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
GridJdbcCheckpointSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridJdbcCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridNoopCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
GridNoopCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
GridNoopCheckpointSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridNoopCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridSharedFsCheckpointSpi.loadCheckpoint(String key)
Loads checkpoint from storage by its unique key.
|
boolean |
GridSharedFsCheckpointSpi.saveCheckpoint(String key,
byte[] state,
long timeout,
boolean overwrite)
Saves checkpoint to the storage.
|
void |
GridSharedFsCheckpointSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridSharedFsCheckpointSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridFifoQueueCollisionSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridFifoQueueCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
GridJobStealingCollisionSpi.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
protected void |
GridJobStealingCollisionSpi.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
GridJobStealingCollisionSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridJobStealingCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNoopCollisionSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridNoopCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
GridPriorityQueueCollisionSpi.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
void |
GridPriorityQueueCollisionSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridPriorityQueueCollisionSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCommunicationSpi.sendMessage(GridNode destNode,
T msg)
Sends given message to destination node.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridTcpCommunicationSpi.checkConfigurationConsistency0(GridSpiContext spiCtx,
GridNode node,
boolean starting)
Method which is called in the end of checkConfigurationConsistency() method.
|
Map<String,Object> |
GridTcpCommunicationSpi.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
void |
GridTcpCommunicationSpi.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
GridTcpCommunicationSpi.sendMessage(GridNode node,
GridTcpCommunicationMessageAdapter msg)
Sends given message to destination node.
|
void |
GridTcpCommunicationSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridTcpCommunicationSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridDeploymentSpi.register(ClassLoader ldr,
Class<?> rsrc)
Registers a class loader with this SPI.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
GridLocalDeploymentSpi.register(ClassLoader ldr,
Class<?> rsrc)
Registers a class loader with this SPI.
|
void |
GridLocalDeploymentSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridLocalDeploymentSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridDiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
void |
GridDiscoverySpi.reconnect()
Tells discovery SPI to reconnect to topology.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTcpDiscoverySpi.disconnect()
Tells discovery SPI to disconnect from topology.
|
void |
GridTcpDiscoverySpi.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
GridTcpDiscoverySpi.reconnect()
Tells discovery SPI to reconnect to topology.
|
void |
GridTcpDiscoverySpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridTcpDiscoverySpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
GridTcpDiscoveryIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
GridTcpDiscoveryIpFinder.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
void |
GridTcpDiscoveryIpFinderAdapter.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
void |
GridTcpDiscoveryIpFinder.onSpiContextInitialized(GridSpiContext spiCtx)
Callback invoked when SPI context is initialized after
GridTcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
void |
GridTcpDiscoveryIpFinderAdapter.onSpiContextInitialized(GridSpiContext spiCtx)
Callback invoked when SPI context is initialized after
GridTcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
void |
GridTcpDiscoveryIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
GridTcpDiscoveryIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
GridTcpDiscoveryJdbcIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
GridTcpDiscoveryJdbcIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
GridTcpDiscoveryJdbcIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTcpDiscoveryMulticastIpFinder.initializeLocalAddresses(Collection<InetSocketAddress> addrs)
Initializes addresses discovery SPI binds to.
|
void |
GridTcpDiscoveryMulticastIpFinder.onSpiContextInitialized(GridSpiContext spiCtx)
Callback invoked when SPI context is initialized after
GridTcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
| Modifier and Type | Method and Description |
|---|---|
Collection<InetSocketAddress> |
GridTcpDiscoverySharedFsIpFinder.getRegisteredAddresses()
Gets all addresses registered in this finder.
|
void |
GridTcpDiscoverySharedFsIpFinder.registerAddresses(Collection<InetSocketAddress> addrs)
Registers new addresses.
|
void |
GridTcpDiscoverySharedFsIpFinder.unregisterAddresses(Collection<InetSocketAddress> addrs)
Unregisters provided addresses.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTcpDiscoveryVmIpFinder.setAddresses(Collection<String> addrs)
Parses provided values and initializes the internal collection of addresses.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<UUID> |
GridTcpDiscoveryMetricsStore.allNodeIds()
Gets all node IDs currently contained in the store.
|
Map<UUID,GridNodeMetrics> |
GridTcpDiscoveryMetricsStore.metrics(Collection<UUID> nodeIds)
Gets metrics map for provided nodes.
|
Map<UUID,GridNodeMetrics> |
GridTcpDiscoveryMetricsStoreAdapter.metrics(Collection<UUID> nodeIds)
Gets metrics map for provided nodes.
|
protected abstract Map<UUID,GridNodeMetrics> |
GridTcpDiscoveryMetricsStoreAdapter.metrics0(Collection<UUID> nodeIds)
Requests metrics from store in case local cached metrics are outdated.
|
void |
GridTcpDiscoveryMetricsStore.onSpiContextInitialized(GridSpiContext spiCtx)
Callback invoked when SPI context is initialized after
GridTcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
void |
GridTcpDiscoveryMetricsStoreAdapter.onSpiContextInitialized(GridSpiContext spiCtx)
Callback invoked when SPI context is initialized after
GridTcpDiscoverySpi.spiStart(String)
method is completed, SPI context can be stored for future access. |
void |
GridTcpDiscoveryMetricsStore.removeMetrics(Collection<UUID> nodeIds)
Removes metrics of provided nodes from the store.
|
void |
GridTcpDiscoveryMetricsStoreAdapter.removeMetrics(Collection<UUID> nodeIds)
Removes metrics of provided nodes from the store.
|
protected abstract void |
GridTcpDiscoveryMetricsStoreAdapter.removeMetrics0(Collection<UUID> nodeIds)
Removes metrics from store.
|
void |
GridTcpDiscoveryMetricsStore.updateLocalMetrics(UUID locNodeId,
GridNodeMetrics metrics)
Updates local node metrics in the store.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<UUID> |
GridTcpDiscoveryJdbcMetricsStore.allNodeIds()
Gets all node IDs currently contained in the store.
|
protected Map<UUID,GridNodeMetrics> |
GridTcpDiscoveryJdbcMetricsStore.metrics0(Collection<UUID> nodeIds)
Requests metrics from store in case local cached metrics are outdated.
|
protected void |
GridTcpDiscoveryJdbcMetricsStore.removeMetrics0(Collection<UUID> nodeIds)
Removes metrics from store.
|
void |
GridTcpDiscoveryJdbcMetricsStore.updateLocalMetrics(UUID locNodeId,
GridNodeMetrics metrics)
Updates local node metrics in the store.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<UUID> |
GridTcpDiscoverySharedFsMetricsStore.allNodeIds()
Gets all node IDs currently contained in the store.
|
protected Map<UUID,GridNodeMetrics> |
GridTcpDiscoverySharedFsMetricsStore.metrics0(Collection<UUID> nodeIds)
Requests metrics from store in case local cached metrics are outdated.
|
void |
GridTcpDiscoverySharedFsMetricsStore.removeMetrics0(Collection<UUID> nodeIds)
Removes metrics from store.
|
void |
GridTcpDiscoverySharedFsMetricsStore.updateLocalMetrics(UUID locNodeId,
GridNodeMetrics metrics)
Updates local node metrics in the store.
|
| Modifier and Type | Method and Description |
|---|---|
Collection<UUID> |
GridTcpDiscoveryVmMetricsStore.allNodeIds()
Gets all node IDs currently contained in the store.
|
protected void |
GridTcpDiscoveryVmMetricsStore.removeMetrics0(Collection<UUID> nodeIds)
Removes metrics from store.
|
void |
GridTcpDiscoveryVmMetricsStore.updateLocalMetrics(UUID locNodeId,
GridNodeMetrics metrics)
Updates local node metrics in the store.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridEventStorageSpi.record(GridEvent evt)
Records single event.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridMemoryEventStorageSpi.record(GridEvent evt)
Records single event.
|
void |
GridMemoryEventStorageSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridMemoryEventStorageSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
GridAlwaysFailoverSpi.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
void |
GridAlwaysFailoverSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridAlwaysFailoverSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
GridJobStealingFailoverSpi.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
void |
GridJobStealingFailoverSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridJobStealingFailoverSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNeverFailoverSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridNeverFailoverSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridIndexingMarshaller.marshal(GridIndexingEntity<?> entity)
Marshals object to bytes.
|
<K> void |
GridIndexingSpi.onSwap(String spaceName,
String swapSpaceName,
K key)
Will be called when entry with given key is swapped.
|
<K> void |
GridNoopIndexingSpi.onSwap(String spaceName,
String swapSpaceName,
K key)
Will be called when entry with given key is swapped.
|
<K,V> void |
GridIndexingSpi.onUnswap(String spaceName,
K key,
V val,
byte[] valBytes)
Will be called when entry with given key is unswapped.
|
<K,V> void |
GridNoopIndexingSpi.onUnswap(String spaceName,
K key,
V val,
byte[] valBytes)
Will be called when entry with given key is unswapped.
|
<K,V> GridSpiCloseableIterator<GridIndexingKeyValueRow<K,V>> |
GridIndexingSpi.query(String spaceName,
String qry,
Collection<Object> params,
GridIndexingTypeDescriptor type,
GridIndexingQueryFilter<K,V>... filters)
Executes regular query.
|
<K,V> GridSpiCloseableIterator<GridIndexingKeyValueRow<K,V>> |
GridNoopIndexingSpi.query(String spaceName,
String qry,
Collection<Object> params,
GridIndexingTypeDescriptor type,
GridIndexingQueryFilter<K,V>... filters)
Executes regular query.
|
<K,V> GridIndexingFieldsResult |
GridIndexingSpi.queryFields(String spaceName,
String qry,
Collection<Object> params,
GridIndexingQueryFilter<K,V>... filters)
Queries individual fields (generally used by JDBC drivers).
|
<K,V> GridIndexingFieldsResult |
GridNoopIndexingSpi.queryFields(String spaceName,
String qry,
Collection<Object> params,
GridIndexingQueryFilter<K,V>... filters)
Queries individual fields (generally used by JDBC drivers).
|
<K,V> GridSpiCloseableIterator<GridIndexingKeyValueRow<K,V>> |
GridIndexingSpi.queryText(String spaceName,
String qry,
GridIndexingTypeDescriptor type,
GridIndexingQueryFilter<K,V>... filters)
Executes text query.
|
<K,V> GridSpiCloseableIterator<GridIndexingKeyValueRow<K,V>> |
GridNoopIndexingSpi.queryText(String spaceName,
String qry,
GridIndexingTypeDescriptor type,
GridIndexingQueryFilter<K,V>... filters)
Executes text query.
|
void |
GridIndexingSpi.registerSpace(String spaceName)
Registers space in this SPI.
|
void |
GridNoopIndexingSpi.registerSpace(String spaceName)
Registers space in this SPI.
|
boolean |
GridIndexingSpi.registerType(String spaceName,
GridIndexingTypeDescriptor desc)
Registers type if it was not known before or updates it otherwise.
|
boolean |
GridNoopIndexingSpi.registerType(String spaceName,
GridIndexingTypeDescriptor desc)
Registers type if it was not known before or updates it otherwise.
|
<K> boolean |
GridIndexingSpi.remove(String spaceName,
GridIndexingEntity<K> key)
Removes index entry by key.
|
<K> boolean |
GridNoopIndexingSpi.remove(String spaceName,
GridIndexingEntity<K> key)
Removes index entry by key.
|
long |
GridIndexingSpi.size(String spaceName,
GridIndexingTypeDescriptor desc)
Gets size of index for given type or -1 if it is a unknown type.
|
long |
GridNoopIndexingSpi.size(String spaceName,
GridIndexingTypeDescriptor desc)
Gets size of index for given type or -1 if it is a unknown type.
|
void |
GridNoopIndexingSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridNoopIndexingSpi.spiStop()
This method is called to stop SPI.
|
<K,V> void |
GridIndexingSpi.store(String spaceName,
GridIndexingTypeDescriptor type,
GridIndexingEntity<K> key,
GridIndexingEntity<V> val,
byte[] ver,
long expirationTime)
Updates index.
|
<K,V> void |
GridNoopIndexingSpi.store(String spaceName,
GridIndexingTypeDescriptor type,
GridIndexingEntity<K> key,
GridIndexingEntity<V> val,
byte[] ver,
long expirationTime)
Updates index.
|
<T> GridIndexingEntity<T> |
GridIndexingMarshaller.unmarshal(byte[] bytes)
Unmarshalls bytes to object.
|
void |
GridIndexingSpi.unregisterType(String spaceName,
GridIndexingTypeDescriptor type)
Unregisters type and removes all corresponding data.
|
void |
GridNoopIndexingSpi.unregisterType(String spaceName,
GridIndexingTypeDescriptor type)
Unregisters type and removes all corresponding data.
|
T |
GridIndexingEntity.value()
Gets indexed value.
|
<T> T |
GridIndexingTypeDescriptor.value(Object obj,
String field)
Gets field value for given object.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridAdaptiveLoadBalancingSpi.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
GridAdaptiveLoadBalancingSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridAdaptiveLoadBalancingSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
GridRoundRobinLoadBalancingSpi.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
GridRoundRobinLoadBalancingSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridRoundRobinLoadBalancingSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
Map<String,Object> |
GridWeightedRandomLoadBalancingSpi.getNodeAttributes()
This method is called before SPI starts (before method
GridSpi.spiStart(String)
is called). |
protected void |
GridWeightedRandomLoadBalancingSpi.onContextInitialized0(GridSpiContext spiCtx)
Method to be called in the end of onContextInitialized method.
|
void |
GridWeightedRandomLoadBalancingSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridWeightedRandomLoadBalancingSpi.spiStop()
This method is called to stop SPI.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridSecureSessionSpi.generateSessionToken(GridSecuritySubjectType subjType,
UUID subjId,
Object params)
Generates new session token.
|
boolean |
GridSecureSessionSpi.validate(GridSecuritySubjectType subjType,
UUID subjId,
byte[] tok,
Object params)
Validates given session token.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNoopSecureSessionSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridNoopSecureSessionSpi.spiStop()
This method is called to stop SPI.
|
boolean |
GridNoopSecureSessionSpi.validate(GridSecuritySubjectType subjType,
UUID subjId,
byte[] tok,
Object params)
Validates given session token.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridSwapSpaceSpi.clear(String spaceName)
Entirely clears data space with given name, if any.
|
long |
GridSwapSpaceSpi.count(String spaceName)
Gets number of stored entries (keys) in data space with given name.
|
<K> GridSpiCloseableIterator<K> |
GridSwapSpaceSpi.keyIterator(String spaceName,
GridSwapContext ctx)
Gets iterator over space keys.
|
Collection<Integer> |
GridSwapSpaceSpi.partitions(String spaceName)
Gets partitions IDs that are stored in the passed in space.
|
GridSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
GridSwapSpaceSpi.rawIterator(String spaceName)
Gets raw iterator over space entries.
|
GridSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
GridSwapSpaceSpi.rawIterator(String spaceName,
int part)
Gets raw iterator over space entries.
|
byte[] |
GridSwapSpaceSpi.read(String spaceName,
GridSwapKey key,
GridSwapContext ctx)
Reads stored value as array of bytes by key from data space with given name.
|
Map<GridSwapKey,byte[]> |
GridSwapSpaceSpi.readAll(String spaceName,
Iterable<GridSwapKey> keys,
GridSwapContext ctx)
Reads stored values as array of bytes by all passed keys from data space with
given name.
|
void |
GridSwapSpaceSpi.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
GridSwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
void |
GridSwapSpaceSpi.removeAll(String spaceName,
Collection<GridSwapKey> keys,
GridBiInClosure<GridSwapKey,byte[]> c,
GridSwapContext ctx)
Removes values stored in data space with given name corresponding to specified keys.
|
long |
GridSwapSpaceSpi.size(String spaceName)
Gets size in bytes for data space with given name.
|
void |
GridSwapSpaceSpi.store(String spaceName,
GridSwapKey key,
byte[] val,
GridSwapContext ctx)
Stores value as array of bytes with given key into data space with given name.
|
void |
GridSwapSpaceSpi.storeAll(String spaceName,
Map<GridSwapKey,byte[]> pairs,
GridSwapContext 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 |
GridFileSwapSpaceSpi.clear(String spaceName)
Entirely clears data space with given name, if any.
|
long |
GridFileSwapSpaceSpi.count(String spaceName)
Gets number of stored entries (keys) in data space with given name.
|
<K> GridSpiCloseableIterator<K> |
GridFileSwapSpaceSpi.keyIterator(String spaceName,
GridSwapContext ctx)
Gets iterator over space keys.
|
Collection<Integer> |
GridFileSwapSpaceSpi.partitions(String spaceName)
Gets partitions IDs that are stored in the passed in space.
|
GridSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
GridFileSwapSpaceSpi.rawIterator(String spaceName)
Gets raw iterator over space entries.
|
GridSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
GridFileSwapSpaceSpi.rawIterator(String spaceName,
int part)
Gets raw iterator over space entries.
|
byte[] |
GridFileSwapSpaceSpi.read(String spaceName,
GridSwapKey key,
GridSwapContext ctx)
Reads stored value as array of bytes by key from data space with given name.
|
Map<GridSwapKey,byte[]> |
GridFileSwapSpaceSpi.readAll(String spaceName,
Iterable<GridSwapKey> keys,
GridSwapContext ctx)
Reads stored values as array of bytes by all passed keys from data space with
given name.
|
void |
GridFileSwapSpaceSpi.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
GridSwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
void |
GridFileSwapSpaceSpi.removeAll(String spaceName,
Collection<GridSwapKey> keys,
GridBiInClosure<GridSwapKey,byte[]> c,
GridSwapContext ctx)
Removes values stored in data space with given name corresponding to specified keys.
|
long |
GridFileSwapSpaceSpi.size(String spaceName)
Gets size in bytes for data space with given name.
|
void |
GridFileSwapSpaceSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridFileSwapSpaceSpi.spiStop()
This method is called to stop SPI.
|
void |
GridFileSwapSpaceSpi.store(String spaceName,
GridSwapKey key,
byte[] val,
GridSwapContext ctx)
Stores value as array of bytes with given key into data space with given name.
|
void |
GridFileSwapSpaceSpi.storeAll(String spaceName,
Map<GridSwapKey,byte[]> pairs,
GridSwapContext 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 |
GridNoopSwapSpaceSpi.clear(String space)
Entirely clears data space with given name, if any.
|
long |
GridNoopSwapSpaceSpi.count(String space)
Gets number of stored entries (keys) in data space with given name.
|
<K> GridSpiCloseableIterator<K> |
GridNoopSwapSpaceSpi.keyIterator(String spaceName,
GridSwapContext ctx)
Gets iterator over space keys.
|
Collection<Integer> |
GridNoopSwapSpaceSpi.partitions(String spaceName)
Gets partitions IDs that are stored in the passed in space.
|
GridSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
GridNoopSwapSpaceSpi.rawIterator(String spaceName)
Gets raw iterator over space entries.
|
GridSpiCloseableIterator<Map.Entry<byte[],byte[]>> |
GridNoopSwapSpaceSpi.rawIterator(String spaceName,
int part)
Gets raw iterator over space entries.
|
byte[] |
GridNoopSwapSpaceSpi.read(String spaceName,
GridSwapKey key,
GridSwapContext ctx)
Reads stored value as array of bytes by key from data space with given name.
|
Map<GridSwapKey,byte[]> |
GridNoopSwapSpaceSpi.readAll(String spaceName,
Iterable<GridSwapKey> keys,
GridSwapContext ctx)
Reads stored values as array of bytes by all passed keys from data space with
given name.
|
void |
GridNoopSwapSpaceSpi.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
GridSwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
void |
GridNoopSwapSpaceSpi.removeAll(String spaceName,
Collection<GridSwapKey> keys,
GridBiInClosure<GridSwapKey,byte[]> c,
GridSwapContext ctx)
Removes values stored in data space with given name corresponding to specified keys.
|
long |
GridNoopSwapSpaceSpi.size(String space)
Gets size in bytes for data space with given name.
|
void |
GridNoopSwapSpaceSpi.spiStart(String gridName)
This method is called to start SPI.
|
void |
GridNoopSwapSpaceSpi.spiStop()
This method is called to stop SPI.
|
void |
GridNoopSwapSpaceSpi.store(String spaceName,
GridSwapKey key,
byte[] val,
GridSwapContext ctx)
Stores value as array of bytes with given key into data space with given name.
|
void |
GridNoopSwapSpaceSpi.storeAll(String spaceName,
Map<GridSwapKey,byte[]> pairs,
GridSwapContext ctx)
Stores key-value pairs (both keys and values are arrays of bytes) into data
space with given name.
|
Copyright © 2014. All rights reserved.