Interface Ignite
- 
- All Superinterfaces:
- AutoCloseable
 - All Known Implementing Classes:
- IgniteSpringBean
 
 public interface Ignite extends AutoCloseable Main entry-point for all Ignite APIs. You can obtain an instance ofIgnitethroughIgnition.ignite(), or for named grids you can useIgnition.ignite(String). Note that you can have multiple instances ofIgniterunning in the same VM by giving each instance a different name.Ignite provides the following functionality: - IgniteCluster- clustering functionality.
- IgniteCache- functionality for in-memory distributed cache, including SQL, TEXT, and Predicate-based queries.
- IgniteTransactions- distributed ACID-compliant transactions.
- IgniteDataStreamer- functionality for streaming large amounts of data into cache.
- IgniteCompute- functionality for executing tasks and closures on all grid nodes (inherited form- ClusterGroup).
- IgniteServices- distributed service grid functionality (e.g. singletons on the cluster).
- IgniteMessaging- functionality for topic-based message exchange on all grid nodes (inherited form- ClusterGroup).
- IgniteEvents- functionality for querying and listening to events on all grid nodes (inherited form- ClusterGroup).
- ExecutorService- distributed thread pools.
- IgniteAtomicLong- distributed atomic long.
- IgniteAtomicReference- distributed atomic reference.
- IgniteAtomicSequence- distributed atomic sequence.
- IgniteAtomicStamped- distributed atomic stamped reference.
- IgniteCountDownLatch- distributed count down latch.
- IgniteQueue- distributed blocking queue.
- IgniteSet- distributed concurrent set.
- IgniteScheduler- functionality for scheduling jobs using UNIX Cron syntax.
 
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description booleanactive()Deprecated.UseIgniteCluster.state()instead.voidactive(boolean active)Deprecated.UseIgniteCluster.state(ClusterState)instead.<K,V>
 voidaddCacheConfiguration(CacheConfiguration<K,V> cacheCfg)Adds cache configuration template.<K> Affinity<K>affinity(String cacheName)Gets affinity service to provide information about data partitioning and distribution.IgniteAtomicLongatomicLong(String name, long initVal, boolean create)Will get a atomic long from cache and create one if it has not been created yet andcreateflag istrue.IgniteAtomicLongatomicLong(String name, AtomicConfiguration cfg, long initVal, boolean create)Will get a atomic long from cache and create one if it has not been created yet andcreateflag istrue.<T> IgniteAtomicReference<T>atomicReference(String name, AtomicConfiguration cfg, T initVal, boolean create)Will get a atomic reference from cache and create one if it has not been created yet andcreateflag istrue.<T> IgniteAtomicReference<T>atomicReference(String name, T initVal, boolean create)Will get a atomic reference from cache and create one if it has not been created yet andcreateflag istrue.IgniteAtomicSequenceatomicSequence(String name, long initVal, boolean create)Will get an atomic sequence from cache and create one if it has not been created yet andcreateflag istrue.IgniteAtomicSequenceatomicSequence(String name, AtomicConfiguration cfg, long initVal, boolean create)Will get an atomic sequence from cache and create one if it has not been created yet andcreateflag istrue.<T,S>
 IgniteAtomicStamped<T,S>atomicStamped(String name, AtomicConfiguration cfg, T initVal, S initStamp, boolean create)Will get a atomic stamped from cache and create one if it has not been created yet andcreateflag istrue.<T,S>
 IgniteAtomicStamped<T,S>atomicStamped(String name, T initVal, S initStamp, boolean create)Will get a atomic stamped from cache and create one if it has not been created yet andcreateflag istrue.IgniteBinarybinary()Gets an instance ofIgniteBinaryinterface.<K,V>
 IgniteCache<K,V>cache(String name)Gets an instance ofIgniteCacheAPI for the given name if one is configured ornullotherwise.Collection<String>cacheNames()Gets the collection of names of currently available caches.voidclose()Closesthisinstance of grid.IgniteClustercluster()Gets an instance ofIgniteClusterinterface.IgniteComputecompute()Getscomputefacade over all cluster nodes started in server mode.IgniteComputecompute(ClusterGroup grp)Getscomputefacade over the specified cluster group.IgniteConfigurationconfiguration()Gets the configuration of this Ignite instance.IgniteCountDownLatchcountDownLatch(String name, int cnt, boolean autoDel, boolean create)Gets or creates count down latch.<K,V>
 IgniteCache<K,V>createCache(String cacheName)Dynamically starts new cache using template configuration.<K,V>
 IgniteCache<K,V>createCache(CacheConfiguration<K,V> cacheCfg)Dynamically starts new cache with the given cache configuration.<K,V>
 IgniteCache<K,V>createCache(CacheConfiguration<K,V> cacheCfg, NearCacheConfiguration<K,V> nearCfg)Dynamically starts new cache with the given cache configuration.Collection<IgniteCache>createCaches(Collection<CacheConfiguration> cacheCfgs)Dynamically starts new caches with the given cache configurations.<K,V>
 IgniteCache<K,V>createNearCache(String cacheName, NearCacheConfiguration<K,V> nearCfg)Starts a near cache on local node if cache was previously started with one of thecreateCache(CacheConfiguration)orcreateCache(CacheConfiguration, NearCacheConfiguration)methods.Collection<DataRegionMetrics>dataRegionMetrics()Deprecated.Check theReadOnlyMetricRegistrywith "name=io.dataregion.@Nullable DataRegionMetricsdataRegionMetrics(String memPlcName)Returns the latestDataRegionMetricssnapshot for the memory region of the given name.<K,V>
 IgniteDataStreamer<K,V>dataStreamer(String cacheName)Gets a new instance of data streamer associated with given cache name.voiddestroyCache(String cacheName)Destroys a cache with the given name and cleans data that was written to the cache.voiddestroyCaches(Collection<String> cacheNames)Destroys caches with the given names and cleans data that was written to the caches.IgniteEncryptionencryption()Gets an instance ofIgniteEncryptioninterface.IgniteEventsevents()Getseventsfacade over all cluster nodes.IgniteEventsevents(ClusterGroup grp)Getseventsfacade over nodes within the cluster group.ExecutorServiceexecutorService()Creates a newExecutorServicewhich will execute all submittedCallableandRunnablejobs on all cluster nodes.ExecutorServiceexecutorService(ClusterGroup grp)Creates a newExecutorServicewhich will execute all submittedCallableandRunnablejobs on nodes in the specified cluster group.<K,V>
 IgniteCache<K,V>getOrCreateCache(String cacheName)Gets existing cache with the given name or creates new one using template configuration.<K,V>
 IgniteCache<K,V>getOrCreateCache(CacheConfiguration<K,V> cacheCfg)Gets existing cache with the given name or creates new one with the given configuration.<K,V>
 IgniteCache<K,V>getOrCreateCache(CacheConfiguration<K,V> cacheCfg, NearCacheConfiguration<K,V> nearCfg)Gets existing cache with the given cache configuration or creates one if it does not exist.Collection<IgniteCache>getOrCreateCaches(Collection<CacheConfiguration> cacheCfgs)Gets existing caches with the given name or created one with the given configuration.<K,V>
 IgniteCache<K,V>getOrCreateNearCache(String cacheName, NearCacheConfiguration<K,V> nearCfg)Gets existing near cache with the given name or creates a new one.IgniteLoggerlog()Gets grid's logger.Collection<MemoryMetrics>memoryMetrics()Deprecated.Check theReadOnlyMetricRegistrywith "name=io.dataregion.@Nullable MemoryMetricsmemoryMetrics(String dataRegionName)Deprecated.Check theReadOnlyMetricRegistrywith "name=io.dataregion.IgniteMessagingmessage()Getsmessagingfacade over all cluster nodes.IgniteMessagingmessage(ClusterGroup grp)Getsmessagingfacade over nodes within the cluster group.IgniteMetricsmetrics()Gets custom metrics facade over current node.Stringname()Gets the name of the Ignite instance.<T extends IgnitePlugin>
 Tplugin(String name)Gets an instance of deployed Ignite plugin.<T> IgniteQueue<T>queue(String name, int cap, @Nullable CollectionConfiguration cfg)Will get a named queue from cache and create one if it has not been created yet andcfgis notnull.IgniteLockreentrantLock(String name, boolean failoverSafe, boolean fair, boolean create)Gets or creates reentrant lock.voidresetLostPartitions(Collection<String> cacheNames)Clears partition's lost state and moves caches to a normal mode.IgniteSchedulerscheduler()Gets an instance of cron-based scheduler.IgniteSemaphoresemaphore(String name, int cnt, boolean failoverSafe, boolean create)Gets or creates semaphore.IgniteServicesservices()Getsservicesfacade over all cluster nodes started in server mode.IgniteServicesservices(ClusterGroup grp)Getsservicesfacade over nodes within the cluster group.<T> IgniteSet<T>set(String name, @Nullable CollectionConfiguration cfg)Will get a named set from cache and create one if it has not been created yet andcfgis notnull.IgniteSnapshotsnapshot()@NotNull TracingConfigurationManagertracingConfiguration()Returns theTracingConfigurationManagerinstance that allows to Configure tracing parameters such as sampling rate for the specific tracing coordinates such as scope and label. Retrieve the most specific tracing parameters for the specified tracing coordinates (scope and label) Restore the tracing parameters for the specified tracing coordinates to the default. List all pairs of tracing configuration coordinates and tracing configuration parameters.IgniteTransactionstransactions()Gets grid transactions facade.IgniteProductVersionversion()Gets Ignite version.
 
- 
- 
- 
Method Detail- 
nameString name() Gets the name of the Ignite instance. The name allows having multiple Ignite instances with different names within the same Java VM.If default Ignite instance is used, then nullis returned. Refer toIgnitiondocumentation for information on how to start named ignite Instances.- Returns:
- Name of the Ignite instance, or nullfor default Ignite instance.
 
 - 
logIgniteLogger log() Gets grid's logger.- Returns:
- Grid's logger.
 
 - 
configurationIgniteConfiguration configuration() Gets the configuration of this Ignite instance.NOTE: 
 SPIs obtains through this method should never be used directly. SPIs provide internal view on the subsystem and is used internally by Ignite kernal. In rare use cases when access to a specific implementation of this SPI is required - an instance of this SPI can be obtained via this method to check its configuration properties or call other non-SPI methods.- Returns:
- Ignite configuration instance.
 
 - 
clusterIgniteCluster cluster() Gets an instance ofIgniteClusterinterface.- Returns:
- Instance of IgniteClusterinterface.
 
 - 
computeIgniteCompute compute() Getscomputefacade over all cluster nodes started in server mode.- Returns:
- Compute instance over all cluster nodes started in server mode.
 
 - 
metricsIgniteMetrics metrics() Gets custom metrics facade over current node.- Returns:
- IgniteMetricsinstance for current node.
 
 - 
computeIgniteCompute compute(ClusterGroup grp) Getscomputefacade over the specified cluster group. All operations on the returnedIgniteComputeinstance will only include nodes from this cluster group.- Parameters:
- grp- Cluster group.
- Returns:
- Compute instance over given cluster group.
 
 - 
messageIgniteMessaging message() Getsmessagingfacade over all cluster nodes.- Returns:
- Messaging instance over all cluster nodes.
 
 - 
messageIgniteMessaging message(ClusterGroup grp) Getsmessagingfacade over nodes within the cluster group. All operations on the returnedIgniteMessaginginstance will only include nodes from the specified cluster group.- Parameters:
- grp- Cluster group.
- Returns:
- Messaging instance over given cluster group.
 
 - 
eventsIgniteEvents events() Getseventsfacade over all cluster nodes.- Returns:
- Events instance over all cluster nodes.
 
 - 
eventsIgniteEvents events(ClusterGroup grp) Getseventsfacade over nodes within the cluster group. All operations on the returnedIgniteEventsinstance will only include nodes from the specified cluster group.- Parameters:
- grp- Cluster group.
- Returns:
- Events instance over given cluster group.
 
 - 
servicesIgniteServices services() Getsservicesfacade over all cluster nodes started in server mode.- Returns:
- Services facade over all cluster nodes started in server mode.
 
 - 
servicesIgniteServices services(ClusterGroup grp) Getsservicesfacade over nodes within the cluster group. All operations on the returnedIgniteMessaginginstance will only include nodes from the specified cluster group.- Parameters:
- grp- Cluster group.
- Returns:
- Servicesfunctionality over given cluster group.
 
 - 
executorServiceExecutorService executorService() Creates a newExecutorServicewhich will execute all submittedCallableandRunnablejobs on all cluster nodes. This essentially creates a Distributed Thread Pool that can be used as a replacement for local thread pools.- Returns:
- Grid-enabled ExecutorService.
 
 - 
executorServiceExecutorService executorService(ClusterGroup grp) Creates a newExecutorServicewhich will execute all submittedCallableandRunnablejobs on nodes in the specified cluster group. This essentially creates a Distributed Thread Pool that can be used as a replacement for local thread pools.- Parameters:
- grp- Cluster group.
- Returns:
- ExecutorServicewhich will execute jobs on nodes in given cluster group.
 
 - 
versionIgniteProductVersion version() Gets Ignite version.- Returns:
- Ignite version.
 
 - 
schedulerIgniteScheduler scheduler() Gets an instance of cron-based scheduler.- Returns:
- Instance of scheduler.
 
 - 
createCache<K,V> IgniteCache<K,V> createCache(CacheConfiguration<K,V> cacheCfg) throws javax.cache.CacheException Dynamically starts new cache with the given cache configuration.If local node is an affinity node, this method will return the instance of started cache. Otherwise, it will create a client cache on local node. If a cache with the same name already exists in the grid, an exception will be thrown regardless whether the given configuration matches the configuration of the existing cache or not. - Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheCfg- Cache configuration to use.
- Returns:
- Instance of started cache.
- Throws:
- javax.cache.CacheException- If a cache with the same name already exists or other error occurs.
 
 - 
createCachesCollection<IgniteCache> createCaches(Collection<CacheConfiguration> cacheCfgs) throws javax.cache.CacheException Dynamically starts new caches with the given cache configurations.If local node is an affinity node, this method will return the instance of started caches. Otherwise, it will create a client caches on local node. If for one of configurations a cache with the same name already exists in the grid, an exception will be thrown regardless whether the given configuration matches the configuration of the existing cache or not. - Parameters:
- cacheCfgs- Collection of cache configuration to use.
- Returns:
- Collection of instances of started caches.
- Throws:
- javax.cache.CacheException- If one of created caches exists or other error occurs.
 
 - 
createCache<K,V> IgniteCache<K,V> createCache(String cacheName) throws javax.cache.CacheException Dynamically starts new cache using template configuration.If local node is an affinity node, this method will return the instance of started cache. Otherwise, it will create a client cache on local node. If a cache with the same name already exists in the grid, an exception will be thrown. - Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheName- Cache name.
- Returns:
- Instance of started cache.
- Throws:
- javax.cache.CacheException- If a cache with the same name already exists or other error occurs.
 
 - 
getOrCreateCache<K,V> IgniteCache<K,V> getOrCreateCache(CacheConfiguration<K,V> cacheCfg) throws javax.cache.CacheException Gets existing cache with the given name or creates new one with the given configuration.If a cache with the same name already exist, this method will not check that the given configuration matches the configuration of existing cache and will return an instance of the existing cache. - Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheCfg- Cache configuration to use.
- Returns:
- Existing or newly created cache.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
getOrCreateCache<K,V> IgniteCache<K,V> getOrCreateCache(String cacheName) throws javax.cache.CacheException Gets existing cache with the given name or creates new one using template configuration.- Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheName- Cache name.
- Returns:
- Existing or newly created cache.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
getOrCreateCachesCollection<IgniteCache> getOrCreateCaches(Collection<CacheConfiguration> cacheCfgs) throws javax.cache.CacheException Gets existing caches with the given name or created one with the given configuration.If a cache with the same name already exist, this method will not check that the given configuration matches the configuration of existing cache and will return an instance of the existing cache. - Parameters:
- cacheCfgs- Collection of cache configuration to use.
- Returns:
- Collection of existing or newly created caches.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
addCacheConfiguration<K,V> void addCacheConfiguration(CacheConfiguration<K,V> cacheCfg) throws javax.cache.CacheException Adds cache configuration template.- Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheCfg- Cache configuration template.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
createCache<K,V> IgniteCache<K,V> createCache(CacheConfiguration<K,V> cacheCfg, NearCacheConfiguration<K,V> nearCfg) throws javax.cache.CacheException Dynamically starts new cache with the given cache configuration.If local node is an affinity node, this method will return the instance of started cache. Otherwise, it will create a near cache with the given configuration on local node. If a cache with the same name already exists in the grid, an exception will be thrown regardless whether the given configuration matches the configuration of the existing cache or not. - Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheCfg- Cache configuration to use.
- nearCfg- Near cache configuration to use on local node in case it is not an affinity node.
- Returns:
- Instance of started cache.
- Throws:
- javax.cache.CacheException- If a cache with the same name already exists or other error occurs.
 
 - 
getOrCreateCache<K,V> IgniteCache<K,V> getOrCreateCache(CacheConfiguration<K,V> cacheCfg, NearCacheConfiguration<K,V> nearCfg) throws javax.cache.CacheException Gets existing cache with the given cache configuration or creates one if it does not exist.If a cache with the same name already exist, this method will not check that the given configuration matches the configuration of existing cache and will return an instance of the existing cache. If local node is not an affinity node and a client cache without near cache has been already started on this node, an exception will be thrown. - Type Parameters:
- K- type.
- V- type.
- Parameters:
- cacheCfg- Cache configuration.
- nearCfg- Near cache configuration for client.
- Returns:
- IgniteCacheinstance.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
createNearCache<K,V> IgniteCache<K,V> createNearCache(String cacheName, NearCacheConfiguration<K,V> nearCfg) throws javax.cache.CacheException Starts a near cache on local node if cache was previously started with one of thecreateCache(CacheConfiguration)orcreateCache(CacheConfiguration, NearCacheConfiguration)methods.- Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheName- Cache name.
- nearCfg- Near cache configuration.
- Returns:
- Cache instance.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
getOrCreateNearCache<K,V> IgniteCache<K,V> getOrCreateNearCache(String cacheName, NearCacheConfiguration<K,V> nearCfg) throws javax.cache.CacheException Gets existing near cache with the given name or creates a new one.- Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheName- Cache name.
- nearCfg- Near configuration.
- Returns:
- IgniteCacheinstance.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
destroyCachevoid destroyCache(String cacheName) throws javax.cache.CacheException Destroys a cache with the given name and cleans data that was written to the cache. The call will deallocate all resources associated with the given cache on all nodes in the cluster. There is no way to undo the action and recover destroyed data.All existing instances of IgniteCachewill be invalidated, subsequent calls to the API will throw exceptions.If a cache with the specified name does not exist in the grid, the operation has no effect. - Parameters:
- cacheName- Cache name to destroy.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
destroyCachesvoid destroyCaches(Collection<String> cacheNames) throws javax.cache.CacheException Destroys caches with the given names and cleans data that was written to the caches. The call will deallocate all resources associated with the given caches on all nodes in the cluster. There is no way to undo the action and recover destroyed data.All existing instances of IgniteCachewill be invalidated, subsequent calls to the API will throw exceptions.If the specified collection contains nullor an empty value, this method will throwIllegalArgumentExceptionand the caches will not be destroyed.If a cache with the specified name does not exist in the grid, the specified value will be skipped. - Parameters:
- cacheNames- Collection of cache names to destroy.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
cache<K,V> IgniteCache<K,V> cache(String name) throws javax.cache.CacheException Gets an instance ofIgniteCacheAPI for the given name if one is configured ornullotherwise.IgniteCacheis a fully-compatible implementation ofJCache (JSR 107)specification.- Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- name- Cache name.
- Returns:
- Instance of the cache for the specified name or nullif one does not exist.
- Throws:
- javax.cache.CacheException- If error occurs.
 
 - 
cacheNamesCollection<String> cacheNames() Gets the collection of names of currently available caches.- Returns:
- Collection of names of currently available caches or an empty collection if no caches are available.
 
 - 
transactionsIgniteTransactions transactions() Gets grid transactions facade.- Returns:
- Grid transactions facade.
 
 - 
dataStreamer<K,V> IgniteDataStreamer<K,V> dataStreamer(String cacheName) throws IllegalStateException Gets a new instance of data streamer associated with given cache name. Data streamer is responsible for loading external data into in-memory data grid. For more information refer toIgniteDataStreamerdocumentation.- Type Parameters:
- K- Type of the cache key.
- V- Type of the cache value.
- Parameters:
- cacheName- Cache name.
- Returns:
- Data streamer.
- Throws:
- IllegalStateException- If node is stopping.
 
 - 
atomicSequenceIgniteAtomicSequence atomicSequence(String name, long initVal, boolean create) throws IgniteException Will get an atomic sequence from cache and create one if it has not been created yet andcreateflag istrue. It will use configuration fromIgniteConfiguration.getAtomicConfiguration().- Parameters:
- name- Sequence name.
- initVal- Initial value for sequence. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Sequence for the given name.
- Throws:
- IgniteException- If sequence could not be fetched or created.
 
 - 
atomicSequenceIgniteAtomicSequence atomicSequence(String name, AtomicConfiguration cfg, long initVal, boolean create) throws IgniteException Will get an atomic sequence from cache and create one if it has not been created yet andcreateflag istrue.- Parameters:
- name- Sequence name.
- cfg- Configuration.
- initVal- Initial value for sequence. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Sequence for the given name.
- Throws:
- IgniteException- If sequence could not be fetched or created.
 
 - 
atomicLongIgniteAtomicLong atomicLong(String name, long initVal, boolean create) throws IgniteException Will get a atomic long from cache and create one if it has not been created yet andcreateflag istrue.- Parameters:
- name- Name of atomic long.
- initVal- Initial value for atomic long. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Atomic long.
- Throws:
- IgniteException- If atomic long could not be fetched or created.
 
 - 
atomicLongIgniteAtomicLong atomicLong(String name, AtomicConfiguration cfg, long initVal, boolean create) throws IgniteException Will get a atomic long from cache and create one if it has not been created yet andcreateflag istrue.- Parameters:
- name- Name of atomic long.
- cfg- Configuration.
- initVal- Initial value for atomic long. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Atomic long.
- Throws:
- IgniteException- If atomic long could not be fetched or created.
 
 - 
atomicReference<T> IgniteAtomicReference<T> atomicReference(String name, @Nullable T initVal, boolean create) throws IgniteException Will get a atomic reference from cache and create one if it has not been created yet andcreateflag istrue. It will use configuration fromIgniteConfiguration.getAtomicConfiguration().- Type Parameters:
- T- Type of object referred to by this reference.
- Parameters:
- name- Atomic reference name.
- initVal- Initial value for atomic reference. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Atomic reference for the given name.
- Throws:
- IgniteException- If atomic reference could not be fetched or created.
 
 - 
atomicReference<T> IgniteAtomicReference<T> atomicReference(String name, AtomicConfiguration cfg, @Nullable T initVal, boolean create) throws IgniteException Will get a atomic reference from cache and create one if it has not been created yet andcreateflag istrue.- Type Parameters:
- T- Type of object referred to by this reference.
- Parameters:
- name- Atomic reference name.
- cfg- Configuration.
- initVal- Initial value for atomic reference. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Atomic reference for the given name.
- Throws:
- IgniteException- If atomic reference could not be fetched or created.
 
 - 
atomicStamped<T,S> IgniteAtomicStamped<T,S> atomicStamped(String name, @Nullable T initVal, @Nullable S initStamp, boolean create) throws IgniteException Will get a atomic stamped from cache and create one if it has not been created yet andcreateflag istrue.- Type Parameters:
- T- Type of object referred to by this atomic.
- S- Type of stamp object.
- Parameters:
- name- Atomic stamped name.
- initVal- Initial value for atomic stamped. Ignored if- createflag is- false.
- initStamp- Initial stamp for atomic stamped. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Atomic stamped for the given name.
- Throws:
- IgniteException- If atomic stamped could not be fetched or created.
 
 - 
atomicStamped<T,S> IgniteAtomicStamped<T,S> atomicStamped(String name, AtomicConfiguration cfg, @Nullable T initVal, @Nullable S initStamp, boolean create) throws IgniteException Will get a atomic stamped from cache and create one if it has not been created yet andcreateflag istrue.- Type Parameters:
- T- Type of object referred to by this atomic.
- S- Type of stamp object.
- Parameters:
- name- Atomic stamped name.
- cfg- Configuration.
- initVal- Initial value for atomic stamped. Ignored if- createflag is- false.
- initStamp- Initial stamp for atomic stamped. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Atomic stamped for the given name.
- Throws:
- IgniteException- If atomic stamped could not be fetched or created.
 
 - 
countDownLatchIgniteCountDownLatch countDownLatch(String name, int cnt, boolean autoDel, boolean create) throws IgniteException Gets or creates count down latch. If count down latch is not found in cache andcreateflag istrue, it is created using provided name and count parameter.- Parameters:
- name- Name of the latch.
- cnt- Count for new latch creation. Ignored if- createflag is- false.
- autoDel-- Trueto automatically delete latch from cache when its count reaches zero. Ignored if- createflag is- false.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Count down latch for the given name.
- Throws:
- IgniteException- If latch could not be fetched or created.
 
 - 
semaphoreIgniteSemaphore semaphore(String name, int cnt, boolean failoverSafe, boolean create) throws IgniteException Gets or creates semaphore. If semaphore is not found in cache andcreateflag istrue, it is created using provided name and count parameter.- Parameters:
- name- Name of the semaphore.
- cnt- Count for new semaphore creation. Ignored if- createflag is- false.
- failoverSafe-- Trueto create failover safe semaphore which means that if any node leaves topology permits already acquired by that node are silently released and become available for alive nodes to acquire. If flag is- falsethen all threads waiting for available permits get interrupted.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- Semaphore for the given name.
- Throws:
- IgniteException- If semaphore could not be fetched or created.
 
 - 
reentrantLockIgniteLock reentrantLock(String name, boolean failoverSafe, boolean fair, boolean create) throws IgniteException Gets or creates reentrant lock. If reentrant lock is not found in cache andcreateflag istrue, it is created using provided name.- Parameters:
- name- Name of the lock.
- failoverSafe-- Trueto create failover safe lock which means that if any node leaves topology, all locks already acquired by that node are silently released and become available for other nodes to acquire. If flag is- falsethen all threads on other nodes waiting to acquire lock are interrupted.
- fair- If- True, fair lock will be created.
- create- Boolean flag indicating whether data structure should be created if does not exist.
- Returns:
- ReentrantLock for the given name.
- Throws:
- IgniteException- If reentrant lock could not be fetched or created.
 
 - 
queue<T> IgniteQueue<T> queue(String name, int cap, @Nullable @Nullable CollectionConfiguration cfg) throws IgniteException Will get a named queue from cache and create one if it has not been created yet andcfgis notnull. If queue is present already, queue properties will not be changed. Use collocation forCacheMode.PARTITIONEDcaches if you have lots of relatively small queues as it will make fetching, querying, and iteration a lot faster. If you have few very large queues, then you should consider turning off collocation as they simply may not fit in a single node's memory.- Type Parameters:
- T- Type of the elements in queue.
- Parameters:
- name- Name of queue.
- cap- Capacity of queue,- 0for unbounded queue. Ignored if- cfgis- null.
- cfg- Queue configuration if new queue should be created.
- Returns:
- Queue with given properties.
- Throws:
- IgniteException- If queue could not be fetched or created.
 
 - 
set<T> IgniteSet<T> set(String name, @Nullable @Nullable CollectionConfiguration cfg) throws IgniteException Will get a named set from cache and create one if it has not been created yet andcfgis notnull.- Type Parameters:
- T- Type of the elements in set.
- Parameters:
- name- Set name.
- cfg- Set configuration if new set should be created.
- Returns:
- Set with given properties.
- Throws:
- IgniteException- If set could not be fetched or created.
 
 - 
plugin<T extends IgnitePlugin> T plugin(String name) throws PluginNotFoundException Gets an instance of deployed Ignite plugin.- Type Parameters:
- T- Plugin type.
- Parameters:
- name- Plugin name.
- Returns:
- Plugin instance.
- Throws:
- PluginNotFoundException- If plugin for the given name was not found.
 
 - 
binaryIgniteBinary binary() Gets an instance ofIgniteBinaryinterface.- Returns:
- Instance of IgniteBinaryinterface.
 
 - 
closevoid close() throws IgniteExceptionClosesthisinstance of grid. This method is identical to callingG.stop(igniteInstanceName, true).The method is invoked automatically on objects managed by the try-with-resourcesstatement.- Specified by:
- closein interface- AutoCloseable
- Throws:
- IgniteException- If failed to stop grid.
 
 - 
affinity<K> Affinity<K> affinity(String cacheName) Gets affinity service to provide information about data partitioning and distribution.- Type Parameters:
- K- Cache key type.
- Parameters:
- cacheName- Cache name.
- Returns:
- Affinity.
 
 - 
active@Deprecated boolean active() Deprecated.UseIgniteCluster.state()instead.Checks Ignite grid is active or not active.- Returns:
- Trueif grid is active.- FalseIf grid is not active.
 
 - 
active@Deprecated void active(boolean active) Deprecated.UseIgniteCluster.state(ClusterState)instead.Changes Ignite grid state to active or inactive.NOTE: Deactivation clears in-memory caches (without persistence) including the system caches. - Parameters:
- active- If- Truestart activation process. If- Falsestart deactivation process.
- Throws:
- IgniteException- If there is an already started transaction or lock in the same thread.
 
 - 
resetLostPartitionsvoid resetLostPartitions(Collection<String> cacheNames) Clears partition's lost state and moves caches to a normal mode.To avoid permanent data loss for persistent caches it's recommended to return all previously failed baseline nodes to the topology before calling this method. - Parameters:
- cacheNames- Name of the caches for which lost partitions is reset.
 
 - 
memoryMetrics@Deprecated Collection<MemoryMetrics> memoryMetrics() Deprecated.Check theReadOnlyMetricRegistrywith "name=io.dataregion.{data_region_name}" instead.- Returns:
- Collection of MemoryMetricssnapshots.
 
 - 
memoryMetrics@Deprecated @Nullable @Nullable MemoryMetrics memoryMetrics(String dataRegionName) Deprecated.Check theReadOnlyMetricRegistrywith "name=io.dataregion.{data_region_name}" instead.- Parameters:
- dataRegionName- Name of the data region.
- Returns:
- MemoryMetricssnapshot or- nullif no memory region is configured under specified name.
 
 - 
dataRegionMetricsCollection<DataRegionMetrics> dataRegionMetrics() Deprecated.Check theReadOnlyMetricRegistrywith "name=io.dataregion.{data_region_name}" instead.Returns a collection ofDataRegionMetricsthat reflects page memory usage on this Apache Ignite node instance. Returns the collection that contains the latest snapshots for each memory region configured withconfigurationon this Ignite node instance.- Returns:
- Collection of DataRegionMetricssnapshots.
 
 - 
dataRegionMetrics@Nullable @Nullable DataRegionMetrics dataRegionMetrics(String memPlcName) Returns the latestDataRegionMetricssnapshot for the memory region of the given name. To get the metrics for the default memory region useDataStorageConfiguration.DFLT_DATA_REG_DEFAULT_NAMEas the name or a custom name if the default memory region has been renamed.- Parameters:
- memPlcName- Name of memory region configured with- config.
- Returns:
- DataRegionMetricssnapshot or- nullif no memory region is configured under specified name.
 
 - 
encryptionIgniteEncryption encryption() Gets an instance ofIgniteEncryptioninterface.- Returns:
- Instance of IgniteEncryptioninterface.
 
 - 
snapshotIgniteSnapshot snapshot() - Returns:
- Snapshot manager.
 
 - 
tracingConfiguration@NotNull @NotNull TracingConfigurationManager tracingConfiguration() Returns theTracingConfigurationManagerinstance that allows to- Configure tracing parameters such as sampling rate for the specific tracing coordinates such as scope and label.
- Retrieve the most specific tracing parameters for the specified tracing coordinates (scope and label)
- Restore the tracing parameters for the specified tracing coordinates to the default.
- List all pairs of tracing configuration coordinates and tracing configuration parameters.
 - Returns:
- TracingConfigurationManagerinstance.
 
 
- 
 
-