Uses of Class
org.apache.ignite.IgniteCheckedException

Packages that use IgniteCheckedException

Package	Description
org.apache.ignite	Contains entry-point Ignite & HPC APIs.
org.apache.ignite.cache	Contains main Data Grid APIs.
org.apache.ignite.cache.eviction.igfs	Contains IGFS LRU eviction policy implementations.
org.apache.ignite.cache.store.jdbc	Contains reference JDBC-based cache store implementation.
org.apache.ignite.compute.gridify	Contains APIs utilized for AOP-based grid-enabling.
org.apache.ignite.compute.gridify.aop	Contains common classes for different AOP providers.
org.apache.ignite.configuration
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.client.router
org.apache.ignite.internal.client.router.impl
org.apache.ignite.internal.cluster
org.apache.ignite.internal.compute
org.apache.ignite.internal.igfs.common	Contains IGFS classes that are common between client and server.
org.apache.ignite.internal.managers	TODO.
org.apache.ignite.internal.managers.checkpoint	TODO.
org.apache.ignite.internal.managers.collision	TODO.
org.apache.ignite.internal.managers.communication	TODO.
org.apache.ignite.internal.managers.deployment	TODO.
org.apache.ignite.internal.managers.discovery	TODO.
org.apache.ignite.internal.managers.eventstorage	TODO.
org.apache.ignite.internal.managers.failover	TODO.
org.apache.ignite.internal.managers.indexing	Indexing manager classes.
org.apache.ignite.internal.managers.loadbalancer	TODO.
org.apache.ignite.internal.managers.swapspace	TODO.
org.apache.ignite.internal.processors	TODO.
org.apache.ignite.internal.processors.affinity	Data affinity processor.
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.datastructures
org.apache.ignite.internal.processors.cache.distributed
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.dht.atomic
org.apache.ignite.internal.processors.cache.distributed.dht.colocated
org.apache.ignite.internal.processors.cache.distributed.dht.preloader
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.dr
org.apache.ignite.internal.processors.cache.dr.os
org.apache.ignite.internal.processors.cache.jta
org.apache.ignite.internal.processors.cache.local
org.apache.ignite.internal.processors.cache.local.atomic
org.apache.ignite.internal.processors.cache.query
org.apache.ignite.internal.processors.cache.query.continuous
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.cache.version
org.apache.ignite.internal.processors.clock
org.apache.ignite.internal.processors.closure	TODO.
org.apache.ignite.internal.processors.continuous
org.apache.ignite.internal.processors.dataload	Data loader processor.
org.apache.ignite.internal.processors.datastructures
org.apache.ignite.internal.processors.hadoop	Contains Hadoop APIs.
org.apache.ignite.internal.processors.igfs	Contains high performance file system processer.
org.apache.ignite.internal.processors.job	TODO.
org.apache.ignite.internal.processors.jobmetrics	TODO.
org.apache.ignite.internal.processors.offheap
org.apache.ignite.internal.processors.port	TODO.
org.apache.ignite.internal.processors.query
org.apache.ignite.internal.processors.resource	TODO.
org.apache.ignite.internal.processors.rest	REST processor.
org.apache.ignite.internal.processors.rest.handlers.cache	REST in-memory data grid commands.
org.apache.ignite.internal.processors.rest.protocols	REST protocol handlers.
org.apache.ignite.internal.processors.rest.protocols.tcp	Adapters for TCP-based REST protocols.
org.apache.ignite.internal.processors.securesession
org.apache.ignite.internal.processors.securesession.os
org.apache.ignite.internal.processors.security
org.apache.ignite.internal.processors.security.os
org.apache.ignite.internal.processors.service
org.apache.ignite.internal.processors.session	Session processing package to guarantee reuse of same session object on the same node.
org.apache.ignite.internal.processors.spring
org.apache.ignite.internal.processors.streamer	TODO.
org.apache.ignite.internal.processors.task	TODO.
org.apache.ignite.internal.processors.timeout	TODO.
org.apache.ignite.internal.transactions
org.apache.ignite.internal.util	System-wide utility routine and helper classes.
org.apache.ignite.internal.util.future	Future related classes.
org.apache.ignite.internal.util.gridify	Utility classes for gridify annotations.
org.apache.ignite.internal.util.ipc	IPC utility classes.
org.apache.ignite.internal.util.ipc.loopback	Loopback IPC utility classes.
org.apache.ignite.internal.util.ipc.shmem	Shared memory IPC utility classes.
org.apache.ignite.internal.util.lang
org.apache.ignite.internal.util.nio	NIO server interfaces and common utility classes for NIO.
org.apache.ignite.internal.util.nio.ssl	Implementation of Secure Socket Layer filter for NIO server based on SSLEngine class.
org.apache.ignite.internal.util.nodestart
org.apache.ignite.internal.util.typedef	Contains typedefs definitions for frequently used classes.
org.apache.ignite.internal.util.worker	Common utility classes for threads.
org.apache.ignite.internal.visor.cache
org.apache.ignite.internal.visor.query
org.apache.ignite.internal.visor.util
org.apache.ignite.logger.java	Contains Java logging implementation for logging.
org.apache.ignite.marshaller	Contains various supported marshallers.
org.apache.ignite.marshaller.jdk	Contains JDK java.io based marshaller.
org.apache.ignite.marshaller.optimized	Contains default Optimized marshaller.
org.apache.ignite.plugin
org.apache.ignite.plugin.security	Contains APIs for security, authentication, and authorization.
org.apache.ignite.plugin.segmentation	Contains segmentation "split-brain" related classes.
org.apache.ignite.spi	Contains common classes and interfaces for SPI implementations.
org.apache.ignite.spi.communication.tcp	Contains default TCP/IP-based implementation for communication SPI.

Uses of IgniteCheckedException in org.apache.ignite

Subclasses of IgniteCheckedException in org.apache.ignite

Modifier and Type	Class and Description
class	IgniteAuthenticationException Exception that represents authentication failure.

Uses of IgniteCheckedException in org.apache.ignite.cache

Methods in org.apache.ignite.cache that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridCache.loadCache(IgniteBiPredicate<K,V> p, long ttl, Object... args) Delegates to CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method to load state from the underlying persistent storage.
Iterator<Map.Entry<K,V>>	GridCache.offHeapIterator() Gets iterator over keys and values belonging to this cache off-heap memory on local node.
long	GridCache.overflowSize() Gets size (in bytes) of all entries swapped to disk.
Iterator<Map.Entry<K,V>>	GridCache.swapIterator() Gets iterator over keys and values belonging to this cache swap space on local node.
long	GridCache.swapKeys() Gets number of swap entries (keys).
long	GridCache.swapSize() Gets size in bytes for swap space.

Uses of IgniteCheckedException in org.apache.ignite.cache.eviction.igfs

Methods in org.apache.ignite.cache.eviction.igfs that throw IgniteCheckedException

Modifier and Type	Method and Description
boolean	CacheIgfsPerBlockLruEvictionPolicy.exclude(IgfsPath path) Check whether provided path must be excluded from evictions.

Uses of IgniteCheckedException in org.apache.ignite.cache.store.jdbc

Methods in org.apache.ignite.cache.store.jdbc that throw IgniteCheckedException

Modifier and Type	Method and Description
protected <X> X	CacheJdbcBlobStore.fromBytes(byte[] bytes) Deserialize object from byte array using marshaller.
protected byte[]	CacheJdbcBlobStore.toBytes(Object obj) Serialize object to byte array using marshaller.

Uses of IgniteCheckedException in org.apache.ignite.compute.gridify

Methods in org.apache.ignite.compute.gridify that throw IgniteCheckedException

Modifier and Type	Method and Description
boolean	GridifyInterceptor.isGridify(Annotation gridify, GridifyArgument arg) This method is called before actual grid-enabling happens.

Uses of IgniteCheckedException in org.apache.ignite.compute.gridify.aop

Methods in org.apache.ignite.compute.gridify.aop that throw IgniteCheckedException

Modifier and Type	Method and Description
protected void	GridifySetToSetAbstractAspect.checkIsSplitToJobsAllowed(GridifyRangeArgument arg, GridifySetToSet ann) Check if split allowed for input argument.
protected void	GridifySetToValueAbstractAspect.checkIsSplitToJobsAllowed(GridifyRangeArgument arg, GridifySetToValue ann) Check if split allowed for input argument.
protected void	GridifySetToSetAbstractAspect.checkMethodSignature(Method mtd) Check method signature.
protected void	GridifySetToValueAbstractAspect.checkMethodSignature(Method mtd) Check method signature.
protected Object	GridifySetToSetAbstractAspect.execute(IgniteCompute compute, Class<?> cls, GridifyRangeArgument arg, GridifyNodeFilter nodeFilter, int threshold, int splitSize, long timeout) Execute method on grid.
protected Object	GridifySetToValueAbstractAspect.execute(Method mtd, IgniteCompute compute, Class<?> cls, GridifyRangeArgument arg, GridifyNodeFilter nodeFilter, int threshold, int splitSize, long timeout) Execute method on grid.

Uses of IgniteCheckedException in org.apache.ignite.configuration

Methods in org.apache.ignite.configuration that throw IgniteCheckedException

Modifier and Type	Method and Description
Collection<InetSocketAddress>	AddressResolver.getExternalAddresses(InetSocketAddress addr) Maps internal address to a collection of external addresses.

Uses of IgniteCheckedException in org.apache.ignite.internal

Subclasses of IgniteCheckedException in org.apache.ignite.internal

Modifier and Type	Class and Description
class	GridInternalException When log debug mode is disabled this exception should be logged in short form - without stack trace.
class	IgniteDeploymentCheckedException Deployment or re-deployment failed.
class	IgniteFutureCancelledCheckedException Future computation cannot be retrieved because it was cancelled.
class	IgniteFutureTimeoutCheckedException Future computation completion is timed out.
class	IgniteInterruptedCheckedException This exception is used to wrap standard InterruptedException into IgniteCheckedException.

Methods in org.apache.ignite.internal with parameters of type IgniteCheckedException

Modifier and Type	Method and Description
static <R> ComputeTaskInternalFuture<R>	ComputeTaskInternalFuture.finishedFuture(GridKernalContext ctx, Class<?> taskCls, IgniteCheckedException e)

Methods in org.apache.ignite.internal that throw IgniteCheckedException

Modifier and Type	Method and Description
boolean	ComputeTaskInternalFuture.cancel() Default no-op implementation that always returns false.
boolean	IgniteInternalFuture.cancel() Cancels this future.
boolean	ComputeTaskInternalFuture.cancelOnMasterLeave() Cancel task on master leave event.
<T> T	IgniteComponentType.create(boolean noOp) Creates component.
<T extends GridComponent> T	IgniteComponentType.create(GridKernalContext ctx, boolean noOp) Creates component.
<T extends GridComponent> T	IgniteComponentType.createIfInClassPath(GridKernalContext ctx, boolean mandatory) Creates component.
<T> T	IgniteComponentType.createOptional() First tries to find main component class, if it is not found creates no-op implementation.
<T> T	IgniteComponentType.createOptional(GridKernalContext ctx) First tries to find main component class, if it is not found creates no-op implementation.
R	IgniteInternalFuture.get() Synchronously waits for completion of the computation and returns computation result.
R	IgniteInternalFuture.get(long timeout) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
R	IgniteInternalFuture.get(long timeout, TimeUnit unit) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
static IgniteBiTuple<IgniteConfiguration,GridSpringResourceContext>	IgnitionEx.loadConfiguration(String springCfgPath) Loads first found grid configuration specified within given Spring XML configuration file.
static IgniteBiTuple<IgniteConfiguration,GridSpringResourceContext>	IgnitionEx.loadConfiguration(URL springCfgUrl) Loads first found grid configuration specified within given Spring XML configuration file.
static IgniteBiTuple<Collection<IgniteConfiguration>,? extends GridSpringResourceContext>	IgnitionEx.loadConfigurations(String springCfgPath) Loads all grid configurations specified within given Spring XML configuration file.
static IgniteBiTuple<Collection<IgniteConfiguration>,? extends GridSpringResourceContext>	IgnitionEx.loadConfigurations(URL springCfgUrl) Loads all grid configurations specified within given Spring XML configuration file.
void	GridPluginComponent.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	GridComponent.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	GridMessageListenHandler.p2pMarshal(GridKernalContext ctx) Deploys and marshals inner objects (called only if peer deployment is enabled).
void	GridMessageListenHandler.p2pUnmarshal(UUID nodeId, GridKernalContext ctx) Unmarshals inner objects (called only if peer deployment is enabled).
boolean	GridMessageListenHandler.register(UUID nodeId, UUID routineId, GridKernalContext ctx) Registers listener.
<R> R	AsyncSupportAdapter.saveOrGet(IgniteInternalFuture<R> fut)
void	GridPluginComponent.start() Starts grid component.
static Ignite	IgnitionEx.start() Starts grid with default configuration.
void	GridComponent.start() Starts grid component.
static Ignite	IgnitionEx.start(GridSpringResourceContext springCtx) Starts grid with default configuration.
static Ignite	IgnitionEx.start(IgniteConfiguration cfg) Starts grid with given configuration.
void	IgniteKernal.start(IgniteConfiguration cfg, ExecutorService utilityCachePool, ExecutorService execSvc, ExecutorService sysExecSvc, ExecutorService p2pExecSvc, ExecutorService mgmtExecSvc, ExecutorService igfsExecSvc, ExecutorService restExecSvc, GridAbsClosure errHnd)
static Ignite	IgnitionEx.start(IgniteConfiguration cfg, GridSpringResourceContext springCtx) Starts grid with given configuration.
static Ignite	IgnitionEx.start(String springCfgPath) Starts all grids specified within given Spring XML configuration file.
static Ignite	IgnitionEx.start(String springCfgPath, String gridName) Starts all grids specified within given Spring XML configuration file.
static Ignite	IgnitionEx.start(String springCfgPath, String gridName, GridSpringResourceContext springCtx) Starts all grids specified within given Spring XML configuration file.
static Ignite	IgnitionEx.start(URL springCfgUrl) Starts all grids specified within given Spring XML configuration file URL.
static Ignite	IgnitionEx.start(URL springCfgUrl, String gridName, GridSpringResourceContext springCtx) Starts all grids specified within given Spring XML configuration file URL.
static Ignite	IgnitionEx.startInterop(String springCfgPath, String gridName, IgniteClosure<IgniteConfiguration,IgniteConfiguration> cfgClo) Start Grid for interop scenario.
void	GridPluginComponent.stop(boolean cancel) Stops grid component.
void	GridComponent.stop(boolean cancel) Stops grid component.
void	GridJobSiblingsResponse.unmarshalSiblings(Marshaller marsh)

Uses of IgniteCheckedException in org.apache.ignite.internal.client.router

Methods in org.apache.ignite.internal.client.router that throw IgniteCheckedException

Modifier and Type	Method and Description
static GridTcpRouter	GridRouterFactory.startTcpRouter(GridTcpRouterConfiguration cfg) Starts a TCP router with given configuration.

Uses of IgniteCheckedException in org.apache.ignite.internal.client.router.impl

Methods in org.apache.ignite.internal.client.router.impl that throw IgniteCheckedException

Modifier and Type	Method and Description
static void	GridRouterCommandLineStartup.main(String[] args) Wrapper method to run router from command-line.

Uses of IgniteCheckedException in org.apache.ignite.internal.cluster

Subclasses of IgniteCheckedException in org.apache.ignite.internal.cluster

Modifier and Type	Class and Description
class	ClusterGroupEmptyCheckedException This exception defines illegal call on empty projection.
class	ClusterTopologyCheckedException This exception is used to indicate error with grid topology (e.g., crashed node, etc.).

Uses of IgniteCheckedException in org.apache.ignite.internal.compute

Subclasses of IgniteCheckedException in org.apache.ignite.internal.compute

Modifier and Type	Class and Description
class	ComputeTaskCancelledCheckedException This exception indicates that grid task was cancelled.
class	ComputeTaskTimeoutCheckedException This exception indicates that task execution timed out.

Uses of IgniteCheckedException in org.apache.ignite.internal.igfs.common

Methods in org.apache.ignite.internal.igfs.common with parameters of type IgniteCheckedException

Modifier and Type	Method and Description
void	IgfsControlResponse.error(IgniteCheckedException e)

Methods in org.apache.ignite.internal.igfs.common that throw IgniteCheckedException

Modifier and Type	Method and Description
void	IgfsMarshaller.marshall(IgfsMessage msg, byte[] hdr, ObjectOutput out)
void	IgfsControlResponse.throwError()
static void	IgfsControlResponse.throwError(Integer errCode, String err)
IgfsMessage	IgfsMarshaller.unmarshall(IgfsIpcCommand cmd, byte[] hdr, ObjectInput in)

Uses of IgniteCheckedException in org.apache.ignite.internal.managers

Methods in org.apache.ignite.internal.managers that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridManagerAdapter.addSpiAttributes(Map<String,Object> attrs) Adds attributes from underlying SPI to map of all attributes.
void	GridManager.addSpiAttributes(Map<String,Object> attrs) Adds attributes from underlying SPI to map of all attributes.
protected void	GridManagerAdapter.assertParameter(boolean cond, String condDesc) Throws exception with uniform error message if given parameter's assertion condition is false.
void	GridManagerAdapter.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
protected void	GridManagerAdapter.onKernalStart0()
protected void	GridManagerAdapter.startSpi() Starts wrapped SPI.
protected void	GridManagerAdapter.stopSpi() Stops wrapped SPI.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.checkpoint

Methods in org.apache.ignite.internal.managers.checkpoint that throw IgniteCheckedException

Modifier and Type	Method and Description
Serializable	GridCheckpointManager.loadCheckpoint(GridTaskSessionInternal ses, String key)
void	GridCheckpointManager.start() Starts grid component.
void	GridCheckpointManager.stop(boolean cancel) Stops grid component.
boolean	GridCheckpointManager.storeCheckpoint(GridTaskSessionInternal ses, String key, Object state, ComputeTaskSessionScope scope, long timeout, boolean override)

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.collision

Methods in org.apache.ignite.internal.managers.collision that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridCollisionManager.start() Starts grid component.
void	GridCollisionManager.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.communication

Methods in org.apache.ignite.internal.managers.communication that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridIoManager.onKernalStart0()
void	GridIoManager.send(ClusterNode node, GridTopic topic, MessageAdapter msg, GridIoPolicy plc)
void	GridIoManager.send(ClusterNode node, Object topic, MessageAdapter msg, GridIoPolicy plc)
void	GridIoManager.send(Collection<? extends ClusterNode> nodes, GridTopic topic, MessageAdapter msg, GridIoPolicy plc)
void	GridIoManager.send(Collection<? extends ClusterNode> nodes, Object topic, MessageAdapter msg, GridIoPolicy plc)
void	GridIoManager.send(UUID nodeId, GridTopic topic, MessageAdapter msg, GridIoPolicy plc)
void	GridIoManager.send(UUID nodeId, Object topic, MessageAdapter msg, GridIoPolicy plc)
void	GridIoManager.sendOrderedMessage(ClusterNode node, Object topic, MessageAdapter msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendOrderedMessage(Collection<? extends ClusterNode> nodes, Object topic, MessageAdapter msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendOrderedMessage(UUID nodeId, Object topic, MessageAdapter msg, GridIoPolicy plc, long timeout, boolean skipOnTimeout)
void	GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes, Object msg) Sends a peer deployable user message.
void	GridIoManager.sendUserMessage(Collection<? extends ClusterNode> nodes, Object msg, Object topic, boolean ordered, long timeout) Sends a peer deployable user message.
void	GridIoManager.start() Starts grid component.
void	GridIoManager.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.deployment

Methods in org.apache.ignite.internal.managers.deployment that throw IgniteCheckedException

Modifier and Type	Method and Description
Object	GridDeployment.annotatedValue(Object target, Class<? extends Annotation> annCls) Gets value of annotated field or method.
GridDeployment	GridDeploymentManager.deploy(Class<?> cls, ClassLoader clsLdr)
GridDeployment	GridDeploymentStore.explicitDeploy(Class<?> cls, ClassLoader clsLdr) Explicitly deploys class.
<T> T	GridDeployment.newInstance(Class<T> cls)
void	GridDeploymentStore.onKernalStart() Kernal started callback.
void	GridDeploymentPerVersionStore.onKernalStart() Kernal started callback.
void	GridDeploymentPerLoaderStore.onKernalStart() Kernal started callback.
void	GridDeploymentManager.onKernalStart0()
void	GridDeploymentManager.start() Starts grid component.
void	GridDeploymentStore.start() Starts store.
void	GridDeploymentPerVersionStore.start() Starts store.
void	GridDeploymentPerLoaderStore.start() Starts store.
void	GridDeploymentManager.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.discovery

Methods in org.apache.ignite.internal.managers.discovery that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridDiscoveryManager.start() Starts grid component.
void	GridDiscoveryManager.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.eventstorage

Methods in org.apache.ignite.internal.managers.eventstorage that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridEventStorageManager.start() Starts grid component.
void	GridEventStorageManager.stop(boolean cancel) Stops grid component.
Event	GridEventStorageManager.waitForEvent(long timeout, Runnable c, IgnitePredicate<? super Event> p, int... types)

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.failover

Methods in org.apache.ignite.internal.managers.failover that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridFailoverManager.start() Starts grid component.
void	GridFailoverManager.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.indexing

Methods in org.apache.ignite.internal.managers.indexing that throw IgniteCheckedException

Modifier and Type	Method and Description
IgniteSpiCloseableIterator<?>	GridIndexingManager.query(String space, Collection<Object> params, IndexingQueryFilter filters)
void	GridIndexingManager.remove(String space, Object key)
void	GridIndexingManager.start()
void	GridIndexingManager.stop(boolean cancel)
<K,V> void	GridIndexingManager.store(String space, K key, V val, long expirationTime) Writes key-value pair to index.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.loadbalancer

Methods in org.apache.ignite.internal.managers.loadbalancer that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridLoadBalancerManager.start() Starts grid component.
void	GridLoadBalancerManager.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.managers.swapspace

Methods in org.apache.ignite.internal.managers.swapspace that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridSwapSpaceManager.clear(String spaceName)
<K> GridCloseableIterator<K>	GridSwapSpaceManager.keysIterator(String spaceName, ClassLoader ldr) Gets iterator over space entries.
GridCloseableIterator<Map.Entry<byte[],byte[]>>	GridSwapSpaceManager.rawIterator(String spaceName) Gets iterator over space entries.
GridCloseableIterator<Map.Entry<byte[],byte[]>>	GridSwapSpaceManager.rawIterator(String spaceName, int part)
byte[]	GridSwapSpaceManager.read(String spaceName, SwapKey key, ClassLoader ldr) Reads value from swap.
<T> T	GridSwapSpaceManager.readValue(String spaceName, SwapKey key, ClassLoader ldr) Reads value from swap.
void	GridSwapSpaceManager.remove(String spaceName, Object key, IgniteInClosure<byte[]> c, ClassLoader ldr) Removes value from swap.
void	GridSwapSpaceManager.remove(String spaceName, SwapKey key, IgniteInClosure<byte[]> c, ClassLoader ldr) Removes value from swap.
void	GridSwapSpaceManager.removeAll(String spaceName, Collection<SwapKey> keys, IgniteBiInClosure<SwapKey,byte[]> c, ClassLoader ldr) Removes value from swap.
void	GridSwapSpaceManager.start() Starts grid component.
void	GridSwapSpaceManager.stop(boolean cancel) Stops grid component.
long	GridSwapSpaceManager.swapKeys(String spaceName) Gets number of swap entries (keys).
long	GridSwapSpaceManager.swapKeys(String spaceName, Set<Integer> parts) Gets number of swap entries for given partitions.
long	GridSwapSpaceManager.swapSize(String spaceName) Gets size in bytes for swap space.
void	GridSwapSpaceManager.write(String spaceName, Object key, Object val, ClassLoader ldr) Writes value to swap.
void	GridSwapSpaceManager.write(String spaceName, SwapKey key, byte[] val, ClassLoader ldr) Writes value to swap.
<K,V> void	GridSwapSpaceManager.writeAll(String spaceName, Map<SwapKey,byte[]> batch, ClassLoader ldr) Writes batch to swap.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors

Methods in org.apache.ignite.internal.processors that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridProcessorAdapter.addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
void	GridProcessor.addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
protected void	GridProcessorAdapter.assertParameter(boolean cond, String condDesc) Throws exception with uniform error message if given parameter's assertion condition is false.
void	GridProcessorAdapter.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	GridProcessorAdapter.start() Starts grid component.
void	GridProcessorAdapter.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.affinity

Methods in org.apache.ignite.internal.processors.affinity that throw IgniteCheckedException

Modifier and Type	Method and Description
Object	GridAffinityProcessor.affinityKey(String cacheName, Object key) Gets affinity key for cache key.
<K> Map<ClusterNode,Collection<K>>	GridAffinityProcessor.mapKeysToNodes(Collection<? extends K> keys) Maps keys to nodes on default cache.
<K> Map<ClusterNode,Collection<K>>	GridAffinityProcessor.mapKeysToNodes(String cacheName, Collection<? extends K> keys) Maps keys to nodes for given cache.
<K> ClusterNode	GridAffinityProcessor.mapKeyToNode(K key) Maps single key to a node on default cache.
<K> ClusterNode	GridAffinityProcessor.mapKeyToNode(String cacheName, K key) Maps single key to a node.
<K> ClusterNode	GridAffinityProcessor.mapKeyToNode(String cacheName, K key, long topVer) Maps single key to a node.
<K> List<ClusterNode>	GridAffinityProcessor.mapKeyToPrimaryAndBackups(String cacheName, K key) Map single key to primary and backup nodes.
void	GridAffinityProcessor.start() Starts grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache

Subclasses of IgniteCheckedException in org.apache.ignite.internal.processors.cache

Modifier and Type	Class and Description
class	CacheAtomicUpdateTimeoutCheckedException Exception thrown when atomic operation timeout occurs.
class	CachePartialUpdateCheckedException Exception thrown from non-transactional cache in case when update succeeded only partially.
class	CacheStorePartialUpdateException
class	GridCacheIndexUpdateException Exception indicating that index update failed during cache entry update.

Methods in org.apache.ignite.internal.processors.cache that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridCacheProcessor.addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
void	GridCacheSharedContext.addCacheContext(GridCacheContext cacheCtx) Adds cache context to shared cache context.
void	GridCacheEvictionManager.batchEvict(Collection<? extends K> keys, GridCacheVersion obsoleteVer)
static void	GridCacheUtils.checkAttributeMismatch(IgniteLogger log, CacheConfiguration locCfg, CacheConfiguration rmtCfg, ClusterNode rmt, T2<String,String> attr, boolean fail) Checks that local and remove configurations have the same value of given attribute.
static void	GridCacheUtils.checkAttributeMismatch(IgniteLogger log, String cfgName, ClusterNode rmt, String attrName, String attrMsg, Object locVal, Object rmtVal, boolean fail) Checks that cache configuration attribute has the same value in local and remote cache configurations.
protected void	GridCacheAdapter.checkJta() Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
static void	GridCacheUtils.checkStore(GridCacheContext<?,?> ctx) Checks that cache store is present.
void	GridCacheProjectionImpl.clear() Clears cache on all nodes that store it's data.
void	CacheProjection.clear() Deprecated. Deprecated in favor of CacheProjection.clear(long) method.
void	GridCacheProxyImpl.clear() Clears cache on all nodes that store it's data.
void	GridCacheAdapter.clear() Clears cache on all nodes that store it's data.
boolean	GridCacheMapEntry.clear(GridCacheVersion ver, boolean readers, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Marks entry as obsolete and, if possible or required, removes it from swap storage.
boolean	GridCacheEntryEx.clear(GridCacheVersion ver, boolean readers, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Marks entry as obsolete and, if possible or required, removes it from swap storage.
void	GridCacheProjectionImpl.clear(long timeout) Clears cache on all nodes that store it's data.
void	CacheProjection.clear(long timeout) Clears cache on all nodes that store it's data.
void	GridCacheProxyImpl.clear(long timeout) Clears cache on all nodes that store it's data.
void	GridCacheAdapter.clear(long timeout) Clears cache on all nodes that store it's data.
protected void	GridCacheMapEntry.clearIndex(V prevVal) Clears index.
void	GridCacheSwapManager.clearSwap() Clears swap.
<T> T	GridCacheContext.cloneOnFlag(T obj) Clones cached object depending on whether or not CacheFlag.CLONE flag is set thread locally.
<T> T	GridCacheContext.cloneValue(T obj) Clone cached object.
boolean	GridCacheMapEntry.compact(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Optimizes the size of this entry.
boolean	GridCacheEntryEx.compact(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Optimizes the size of this entry.
boolean	GridCacheProjectionImpl.compact(K key) Clears serialized value bytes from entry (if any) leaving only object representation.
boolean	CacheProjection.compact(K key) Clears serialized value bytes from entry (if any) leaving only object representation.
boolean	GridCacheProxyImpl.compact(K key) Clears serialized value bytes from entry (if any) leaving only object representation.
boolean	GridCacheAdapter.compact(K key) Clears serialized value bytes from entry (if any) leaving only object representation.
boolean	GridCacheAdapter.compact(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
void	GridCacheProjectionImpl.compactAll() Clears serialized value bytes from cache entries (if any) leaving only object representation.
void	CacheProjection.compactAll() Clears serialized value bytes from cache entries (if any) leaving only object representation.
void	GridCacheProxyImpl.compactAll() Clears serialized value bytes from cache entries (if any) leaving only object representation.
void	GridCacheAdapter.compactAll() Clears serialized value bytes from cache entries (if any) leaving only object representation.
void	GridCacheAdapter.compactAll(Iterable<K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
GridCacheVersionConflictContext<K,V>	GridCacheContext.conflictResolve(GridCacheVersionedEntryEx<K,V> oldEntry, GridCacheVersionedEntryEx<K,V> newEntry, boolean atomicVerComparator) Resolve DR conflict.
boolean	GridCacheSwapManager.containsKey(K key, byte[] keyBytes)
byte[]	GridCacheContext.convertPortableBytes(byte[] bytes)
void	GridCacheSharedContext.endTx(IgniteInternalTx<K,V> tx)
boolean	GridCacheEvictionManager.evict(GridCacheEntryEx<K,V> entry, GridCacheVersion obsoleteVer, boolean explicit, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
GridCacheBatchSwapEntry<K,V>	GridCacheMapEntry.evictInBatchInternal(GridCacheVersion obsoleteVer) Evicts entry when batch evict is performed.
GridCacheBatchSwapEntry<K,V>	GridCacheEntryEx.evictInBatchInternal(GridCacheVersion obsoleteVer) Evicts entry when batch evict is performed.
boolean	GridCacheMapEntry.evictInternal(boolean swap, GridCacheVersion obsoleteVer, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
boolean	GridCacheEntryEx.evictInternal(boolean swap, GridCacheVersion obsoleteVer, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
void	GridCacheMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridCacheEvictionRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridCacheEvictionResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridCacheStoreManager.forceFlush()
void	GridCacheWriteBehindStore.forceFlush() Forces all entries collected to be flushed to the underlying store.
V	GridCacheProjectionImpl.get(K key) Retrieves value mapped to the specified key from cache.
V	CacheProjection.get(K key) Retrieves value mapped to the specified key from cache.
V	GridCacheProxyImpl.get(K key) Retrieves value mapped to the specified key from cache.
V	GridCacheAdapter.get(K key) Retrieves value mapped to the specified key from cache.
V	GridCacheAdapter.get(K key, boolean deserializePortable)
V	GridCacheProjectionEx.get(K key, GridCacheEntryEx<K,V> entry, boolean deserializePortable, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
V	GridCacheProjectionImpl.get(K key, GridCacheEntryEx<K,V> entry, boolean deserializePortable, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
V	GridCacheProxyImpl.get(K key, GridCacheEntryEx<K,V> entry, boolean deserializePortable, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
V	GridCacheAdapter.get(K key, GridCacheEntryEx<K,V> entry, boolean deserializePortable, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter)
Map<K,V>	GridCacheProjectionImpl.getAll(Collection<? extends K> keys) Retrieves values mapped to the specified keys from cache.
Map<K,V>	CacheProjection.getAll(Collection<? extends K> keys) Retrieves values mapped to the specified keys from cache.
Map<K,V>	GridCacheProxyImpl.getAll(Collection<? extends K> keys) Retrieves values mapped to the specified keys from cache.
Map<K,V>	GridCacheAdapter.getAll(Collection<? extends K> keys) Retrieves values mapped to the specified keys from cache.
Map<K,V>	GridCacheAdapter.getAll(Collection<? extends K> keys, boolean deserializePortable)
Map<K,V>	GridCacheProjectionEx.getAllOutTx(List<K> keys) Gets values from cache.
Map<K,V>	GridCacheProjectionImpl.getAllOutTx(List<K> keys) Gets values from cache.
Map<K,V>	GridCacheProxyImpl.getAllOutTx(List<K> keys) Gets values from cache.
Map<K,V>	GridCacheAdapter.getAllOutTx(List<K> keys) Gets values from cache.
V	GridCacheProjectionEx.getForcePrimary(K key) Gets value from cache.
V	GridCacheProjectionImpl.getForcePrimary(K key) Gets value from cache.
V	GridCacheProxyImpl.getForcePrimary(K key) Gets value from cache.
V	GridCacheAdapter.getForcePrimary(K key) Gets value from cache.
byte[]	GridCacheMapEntry.getOrMarshalKeyBytes()
byte[]	GridCacheEntryEx.getOrMarshalKeyBytes()
int	GridCacheProjectionImpl.globalPrimarySize() Gets the number of all primary entries cached across all nodes (excluding backups).
int	CacheProjection.globalPrimarySize() Gets the number of all primary entries cached across all nodes (excluding backups).
int	GridCacheProxyImpl.globalPrimarySize() Gets the number of all primary entries cached across all nodes (excluding backups).
int	GridCacheAdapter.globalPrimarySize() Gets the number of all primary entries cached across all nodes (excluding backups).
int	GridCacheProjectionImpl.globalSize() Gets the number of all entries cached across all nodes.
int	CacheProjection.globalSize() Gets the number of all entries cached across all nodes.
int	GridCacheProxyImpl.globalSize() Gets the number of all entries cached across all nodes.
int	GridCacheAdapter.globalSize() Gets the number of all entries cached across all nodes.
boolean	GridCacheMapEntry.initialValue(K key, GridCacheSwapEntry<V> unswapped) Sets new value if current version is 0 using swap entry data.
boolean	GridCacheEntryEx.initialValue(K key, GridCacheSwapEntry<V> unswapped) Sets new value if current version is 0 using swap entry data.
boolean	GridCacheMapEntry.initialValue(V val, byte[] valBytes, GridCacheVersion ver, long ttl, long expireTime, boolean preload, long topVer, GridDrType drType) Sets new value if current version is 0
boolean	GridCacheEntryEx.initialValue(V val, byte[] valBytes, GridCacheVersion ver, long ttl, long expireTime, boolean preload, long topVer, GridDrType drType) Sets new value if current version is 0
V	GridCacheMapEntry.innerGet(IgniteInternalTx<K,V> tx, boolean readSwap, boolean readThrough, boolean failFast, boolean unmarshal, boolean updateMetrics, boolean evt, boolean tmp, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expirePlc)
V	GridCacheEntryEx.innerGet(IgniteInternalTx<K,V> tx, boolean readSwap, boolean readThrough, boolean failFast, boolean unmarshal, boolean updateMetrics, boolean evt, boolean tmp, UUID subjId, Object transformClo, String taskName, IgniteCacheExpiryPolicy expiryPlc)
V	GridCacheMapEntry.innerReload() Reloads entry from underlying storage.
V	GridCacheEntryEx.innerReload() Reloads entry from underlying storage.
GridCacheUpdateTxResult<V>	GridCacheMapEntry.innerRemove(IgniteInternalTx<K,V> tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, long topVer, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult<V>	GridCacheEntryEx.innerRemove(IgniteInternalTx<K,V> tx, UUID evtNodeId, UUID affNodeId, boolean writeThrough, boolean retval, boolean evt, boolean metrics, long topVer, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridDrType drType, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult<V>	GridCacheMapEntry.innerSet(IgniteInternalTx<K,V> tx, UUID evtNodeId, UUID affNodeId, V val, byte[] valBytes, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, long topVer, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateTxResult<V>	GridCacheEntryEx.innerSet(IgniteInternalTx<K,V> tx, UUID evtNodeId, UUID affNodeId, V val, byte[] valBytes, boolean writeThrough, boolean retval, long ttl, boolean evt, boolean metrics, long topVer, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridDrType drType, long drExpireTime, GridCacheVersion explicitVer, UUID subjId, String taskName)
GridCacheUpdateAtomicResult<K,V>	GridCacheMapEntry.innerUpdate(GridCacheVersion newVer, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object writeObj, byte[] valBytes, Object[] invokeArgs, boolean writeThrough, boolean retval, IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean verCheck, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridDrType drType, long drTtl, long drExpireTime, GridCacheVersion drVer, boolean drResolve, boolean intercept, UUID subjId, String taskName)
GridCacheUpdateAtomicResult<K,V>	GridCacheEntryEx.innerUpdate(GridCacheVersion ver, UUID evtNodeId, UUID affNodeId, GridCacheOperation op, Object val, byte[] valBytes, Object[] invokeArgs, boolean writeThrough, boolean retval, IgniteCacheExpiryPolicy expiryPlc, boolean evt, boolean metrics, boolean primary, boolean checkVer, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridDrType drType, long drTtl, long drExpireTime, GridCacheVersion drVer, boolean drResolve, boolean intercept, UUID subjId, String taskName)
GridTuple3<Boolean,V,javax.cache.processor.EntryProcessorResult<Object>>	GridCacheMapEntry.innerUpdateLocal(GridCacheVersion ver, GridCacheOperation op, Object writeObj, Object[] invokeArgs, boolean writeThrough, boolean retval, javax.cache.expiry.ExpiryPolicy expiryPlc, boolean evt, boolean metrics, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, boolean intercept, UUID subjId, String taskName) Update method for local cache in atomic mode.
GridTuple3<Boolean,V,javax.cache.processor.EntryProcessorResult<Object>>	GridCacheEntryEx.innerUpdateLocal(GridCacheVersion ver, GridCacheOperation op, Object writeObj, Object[] invokeArgs, boolean writeThrough, boolean retval, javax.cache.expiry.ExpiryPolicy expiryPlc, boolean evt, boolean metrics, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, boolean intercept, UUID subjId, String taskName) Update method for local cache in atomic mode.
static <K,V> void	GridCacheUtils.inTx(CacheProjection<K,V> cache, TransactionConcurrency concurrency, TransactionIsolation isolation, IgniteInClosureX<CacheProjection<K,V>> clo) Execute closure inside cache transaction.
static <K,V> void	GridCacheUtils.inTx(Ignite ignite, IgniteCache<K,V> cache, TransactionConcurrency concurrency, TransactionIsolation isolation, IgniteInClosureX<IgniteCache<K,V>> clo) Execute closure inside cache transaction.
boolean	GridCacheMapEntry.invalidate(GridCacheVersion curVer, GridCacheVersion newVer) Invalidates this entry.
boolean	GridCacheEntryEx.invalidate(GridCacheVersion curVer, GridCacheVersion newVer) Invalidates this entry.
boolean	GridCacheMapEntry.invalidate(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Invalidates this entry if it passes given filter.
boolean	GridCacheEntryEx.invalidate(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Invalidates this entry if it passes given filter.
<T> javax.cache.processor.EntryProcessorResult<T>	GridCacheProjectionEx.invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> javax.cache.processor.EntryProcessorResult<T>	GridCacheProjectionImpl.invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> javax.cache.processor.EntryProcessorResult<T>	GridCacheProxyImpl.invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> javax.cache.processor.EntryProcessorResult<T>	GridCacheAdapter.invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheProjectionEx.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheProjectionImpl.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheProxyImpl.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheAdapter.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheProjectionEx.invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheProjectionImpl.invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheProxyImpl.invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridCacheAdapter.invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<E> boolean	GridCacheContext.isAll(E e, IgnitePredicate<? super E>[] p) Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.
<K1,V1> boolean	GridCacheContext.isAll(GridCacheEntryEx<K1,V1> e, IgnitePredicate<javax.cache.Cache.Entry<K1,V1>>[] p) Same as GridFunc.isAll(Object, IgnitePredicate[]), but safely unwraps exceptions.
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>>	GridCacheSwapManager.iterator(int part, boolean unmarshal) Gets offheap and swap iterator over partition.
Iterator<Map.Entry<K,V>>	GridCacheSwapManager.lazySwapIterator()
boolean	GridCacheStoreManager.loadAllFromStore(IgniteInternalTx tx, Collection<? extends K> keys, IgniteBiInClosure<K,V> vis) Loads data from persistent store.
boolean	GridCacheStoreManager.loadCache(GridInClosure3<K,V,GridCacheVersion> vis, Object[] args) Loads data from persistent store.
void	GridCacheProxyImpl.loadCache(IgniteBiPredicate<K,V> p, long ttl, Object[] args) Delegates to CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method to load state from the underlying persistent storage.
void	GridCacheAdapter.loadCache(IgniteBiPredicate<K,V> p, long ttl, Object[] args) Delegates to CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method to load state from the underlying persistent storage.
V	GridCacheStoreManager.loadFromStore(IgniteInternalTx tx, K key) Loads data from persistent store.
Iterable<javax.cache.Cache.Entry<K,V>>	GridCacheProjectionImpl.localEntries(CachePeekMode[] peekModes)
Iterable<javax.cache.Cache.Entry<K,V>>	CacheProjection.localEntries(CachePeekMode[] peekModes)
Iterable<javax.cache.Cache.Entry<K,V>>	GridCacheProxyImpl.localEntries(CachePeekMode[] peekModes)
Iterable<javax.cache.Cache.Entry<K,V>>	GridCacheAdapter.localEntries(CachePeekMode[] peekModes)
void	GridCacheAdapter.localLoad(Collection<? extends K> keys, javax.cache.expiry.ExpiryPolicy plc)
V	GridCacheProjectionImpl.localPeek(K key, CachePeekMode[] peekModes, IgniteCacheExpiryPolicy plc)
V	CacheProjection.localPeek(K key, CachePeekMode[] peekModes, IgniteCacheExpiryPolicy plc)
V	GridCacheProxyImpl.localPeek(K key, CachePeekMode[] peekModes, IgniteCacheExpiryPolicy plc)
V	GridCacheAdapter.localPeek(K key, CachePeekMode[] peekModes, IgniteCacheExpiryPolicy plc)
int	GridCacheProjectionImpl.localSize(CachePeekMode[] peekModes)
int	CacheProjection.localSize(CachePeekMode[] peekModes)
int	GridCacheProxyImpl.localSize(CachePeekMode[] peekModes)
int	GridCacheAdapter.localSize(CachePeekMode[] peekModes)
void	GridCacheStoreManager.localStoreLoadAll(IgniteInternalTx tx, Collection<? extends K> keys, GridInClosure3<K,V,GridCacheVersion> vis)
boolean	GridCacheProjectionImpl.lock(K key, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	CacheProjection.lock(K key, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	GridCacheAdapter.lock(K key, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	GridCacheProxyImpl.lock(K key, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Synchronously acquires lock on a cached object with given key only if the passed in filter (if any) passes.
boolean	CacheProjection.lockAll(Collection<? extends K> keys, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) All or nothing synchronous lock for passed in keys.
boolean	GridCacheAdapter.lockAll(Collection<? extends K> keys, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) All or nothing synchronous lock for passed in keys.
boolean	GridCacheProjectionImpl.lockAll(Collection<? extends K> keys, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) All or nothing synchronous lock for passed in keys.
boolean	GridCacheProxyImpl.lockAll(Collection<? extends K> keys, long timeout, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) All or nothing synchronous lock for passed in keys.
boolean	GridCacheMapEntry.markObsoleteIfEmpty(GridCacheVersion ver) Sets obsolete flag if entry value is null or entry is expired and no locks are held.
boolean	GridCacheEntryEx.markObsoleteIfEmpty(GridCacheVersion ver) Sets obsolete flag if entry value is null or entry is expired and no locks are held.
void	GridCacheEntryInfo.marshal(GridCacheSharedContext<K,V> ctx)
static byte[]	GridCacheUtils.marshal(GridCacheSharedContext ctx, Object obj)
protected LinkedHashMap<byte[],Boolean>	GridCacheMessage.marshalBooleanLinkedMap(LinkedHashMap<?,Boolean> map, GridCacheSharedContext<K,V> ctx)
protected List<byte[]>	GridCacheMessage.marshalCollection(Collection<?> col, GridCacheSharedContext<K,V> ctx)
protected <T> byte[][]	GridCacheMessage.marshalFilter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridCacheSharedContext<K,V> ctx)
protected void	GridCacheMessage.marshalInfo(GridCacheEntryInfo<K,V> info, GridCacheSharedContext<K,V> ctx)
protected void	GridCacheMessage.marshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos, GridCacheSharedContext<K,V> ctx)
protected byte[][]	GridCacheMessage.marshalInvokeArguments(Object[] args, GridCacheSharedContext<K,V> ctx)
protected void	GridCacheMessage.marshalTx(Iterable<IgniteTxEntry<K,V>> txEntries, GridCacheSharedContext<K,V> ctx)
protected List<GridCacheValueBytes>	GridCacheMessage.marshalValuesCollection(Collection<?> col, GridCacheSharedContext<K,V> ctx)
int	GridCacheMapEntry.memorySize()
int	GridCacheEntryEx.memorySize()
int	GridCacheSwapManager.offheapEntriesCount(boolean primary, boolean backup, long topVer)
Iterator<Map.Entry<K,V>>	GridCacheProxyImpl.offHeapIterator() Gets iterator over keys and values belonging to this cache off-heap memory on local node.
Iterator<Map.Entry<K,V>>	GridCacheAdapter.offHeapIterator() Gets iterator over keys and values belonging to this cache off-heap memory on local node.
Iterator<javax.cache.Cache.Entry<K,V>>	GridCacheSwapManager.offheapIterator(boolean primary, boolean backup, long topVer)
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>>	GridCacheSwapManager.offHeapIterator(int part, boolean unmarshal) Gets offheap iterator over partition.
protected void	CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onClose() Invoked on iterator close.
boolean	CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onHasNext()
void	GridCachePreloader.onKernalStart() Kernal start callback.
void	GridCachePreloaderAdapter.onKernalStart() Kernal start callback.
void	GridCacheManagerAdapter.onKernalStart()
void	GridCacheManager.onKernalStart()
void	GridCacheSharedManagerAdapter.onKernalStart()
void	GridCacheSharedManager.onKernalStart()
protected void	GridCacheAdapter.onKernalStart() Kernal start callback.
void	GridCacheProcessor.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
protected void	GridCacheManagerAdapter.onKernalStart0()
protected void	GridCachePartitionExchangeManager.onKernalStart0()
protected void	GridCacheSharedManagerAdapter.onKernalStart0()
protected void	GridCacheTtlManager.onKernalStart0()
protected void	GridCacheAffinityManager.onKernalStart0()
protected void	GridCacheEvictionManager.onKernalStart0()
void	GridCacheMvccManager.onKernalStart0()
T	CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onNext()
protected void	CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator.onRemove() Called on remove from iterator.
static <T> T	GridCacheUtils.outTx(Callable<T> cmd, GridCacheContext ctx) Method executes any Callable out of scope of transaction.
long	GridCacheProxyImpl.overflowSize() Gets size (in bytes) of all entries swapped to disk.
long	GridCacheAdapter.overflowSize() Gets size (in bytes) of all entries swapped to disk.
V	GridCacheMapEntry.peek(boolean heap, boolean offheap, boolean swap, long topVer, IgniteCacheExpiryPolicy expiryPlc) Peeks into entry without loading value or updating statistics.
V	GridCacheEntryEx.peek(boolean heap, boolean offheap, boolean swap, long topVer, IgniteCacheExpiryPolicy plc) Peeks into entry without loading value or updating statistics.
V	GridCacheProjectionImpl.peek(K key, Collection<GridCachePeekMode> modes) Peeks at cached value using optional set of peek modes.
V	CacheProjection.peek(K key, Collection<GridCachePeekMode> modes) Peeks at cached value using optional set of peek modes.
V	GridCacheProxyImpl.peek(K key, Collection<GridCachePeekMode> modes) Peeks at cached value using optional set of peek modes.
V	GridCacheAdapter.peek(K key, Collection<GridCachePeekMode> modes) Peeks at cached value using optional set of peek modes.
GridTuple<V>	GridCacheMapEntry.peek0(boolean failFast, GridCachePeekMode mode, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, IgniteInternalTx<K,V> tx)
GridTuple<V>	GridCacheEntryEx.peek0(boolean failFast, GridCachePeekMode mode, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, IgniteInternalTx<K,V> tx)
protected GridTuple<V>	GridCacheAdapter.peek0(boolean failFast, K key, Collection<GridCachePeekMode> modes, IgniteInternalTx<K,V> tx)
protected V	GridCacheAdapter.peek0(K key, Collection<GridCachePeekMode> modes, IgniteInternalTx<K,V> tx)
protected Map<K,V>	GridCacheAdapter.peekAll0(Collection<? extends K> keys, Collection<GridCachePeekMode> modes, IgniteInternalTx<K,V> tx, Collection<K> skipped)
V	GridCacheMapEntry.poke(V val) This method overwrites current in-memory value with new value.
V	GridCacheEntryEx.poke(V val) This method overwrites current in-memory value with new value.
protected void	GridCacheMessage.prepareFilter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filters, GridCacheSharedContext<K,V> ctx)
void	GridCacheMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridCacheEvictionRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridCacheEvictionResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
protected void	GridCacheMessage.prepareObject(Object o, GridCacheSharedContext<K,V> ctx)
protected void	GridCacheMessage.prepareObjects(Iterable<?> col, GridCacheSharedContext<K,V> ctx)
V	GridCacheProjectionImpl.promote(K key) This method promotes cache entry by given key, if any, from offheap or swap storage into memory.
V	CacheProjection.promote(K key) This method promotes cache entry by given key, if any, from offheap or swap storage into memory.
V	GridCacheProxyImpl.promote(K key) This method promotes cache entry by given key, if any, from offheap or swap storage into memory.
V	GridCacheAdapter.promote(K key) This method promotes cache entry by given key, if any, from offheap or swap storage into memory.
V	GridCacheAdapter.promote(K key, boolean deserializePortable)
void	GridCacheProjectionImpl.promoteAll(Collection<? extends K> keys) This method unswaps cache entries by given keys, if any, from swap storage into memory.
void	CacheProjection.promoteAll(Collection<? extends K> keys) This method unswaps cache entries by given keys, if any, from swap storage into memory.
void	GridCacheProxyImpl.promoteAll(Collection<? extends K> keys) This method unswaps cache entries by given keys, if any, from swap storage into memory.
void	GridCacheAdapter.promoteAll(Collection<? extends K> keys) This method unswaps cache entries by given keys, if any, from swap storage into memory.
V	GridCacheProjectionEx.put(K key, V val, GridCacheEntryEx<K,V> entry, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
V	GridCacheProjectionImpl.put(K key, V val, GridCacheEntryEx<K,V> entry, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
V	GridCacheProxyImpl.put(K key, V val, GridCacheEntryEx<K,V> entry, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
V	GridCacheAdapter.put(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Internal method that is called from GridCacheEntryImpl.
V	CacheProjection.put(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Stores given key-value pair in cache.
V	GridCacheAdapter.put(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Stores given key-value pair in cache.
V	GridCacheProjectionImpl.put(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
V	GridCacheProxyImpl.put(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
void	CacheProjection.putAll(Map<? extends K,? extends V> m, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Stores given key-value pairs in cache.
void	GridCacheProjectionImpl.putAll(Map<? extends K,? extends V> m, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pairs in cache.
void	GridCacheProxyImpl.putAll(Map<? extends K,? extends V> m, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pairs in cache.
void	GridCacheAdapter.putAll(Map<? extends K,? extends V> m, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pairs in cache.
void	GridCacheProjectionEx.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data.
void	GridCacheProjectionImpl.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data.
void	GridCacheProxyImpl.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data.
void	GridCacheAdapter.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data.
IgniteInternalFuture<?>	GridCacheProjectionEx.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data asynchronously.
IgniteInternalFuture<?>	GridCacheProjectionImpl.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data asynchronously.
IgniteInternalFuture<?>	GridCacheProxyImpl.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data asynchronously.
IgniteInternalFuture<?>	GridCacheAdapter.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data asynchronously.
boolean	GridCacheStoreManager.putAllToStore(IgniteInternalTx tx, Map<K,IgniteBiTuple<V,GridCacheVersion>> map) Puts key-value pair into storage.
V	GridCacheProjectionImpl.putIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
V	CacheProjection.putIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
V	GridCacheProxyImpl.putIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
V	GridCacheAdapter.putIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
boolean	GridCacheStoreManager.putToStore(IgniteInternalTx tx, K key, V val, GridCacheVersion ver) Puts key-value pair into storage.
boolean	GridCacheProjectionEx.putx(K key, V val, GridCacheEntryEx<K,V> entry, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridCacheProjectionImpl.putx(K key, V val, GridCacheEntryEx<K,V> entry, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridCacheProxyImpl.putx(K key, V val, GridCacheEntryEx<K,V> entry, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridCacheAdapter.putx(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	CacheProjection.putx(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Stores given key-value pair in cache.
boolean	GridCacheProjectionImpl.putx(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
boolean	GridCacheProxyImpl.putx(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
boolean	GridCacheAdapter.putx(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
boolean	GridCacheProjectionImpl.putxIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
boolean	CacheProjection.putxIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
boolean	GridCacheProxyImpl.putxIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
boolean	GridCacheAdapter.putxIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
V	GridCacheMapEntry.rawGetOrUnmarshal(boolean tmp)
V	GridCacheEntryEx.rawGetOrUnmarshal(boolean tmp)
V	GridCacheMapEntry.rawGetOrUnmarshalUnlocked(boolean tmp)
GridCloseableIterator<Map.Entry<byte[],byte[]>>	GridCacheSwapManager.rawIterator() Gets offheap and swap iterator over partition.
GridCloseableIterator<Map.Entry<byte[],byte[]>>	GridCacheSwapManager.rawSwapIterator()
GridCacheSwapEntry<V>	GridCacheSwapManager.read(K key, boolean readOffheap, boolean readSwap)
Collection<GridCacheBatchSwapEntry<K,V>>	GridCacheSwapManager.readAndRemove(Collection<? extends K> keys)
protected V	GridCacheMapEntry.readThrough(IgniteInternalTx<K,V> tx, K key, boolean reload, UUID subjId, String taskName)
void	GridCacheDeploymentManager.registerClass(Class<?> cls)
void	GridCacheDeploymentManager.registerClass(Class<?> cls, ClassLoader ldr)
void	GridCacheDeploymentManager.registerClass(Object obj)
void	GridCacheDeploymentManager.registerClasses(Iterable<?> objs) Register local classes.
void	GridCacheDeploymentManager.registerClasses(Object... objs) Register local classes.
protected void	GridCacheMapEntry.releaseSwap()
V	GridCacheProjectionImpl.reload(K key) Reloads a single key from persistent storage.
V	CacheProjection.reload(K key) Reloads a single key from persistent storage.
V	GridCacheProxyImpl.reload(K key) Reloads a single key from persistent storage.
V	GridCacheAdapter.reload(K key)
void	GridCacheProjectionImpl.reloadAll() Reloads all currently cached keys form persistent storage.
void	CacheProjection.reloadAll() Reloads all currently cached keys form persistent storage.
void	GridCacheProxyImpl.reloadAll() Reloads all currently cached keys form persistent storage.
void	GridCacheAdapter.reloadAll() Reloads all currently cached keys form persistent storage.
void	GridCacheProjectionImpl.reloadAll(Collection<? extends K> keys) Reloads specified entries from underlying persistent storage.
void	CacheProjection.reloadAll(Collection<? extends K> keys) Reloads specified entries from underlying persistent storage.
void	GridCacheProxyImpl.reloadAll(Collection<? extends K> keys) Reloads specified entries from underlying persistent storage.
void	GridCacheAdapter.reloadAll(Collection<? extends K> keys) Reloads specified entries from underlying persistent storage.
Map<K,V>	GridCacheAdapter.reloadAll(Collection<? extends K> keys, boolean ret, boolean skipVals)
void	GridCacheSwapManager.remove(K key, byte[] keyBytes)
V	GridCacheProjectionEx.remove(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
V	GridCacheProjectionImpl.remove(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
V	GridCacheProxyImpl.remove(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
V	GridCacheAdapter.remove(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
V	CacheProjection.remove(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mapping from cache.
V	GridCacheProjectionImpl.remove(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Removes given key mapping from cache.
V	GridCacheProxyImpl.remove(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Removes given key mapping from cache.
V	GridCacheAdapter.remove(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Removes given key mapping from cache.
boolean	GridCacheProjectionImpl.remove(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
boolean	CacheProjection.remove(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
boolean	GridCacheProxyImpl.remove(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
boolean	GridCacheAdapter.remove(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
void	GridCacheProjectionImpl.removeAll() Removes mappings from cache for entries for which the optionally passed in filters do pass.
void	CacheProjection.removeAll() Removes mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheProxyImpl.removeAll() Removes mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheProjectionImpl.removeAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	CacheProjection.removeAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheAdapter.removeAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheProxyImpl.removeAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridCacheProjectionEx.removeAllDr(Map<? extends K,GridCacheVersion> drMap) Removes DR data.
void	GridCacheProjectionImpl.removeAllDr(Map<? extends K,GridCacheVersion> drMap) Removes DR data.
void	GridCacheProxyImpl.removeAllDr(Map<? extends K,GridCacheVersion> drMap) Removes DR data.
void	GridCacheAdapter.removeAllDr(Map<? extends K,GridCacheVersion> drMap) Removes DR data.
IgniteInternalFuture<?>	GridCacheProjectionEx.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) Removes DR data asynchronously.
IgniteInternalFuture<?>	GridCacheProjectionImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) Removes DR data asynchronously.
IgniteInternalFuture<?>	GridCacheProxyImpl.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) Removes DR data asynchronously.
IgniteInternalFuture<?>	GridCacheAdapter.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) Removes DR data asynchronously.
boolean	GridCacheStoreManager.removeAllFromStore(IgniteInternalTx tx, Collection<?> keys)
boolean	GridCacheStoreManager.removeFromStore(IgniteInternalTx tx, K key)
void	CacheWeakQueryIteratorsHolder.removeIterator(CacheWeakQueryIteratorsHolder.WeakQueryFutureIterator it)
boolean	GridCacheProjectionEx.removex(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridCacheProjectionImpl.removex(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridCacheProxyImpl.removex(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridCacheAdapter.removex(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	CacheProjection.removex(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mapping from cache.
boolean	GridCacheAdapter.removex(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mapping from cache.
boolean	GridCacheProjectionImpl.removex(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Removes given key mapping from cache.
boolean	GridCacheProxyImpl.removex(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Removes given key mapping from cache.
GridCacheReturn<V>	GridCacheProjectionEx.removex(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
GridCacheReturn<V>	GridCacheProjectionImpl.removex(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
GridCacheReturn<V>	GridCacheProxyImpl.removex(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
GridCacheReturn<V>	GridCacheAdapter.removex(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
V	GridCacheProjectionImpl.replace(K key, V val) Stores given key-value pair in cache only if there is a previous mapping for it.
V	CacheProjection.replace(K key, V val) Stores given key-value pair in cache only if there is a previous mapping for it.
V	GridCacheProxyImpl.replace(K key, V val) Stores given key-value pair in cache only if there is a previous mapping for it.
V	GridCacheAdapter.replace(K key, V val) Stores given key-value pair in cache only if there is a previous mapping for it.
boolean	GridCacheProjectionImpl.replace(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	CacheProjection.replace(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	GridCacheProxyImpl.replace(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	GridCacheAdapter.replace(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	GridCacheProjectionImpl.replacex(K key, V val) Stores given key-value pair in cache only if only if there is a previous mapping for it.
boolean	CacheProjection.replacex(K key, V val) Stores given key-value pair in cache only if only if there is a previous mapping for it.
boolean	GridCacheProxyImpl.replacex(K key, V val) Stores given key-value pair in cache only if only if there is a previous mapping for it.
boolean	GridCacheAdapter.replacex(K key, V val) Stores given key-value pair in cache only if only if there is a previous mapping for it.
GridCacheReturn<V>	GridCacheProjectionEx.replacex(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
GridCacheReturn<V>	GridCacheProjectionImpl.replacex(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
GridCacheReturn<V>	GridCacheProxyImpl.replacex(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
GridCacheReturn<V>	GridCacheAdapter.replacex(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
IgniteInternalFuture	GridCacheSharedContext.rollbackTxAsync(IgniteInternalTx<K,V> tx)
boolean	GridCacheIoManager.safeSend(Collection<? extends ClusterNode> nodes, GridCacheMessage<K,V> msg, GridIoPolicy plc, IgnitePredicate<ClusterNode> fallback) Sends message and automatically accounts for lefts nodes.
protected V	GridCacheMapEntry.saveValueForIndexUnlocked() This method will return current value only if clearIndex(V) will require previous value (this is the case for Mongo caches).
void	GridCacheIoManager.send(ClusterNode node, GridCacheMessage<K,V> msg, GridIoPolicy plc) Sends communication message.
void	GridCacheIoManager.send(UUID nodeId, GridCacheMessage<K,V> msg, GridIoPolicy plc) Sends communication message.
void	GridCacheIoManager.sendOrderedMessage(ClusterNode node, Object topic, GridCacheMessage<K,V> msg, GridIoPolicy plc, long timeout)
int	GridCacheProjectionImpl.size(CachePeekMode[] peekModes)
int	CacheProjection.size(CachePeekMode[] peekModes)
int	GridCacheProxyImpl.size(CachePeekMode[] peekModes)
int	GridCacheAdapter.size(CachePeekMode[] peekModes)
void	GridCachePreloader.start() Starts preloading.
void	GridCachePreloaderAdapter.start() Starts preloading.
void	GridCacheAdapter.start() Starts this cache.
void	GridCacheProcessor.start() Starts grid component.
void	GridCacheManagerAdapter.start(GridCacheContext<K,V> cctx) Starts manager.
void	GridCacheManager.start(GridCacheContext<K,V> cctx) Starts manager.
void	GridCacheSharedManagerAdapter.start(GridCacheSharedContext<K,V> cctx) Starts manager.
void	GridCacheSharedManager.start(GridCacheSharedContext<K,V> cctx) Starts manager.
void	GridCacheIoManager.start0()
void	GridCacheSwapManager.start0()
protected void	GridCacheManagerAdapter.start0()
protected void	GridCachePartitionExchangeManager.start0()
protected void	GridCacheSharedManagerAdapter.start0()
protected void	GridCacheTtlManager.start0()
void	GridCacheDeploymentManager.start0()
void	GridCacheAffinityManager.start0()
void	GridCacheEvictionManager.start0()
protected void	GridCacheStoreManager.start0()
protected void	GridCacheMvccManager.start0()
void	GridCacheProcessor.stop(boolean cancel) Stops grid component.
int	GridCacheSwapManager.swapEntriesCount(boolean primary, boolean backup, long topVer)
Iterator<Map.Entry<K,V>>	GridCacheProxyImpl.swapIterator() Gets iterator over keys and values belonging to this cache swap space on local node.
Iterator<Map.Entry<K,V>>	GridCacheAdapter.swapIterator() Gets iterator over keys and values belonging to this cache swap space on local node.
Iterator<javax.cache.Cache.Entry<K,V>>	GridCacheSwapManager.swapIterator(boolean primary, boolean backup, long topVer)
GridCloseableIterator<Map.Entry<byte[],GridCacheSwapEntry<V>>>	GridCacheSwapManager.swapIterator(int part, boolean unmarshal) Gets swap space iterator over partition.
long	GridCacheSwapManager.swapKeys() Gets number of swap entries (keys).
long	GridCacheProxyImpl.swapKeys() Gets number of swap entries (keys).
long	GridCacheAdapter.swapKeys() Gets number of swap entries (keys).
long	GridCacheSwapManager.swapSize()
long	GridCacheProxyImpl.swapSize() Gets size in bytes for swap space.
long	GridCacheAdapter.swapSize() Gets size in bytes for swap space.
void	GridCacheStoreManager.txEnd(IgniteInternalTx tx, boolean commit)
void	CacheProjection.unlock(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Unlocks given key only if current thread owns the lock.
void	GridCacheAdapter.unlock(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Unlocks given key only if current thread owns the lock.
void	GridCacheProjectionImpl.unlock(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Unlocks given key only if current thread owns the lock.
void	GridCacheProxyImpl.unlock(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Unlocks given key only if current thread owns the lock.
void	CacheProjection.unlockAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Unlocks given keys only if current thread owns the locks.
void	GridCacheProjectionImpl.unlockAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Unlocks given keys only if current thread owns the locks.
void	GridCacheProxyImpl.unlockAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Unlocks given keys only if current thread owns the locks.
void	GridCacheEntryInfo.unmarshal(GridCacheContext<K,V> ctx, ClassLoader clsLdr) Unmarshalls entry.
protected <K1> LinkedHashMap<K1,Boolean>	GridCacheMessage.unmarshalBooleanLinkedMap(Map<byte[],Boolean> byteMap, GridCacheSharedContext<K,V> ctx, ClassLoader ldr)
protected <T> List<T>	GridCacheMessage.unmarshalCollection(Collection<byte[]> byteCol, GridCacheSharedContext<K,V> ctx, ClassLoader ldr)
protected <T> IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]	GridCacheMessage.unmarshalFilter(byte[][] byteCol, GridCacheSharedContext<K,V> ctx, ClassLoader ldr)
protected void	GridCacheMessage.unmarshalInfo(GridCacheEntryInfo<K,V> info, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected void	GridCacheMessage.unmarshalInfos(Iterable<? extends GridCacheEntryInfo<K,V>> infos, GridCacheContext<K,V> ctx, ClassLoader ldr)
protected Object[]	GridCacheMessage.unmarshalInvokeArguments(byte[][] byteCol, GridCacheSharedContext<K,V> ctx, ClassLoader ldr)
protected void	GridCacheMessage.unmarshalTx(Iterable<IgniteTxEntry<K,V>> txEntries, boolean near, GridCacheSharedContext<K,V> ctx, ClassLoader ldr)
void	GridCacheEntryInfo.unmarshalValue(GridCacheContext<K,V> ctx, ClassLoader ldr)
protected <T> List<T>	GridCacheMessage.unmarshalValueBytesCollection(Collection<GridCacheValueBytes> byteCol, GridCacheSharedContext<K,V> ctx, ClassLoader ldr)
V	GridCacheMapEntry.unswap()
V	GridCacheEntryEx.unswap()
V	GridCacheMapEntry.unswap(boolean ignoreFlags, boolean needVal) Unswaps an entry.
V	GridCacheEntryEx.unswap(boolean ignoreFlags, boolean needVal) Unswap ignoring flags.
protected void	GridCacheMapEntry.updateIndex(V val, byte[] valBytes, long expireTime, GridCacheVersion ver, V prevVal) Updates cache index.
GridCacheValueBytes	GridCacheMapEntry.valueBytes(GridCacheVersion ver) Gets cached serialized value bytes.
GridCacheValueBytes	GridCacheEntryEx.valueBytes(GridCacheVersion ver) Gets cached serialized value bytes.
GridCacheVersionedEntryEx<K,V>	GridCacheMapEntry.versionedEntry() Create versioned entry for this cache entry.
GridCacheVersionedEntryEx<K,V>	GridCacheEntryEx.versionedEntry() Create versioned entry for this cache entry.
boolean	GridCacheMapEntry.versionedValue(V val, GridCacheVersion curVer, GridCacheVersion newVer) Sets new value if passed in version matches the current version (used for read-through only).
boolean	GridCacheEntryEx.versionedValue(V val, GridCacheVersion curVer, GridCacheVersion newVer) Sets new value if passed in version matches the current version (used for read-through only).
javax.cache.Cache.Entry<K,V>	GridCacheMapEntry.wrapFilterLocked() Wraps this map entry into cache entry for filter evaluation inside entry lock.
javax.cache.Cache.Entry<K,V>	GridCacheEntryEx.wrapFilterLocked() Wraps this map entry into cache entry for filter evaluation inside entry lock.

Constructors in org.apache.ignite.internal.processors.cache that throw IgniteCheckedException

Constructor and Description
GridCacheStoreManager(GridKernalContext ctx, Map<CacheStore,ThreadLocal> sesHolders, CacheStore<K,Object> cfgStore, CacheConfiguration cfg)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.datastructures

Methods in org.apache.ignite.internal.processors.cache.datastructures that throw IgniteCheckedException

Modifier and Type	Method and Description
protected void	CacheDataStructuresManager.onKernalStart0()
<T> GridCacheQueueProxy<T>	CacheDataStructuresManager.queue(String name, int cap, boolean colloc, boolean create)
<T> GridCacheQueueProxy<T>	CacheDataStructuresManager.queue0(String name, int cap, boolean colloc, boolean create)
void	CacheDataStructuresManager.removeSetData(IgniteUuid id)
<T> IgniteSet<T>	CacheDataStructuresManager.set(String name, boolean colloc, boolean create)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.distributed

Methods in org.apache.ignite.internal.processors.cache.distributed that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridDistributedUnlockRequest.addKey(K key, byte[] bytes, GridCacheContext<K,V> ctx)
void	GridDistributedLockRequest.addKeyBytes(K key, byte[] keyBytes, boolean retVal, Collection<GridCacheMvccCandidate<K>> cands, GridCacheContext<K,V> ctx) Adds a key.
void	GridDistributedLockResponse.addValueBytes(V val, byte[] valBytes, GridCacheContext<K,V> ctx)
void	GridDistributedTxRemoteAdapter.commit() Commits this transaction by initiating two-phase-commit process.
void	GridDistributedLockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDistributedBaseMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDistributedTxFinishRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDistributedUnlockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridCacheTtlUpdateRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDistributedTxPrepareRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDistributedLockResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDistributedTxPrepareResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDistributedTxRemoteAdapter.forceCommit() Forces commit for this tx.
void	GridDistributedTxRemoteAdapter.prepare() Prepare phase.
void	GridDistributedLockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDistributedBaseMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDistributedTxFinishRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDistributedUnlockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDistributedTxPrepareRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDistributedLockResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDistributedTxPrepareResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDistributedCacheAdapter.removeAll() Removes mappings from cache for entries for which the optionally passed in filters do pass.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.distributed.dht

Methods in org.apache.ignite.internal.processors.cache.distributed.dht that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridDhtLockRequest.addDhtKey(K key, byte[] keyBytes, boolean invalidateEntry, GridCacheContext<K,V> ctx) Adds a DHT key.
IgniteInternalFuture<Boolean>	GridDhtTxLocalAdapter.addEntry(long msgId, IgniteTxEntry<K,V> e)
void	GridDhtLockRequest.addNearKey(K key, byte[] keyBytes, GridCacheSharedContext<K,V> ctx) Adds a Near key.
void	GridDhtUnlockRequest.addNearKey(K key, byte[] keyBytes, GridCacheSharedContext<K,V> ctx) Adds a Near key.
void	GridDhtTxRemote.addWrite(IgniteTxEntry<K,V> entry, ClassLoader ldr)
boolean	GridDhtPartitionTopology.afterExchange(GridDhtPartitionExchangeId exchId) Post-initializes this topology.
boolean	GridClientPartitionTopology.afterExchange(GridDhtPartitionExchangeId exchId) Post-initializes this topology.
void	GridDhtPartitionTopology.beforeExchange(GridDhtPartitionExchangeId exchId) Pre-initializes this topology.
long	GridDhtCacheAdapter.beginMultiUpdate() Starts multi-update lock.
boolean	GridDhtCacheEntry.clearInternal(GridCacheVersion ver, boolean swap) Marks entry as obsolete and, if possible or required, removes it from swap storage.
void	GridDhtCacheAdapter.endMultiUpdate() Ends multi-update lock.
boolean	GridDhtTxLocal.finish(boolean commit) Finishes transaction (either commit or rollback).
boolean	GridDhtTxLocalAdapter.finish(boolean commit) Finishes transaction (either commit or rollback).
void	GridDhtAffinityAssignmentResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtTxPrepareResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtTxPrepareRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtLockResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtLockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtUnlockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtCacheAdapter.loadCache(IgniteBiPredicate<K,V> p, long ttl, Object[] args) Delegates to CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method to load state from the underlying persistent storage.
void	GridDhtCacheAdapter.localLoad(Collection<? extends K> keys, javax.cache.expiry.ExpiryPolicy plc)
int	GridDhtCacheEntry.memorySize()
void	GridDhtLocalPartition.onDeferredDelete(K key, GridCacheVersion ver)
void	GridDhtCacheAdapter.onKernalStart() Kernal start callback.
void	GridDhtAffinityAssignmentResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx)
void	GridDhtTxPrepareResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtTxPrepareRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtLockResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtLockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
V	GridDhtCacheAdapter.reload(K key) Reloads a single key from persistent storage.
void	GridDhtTxLocalAdapter.rollback() Rolls back this transaction.
void	GridDhtCacheAdapter.start() Starts this cache.
void	GridDhtTransactionalCacheAdapter.start() Starts this cache.
void	GridDhtCache.start() Starts this cache.
GridDiscoveryTopologySnapshot	GridDhtTopologyFuture.topologySnapshot() Gets a topology snapshot for the topology version represented by the future.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.distributed.dht.atomic

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic that return IgniteCheckedException

Modifier and Type	Method and Description
IgniteCheckedException	GridDhtAtomicUpdateResponse.error()

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.atomic that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridNearAtomicUpdateResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtAtomicUpdateResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridNearAtomicUpdateRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtAtomicUpdateRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
<T> javax.cache.processor.EntryProcessorResult<T>	GridDhtAtomicCache.invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridDhtAtomicCache.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridDhtAtomicCache.invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
V	GridDhtAtomicCache.peek(K key, Collection<GridCachePeekMode> modes) Peeks at cached value using optional set of peek modes.
void	GridNearAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtAtomicUpdateResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridNearAtomicUpdateRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtAtomicUpdateRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
V	GridDhtAtomicCache.put(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Internal method that is called from GridCacheEntryImpl.
void	GridDhtAtomicCache.putAll(Map<? extends K,? extends V> m, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pairs in cache.
void	GridDhtAtomicCache.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data.
V	GridDhtAtomicCache.putIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
boolean	GridDhtAtomicCache.putx(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridDhtAtomicCache.putx(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
boolean	GridDhtAtomicCache.putxIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
V	GridDhtAtomicCache.remove(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridDhtAtomicCache.remove(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
void	GridDhtAtomicCache.removeAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridDhtAtomicCache.removeAllDr(Map<? extends K,GridCacheVersion> drMap) Removes DR data.
boolean	GridDhtAtomicCache.removex(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
GridCacheReturn<V>	GridDhtAtomicCache.removex(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
V	GridDhtAtomicCache.replace(K key, V val) Stores given key-value pair in cache only if there is a previous mapping for it.
boolean	GridDhtAtomicCache.replace(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	GridDhtAtomicCache.replacex(K key, V val) Stores given key-value pair in cache only if only if there is a previous mapping for it.
GridCacheReturn<V>	GridDhtAtomicCache.replacex(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
void	GridDhtAtomicCache.start() Starts this cache.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.distributed.dht.colocated

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.colocated that throw IgniteCheckedException

Modifier and Type	Method and Description
protected void	GridDhtDetachedCacheEntry.clearIndex(V val) Clears index.
V	GridDhtColocatedCache.peek(K key, Collection<GridCachePeekMode> modes) Peeks at cached value using optional set of peek modes.
void	GridDhtDetachedCacheEntry.resetFromPrimary(V val, byte[] valBytes, GridCacheVersion ver) Sets value to detached entry so it can be retrieved in transactional gets.
void	GridDhtColocatedCache.start() Starts this cache.
V	GridDhtDetachedCacheEntry.unswap(boolean ignoreFlags, boolean needVal) Unswaps an entry.
protected void	GridDhtDetachedCacheEntry.updateIndex(V val, byte[] valBytes, long expireTime, GridCacheVersion ver, V old) Updates cache index.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.distributed.dht.preloader

Methods in org.apache.ignite.internal.processors.cache.distributed.dht.preloader that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridDhtPartitionDemandMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtPartitionsSingleMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtForceKeysRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtForceKeysResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtPartitionSupplyMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtPartitionsFullMessage.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridDhtPreloader.onKernalStart() Kernal start callback.
void	GridDhtPartitionDemandMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtPartitionsSingleMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtForceKeysRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtForceKeysResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtPartitionSupplyMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridDhtPartitionsFullMessage.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
GridDiscoveryTopologySnapshot	GridDhtPartitionsExchangeFuture.topologySnapshot() Gets a topology snapshot for the topology version represented by the future.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.distributed.near

Methods in org.apache.ignite.internal.processors.cache.distributed.near that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridNearTxRemote.addEntries(ClassLoader ldr, Iterable<IgniteTxEntry<K,V>> entries) Adds entries to started near remote tx.
boolean	GridNearTxRemote.addEntry(GridCacheContext<K,V> cacheCtx, IgniteTxKey<K> key, byte[] keyBytes, GridCacheOperation op, V val, byte[] valBytes, GridCacheVersion drVer)
void	GridNearLockRequest.addKeyBytes(K key, byte[] keyBytes, boolean retVal, GridCacheVersion dhtVer, GridCacheContext<K,V> ctx) Adds a key.
void	GridNearLockResponse.addValueBytes(V val, byte[] valBytes, boolean filterPassed, GridCacheVersion dhtVer, GridCacheVersion mappedVer, GridCacheContext<K,V> ctx)
void	GridNearTxLocal.close() Ends the transaction.
boolean	GridNearCacheAdapter.compact(K key, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter)
void	GridNearLockRequest.filter(IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, GridCacheContext<K,V> ctx)
boolean	GridNearTxLocal.finish(boolean commit) Finishes transaction (either commit or rollback).
void	GridNearTxPrepareResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridNearLockRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridNearGetResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridNearTxFinishResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridNearGetRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr)
<T> javax.cache.processor.EntryProcessorResult<T>	GridNearAtomicCache.invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridNearAtomicCache.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridNearAtomicCache.invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
void	GridNearCacheAdapter.loadCache(IgniteBiPredicate<K,V> p, long ttl, Object[] args) Delegates to CacheStore.loadCache(org.apache.ignite.lang.IgniteBiInClosure,Object...) method to load state from the underlying persistent storage.
boolean	GridNearCacheEntry.loadedValue(IgniteInternalTx tx, UUID primaryNodeId, V val, byte[] valBytes, GridCacheVersion ver, GridCacheVersion dhtVer, GridCacheVersion expVer, long ttl, long expireTime, boolean evt, long topVer, UUID subjId)
void	GridNearCacheAdapter.localLoad(Collection<? extends K> keys, javax.cache.expiry.ExpiryPolicy plc)
int	GridNearCacheEntry.memorySize()
Iterator<Map.Entry<K,V>>	GridNearCacheAdapter.offHeapIterator() Gets iterator over keys and values belonging to this cache off-heap memory on local node.
V	GridNearCacheAdapter.peek(K key, Collection<GridCachePeekMode> modes) Peeks at cached value using optional set of peek modes.
void	GridNearTxPrepareResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridNearLockRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridNearGetResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridNearTxFinishResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridNearGetRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx)
V	GridNearCacheAdapter.promote(K key) This method promotes cache entry by given key, if any, from offheap or swap storage into memory.
V	GridNearCacheAdapter.promote(K key, boolean deserializePortable)
void	GridNearCacheAdapter.promoteAll(Collection<? extends K> keys) This method unswaps cache entries by given keys, if any, from swap storage into memory.
V	GridNearAtomicCache.put(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Internal method that is called from GridCacheEntryImpl.
void	GridNearAtomicCache.putAll(Map<? extends K,? extends V> m, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pairs in cache.
void	GridNearAtomicCache.putAllDr(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data.
IgniteInternalFuture<?>	GridNearAtomicCache.putAllDrAsync(Map<? extends K,GridCacheDrInfo<V>> drMap) Store DR data asynchronously.
V	GridNearAtomicCache.putIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
boolean	GridNearAtomicCache.putx(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridNearAtomicCache.putx(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
boolean	GridNearAtomicCache.putxIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
protected V	GridNearCacheEntry.readThrough(IgniteInternalTx<K,V> tx, K key, boolean reload, UUID subjId, String taskName)
V	GridNearCacheAdapter.reload(K key) Reloads a single key from persistent storage.
void	GridNearCacheAdapter.reloadAll() Reloads all currently cached keys form persistent storage.
void	GridNearCacheAdapter.reloadAll(Collection<? extends K> keys) Reloads specified entries from underlying persistent storage.
V	GridNearAtomicCache.remove(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridNearAtomicCache.remove(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
void	GridNearAtomicCache.removeAll() Removes mappings from cache for entries for which the optionally passed in filters do pass.
void	GridNearAtomicCache.removeAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
void	GridNearAtomicCache.removeAllDr(Map<? extends K,GridCacheVersion> drMap) Removes DR data.
IgniteInternalFuture<?>	GridNearAtomicCache.removeAllDrAsync(Map<? extends K,GridCacheVersion> drMap) Removes DR data asynchronously.
boolean	GridNearAtomicCache.removex(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
GridCacheReturn<V>	GridNearAtomicCache.removex(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
V	GridNearAtomicCache.replace(K key, V val) Stores given key-value pair in cache only if there is a previous mapping for it.
boolean	GridNearAtomicCache.replace(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	GridNearAtomicCache.replacex(K key, V val) Stores given key-value pair in cache only if only if there is a previous mapping for it.
GridCacheReturn<V>	GridNearAtomicCache.replacex(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	GridNearCacheEntry.resetFromPrimary(V val, byte[] valBytes, GridCacheVersion ver, GridCacheVersion dhtVer, UUID primaryNodeId) This method should be called only when lock is owned on this entry.
void	GridNearTransactionalCache.start() Starts this cache.
void	GridNearAtomicCache.start() Starts this cache.
GridNearTxRemote<K,V>	GridNearTransactionalCache.startRemoteTx(UUID nodeId, GridDhtLockRequest<K,V> req)
Iterator<Map.Entry<K,V>>	GridNearCacheAdapter.swapIterator() Gets iterator over keys and values belonging to this cache swap space on local node.
long	GridNearCacheAdapter.swapKeys() Gets number of swap entries (keys).
long	GridNearCacheAdapter.swapSize() Gets size in bytes for swap space.
void	GridNearAtomicCache.unlockAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Unlocks given keys only if current thread owns the locks.
protected void	GridNearCacheEntry.updateIndex(V val, byte[] valBytes, long expireTime, GridCacheVersion ver, V old) Updates cache index.

Constructors in org.apache.ignite.internal.processors.cache.distributed.near that throw IgniteCheckedException

Constructor and Description

GridNearTxRemote(GridCacheSharedContext<K,V> ctx, ClassLoader ldr, UUID nodeId, UUID nearNodeId, long rmtThreadId, GridCacheVersion xidVer, GridCacheVersion commitVer, boolean sys, TransactionConcurrency concurrency, TransactionIsolation isolation, boolean invalidate, long timeout, Collection<IgniteTxEntry<K,V>> writeEntries, int txSize, IgniteTxKey grpLockKey, UUID subjId, int taskNameHash) This constructor is meant for optimistic transactions.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.dr

Methods in org.apache.ignite.internal.processors.cache.dr that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridCacheDrManager.beforeExchange(long topVer, boolean left) Process partitions "before exchange" event.
void	GridCacheDrManager.replicate(K key, byte[] keyBytes, V val, byte[] valBytes, long ttl, long expireTime, GridCacheVersion ver, GridDrType drType) Performs replication.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.dr.os

Methods in org.apache.ignite.internal.processors.cache.dr.os that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridOsCacheDrManager.beforeExchange(long topVer, boolean left) Process partitions "before exchange" event.
void	GridOsCacheDrManager.onKernalStart()
void	GridOsCacheDrManager.start(GridCacheContext<K,V> cctx) Starts manager.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.jta

Methods in org.apache.ignite.internal.processors.cache.jta that throw IgniteCheckedException

Modifier and Type	Method and Description
abstract void	CacheJtaManagerAdapter.checkJta() Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
void	CacheNoopJtaManager.checkJta() Checks if cache is working in JTA transaction and enlist cache as XAResource if necessary.
abstract void	CacheJtaManagerAdapter.createTmLookup(CacheConfiguration ccfg) Creates transaction manager finder.
void	CacheNoopJtaManager.createTmLookup(CacheConfiguration ccfg) Creates transaction manager finder.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.local

Methods in org.apache.ignite.internal.processors.cache.local that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridLocalCache.removeAll() Removes mappings from cache for entries for which the optionally passed in filters do pass.
void	GridLocalCache.unlockAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Unlocks given keys only if current thread owns the locks.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.local.atomic

Methods in org.apache.ignite.internal.processors.cache.local.atomic that throw IgniteCheckedException

Modifier and Type	Method and Description
V	GridLocalAtomicCache.get(K key, boolean deserializePortable)
Map<K,V>	GridLocalAtomicCache.getAll(Collection<? extends K> keys, boolean deserializePortable)
<T> javax.cache.processor.EntryProcessorResult<T>	GridLocalAtomicCache.invoke(K key, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridLocalAtomicCache.invokeAll(Map<? extends K,? extends javax.cache.processor.EntryProcessor<K,V,T>> map, Object... args)
<T> Map<K,javax.cache.processor.EntryProcessorResult<T>>	GridLocalAtomicCache.invokeAll(Set<? extends K> keys, javax.cache.processor.EntryProcessor<K,V,T> entryProcessor, Object... args)
V	GridLocalAtomicCache.put(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Internal method that is called from GridCacheEntryImpl.
void	GridLocalAtomicCache.putAll(Map<? extends K,? extends V> m, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pairs in cache.
V	GridLocalAtomicCache.putIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
boolean	GridLocalAtomicCache.putx(K key, V val, GridCacheEntryEx<K,V> cached, long ttl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridLocalAtomicCache.putx(K key, V val, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) Stores given key-value pair in cache.
boolean	GridLocalAtomicCache.putxIfAbsent(K key, V val) Stores given key-value pair in cache only if cache had no previous mapping for it.
V	GridLocalAtomicCache.remove(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
boolean	GridLocalAtomicCache.remove(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
void	GridLocalAtomicCache.removeAll() Removes mappings from cache for entries for which the optionally passed in filters do pass.
void	GridLocalAtomicCache.removeAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Removes given key mappings from cache for entries for which the optionally passed in filters do pass.
boolean	GridLocalAtomicCache.removex(K key, GridCacheEntryEx<K,V> entry, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Internal method that is called from GridCacheEntryImpl.
GridCacheReturn<V>	GridLocalAtomicCache.removex(K key, V val) Removes given key mapping from cache if one exists and value is equal to the passed in value.
V	GridLocalAtomicCache.replace(K key, V val) Stores given key-value pair in cache only if there is a previous mapping for it.
boolean	GridLocalAtomicCache.replace(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
boolean	GridLocalAtomicCache.replacex(K key, V val) Stores given key-value pair in cache only if only if there is a previous mapping for it.
GridCacheReturn<V>	GridLocalAtomicCache.replacex(K key, V oldVal, V newVal) Stores given key-value pair in cache only if only if the previous value is equal to the 'oldVal' passed in.
void	GridLocalAtomicCache.start() Starts this cache.
void	GridLocalAtomicCache.unlockAll(Collection<? extends K> keys, IgnitePredicate<javax.cache.Cache.Entry<K,V>>... filter) Unlocks given keys only if current thread owns the locks.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.query

Methods in org.apache.ignite.internal.processors.cache.query that throw IgniteCheckedException

Modifier and Type	Method and Description
int	CacheQueryFuture.available() Returns number of elements that are already fetched and can be returned from CacheQueryFuture.next() method without blocking.
int	GridCacheQueryErrorFuture.available() Returns number of elements that are already fetched and can be returned from CacheQueryFuture.next() method without blocking.
boolean	CacheQueryFuture.cancel() Cancels this query future and stop receiving any further results for the query associated with this future.
boolean	GridCacheQueryFutureAdapter.cancel() Default no-op implementation that always returns false.
protected void	GridCacheLocalQueryFuture.cancelQuery()
protected abstract void	GridCacheQueryFutureAdapter.cancelQuery()
protected void	GridCacheDistributedQueryFuture.cancelQuery()
void	GridCacheQueryResponse.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
void	GridCacheQueryRequest.finishUnmarshal(GridCacheSharedContext<K,V> ctx, ClassLoader ldr) This method is called after the message is deserialized and is responsible for unmarshalling state marshalled in GridCacheMessage.prepareMarshal(GridCacheSharedContext) method.
Collection<R>	GridCacheQueryFutureAdapter.get() Synchronously waits for completion of the computation and returns computation result.
Collection<R>	GridCacheQueryFutureAdapter.get(long timeout, TimeUnit unit) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
T	CacheQueryFuture.next() Returns next element from result set.
T	GridCacheQueryErrorFuture.next() Returns next element from result set.
Collection<R>	GridCacheQueryFutureAdapter.nextPage() Returns next page for the query.
Collection<R>	GridCacheQueryFutureAdapter.nextPage(long timeout) Returns next page for the query.
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.
void	GridCacheQueryResponse.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridCacheQueryRequest.prepareMarshal(GridCacheSharedContext<K,V> ctx) This method is called before the whole message is serialized and is responsible for pre-marshalling state.
void	GridCacheQueryManager.remove(K key, byte[] keyBytes)
long	GridCacheQueryManager.size(Class<?> valType) Gets number of objects of given type in index.
Collection<GridCacheSqlMetadata>	GridCacheQueryManager.sqlMetadata() Gets SQL metadata.
Collection<GridCacheSqlMetadata>	GridCacheQueriesImpl.sqlMetadata() Gets SQL metadata.
Collection<GridCacheSqlMetadata>	GridCacheQueriesProxy.sqlMetadata() Gets SQL metadata.
Collection<GridCacheSqlMetadata>	GridCacheQueriesEx.sqlMetadata() Gets SQL metadata.
void	GridCacheLocalQueryManager.start0()
void	GridCacheQueryManager.start0()
void	GridCacheDistributedQueryManager.start0()
void	GridCacheQueryManager.store(K key, byte[] keyBytes, V val, byte[] valBytes, GridCacheVersion ver, long expirationTime) Writes key-value pair to index.
void	GridCacheQueryAdapter.validate()

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.query.continuous

Methods in org.apache.ignite.internal.processors.cache.query.continuous that throw IgniteCheckedException

Modifier and Type	Method and Description
void	CacheContinuousQueryManager.cancelJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg)
UUID	CacheContinuousQueryManager.executeInternalQuery(javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr, javax.cache.event.CacheEntryEventFilter<K,V> rmtFilter, boolean loc, boolean notifyExisting)
void	CacheContinuousQueryManager.executeJCacheQuery(javax.cache.configuration.CacheEntryListenerConfiguration<K,V> cfg, boolean onStart)
UUID	CacheContinuousQueryManager.executeQuery(javax.cache.event.CacheEntryUpdatedListener<K,V> locLsnr, javax.cache.event.CacheEntryEventFilter<K,V> rmtFilter, int bufSize, long timeInterval, boolean autoUnsubscribe, ClusterGroup grp)
void	CacheContinuousQueryManager.onEntryExpired(GridCacheEntryEx<K,V> e, K key, V oldVal, GridCacheValueBytes oldBytes)
void	CacheContinuousQueryManager.onEntryUpdated(GridCacheEntryEx<K,V> e, K key, V newVal, GridCacheValueBytes newBytes, V oldVal, GridCacheValueBytes oldBytes, boolean preload)
protected void	CacheContinuousQueryManager.onKernalStart0()
protected void	CacheContinuousQueryManager.start0()

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.transactions

Methods in org.apache.ignite.internal.processors.cache.transactions that throw IgniteCheckedException

Modifier and Type	Method and Description
protected void	IgniteTxLocalAdapter.addActiveCache(GridCacheContext<K,V> cacheCtx) Adds cache to the list of active caches in transaction.
protected GridTuple3<GridCacheOperation,V,byte[]>	IgniteTxAdapter.applyTransformClosures(IgniteTxEntry<K,V> txEntry, boolean metrics)
protected void	IgniteTxAdapter.awaitCompletion() Awaits transaction completion.
protected void	IgniteTxLocalAdapter.batchStoreCommit(Iterable<IgniteTxEntry<K,V>> writeEntries) Performs batch database operations.
protected void	IgniteTxLocalAdapter.checkValid() Checks transaction expiration.
void	IgniteTxAdapter.close()
void	IgniteInternalTx.close() Ends the transaction.
void	IgniteInternalTx.commit() Commits this transaction by initiating two-phase-commit process.
void	IgniteTxLocalAdapter.commit() Commits this transaction by initiating two-phase-commit process.
protected IgniteBiTuple<GridCacheOperation,GridCacheVersionConflictContext<K,V>>	IgniteTxAdapter.conflictResolve(GridCacheOperation op, K key, V newVal, byte[] newValBytes, long newTtl, long newDrExpireTime, GridCacheVersion newVer, GridCacheEntryEx<K,V> old) Resolve DR conflict.
protected boolean	IgniteTxAdapter.evictNearEntry(IgniteTxEntry<K,V> e, boolean primaryOnly)
boolean	IgniteTxLocalEx.finish(boolean commit) Finishes transaction (either commit or rollback).
void	IgniteTxEntry.marshal(GridCacheSharedContext<K,V> ctx, boolean transferExpiry)
protected abstract IgniteInternalFuture<T>	IgniteTxLocalAdapter.PostLockClosure2.postLock() Post lock callback.
protected abstract T	IgniteTxLocalAdapter.PostLockClosure1.postLock(T val) Post lock callback.
protected Set<K>	IgniteTxLocalAdapter.postLockWrite(GridCacheContext<K,V> cacheCtx, Iterable<? extends K> keys, Set<K> failed, GridCacheReturn ret, boolean rmv, boolean retval, boolean read, long accessTtl, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter, boolean computeInvoke) Post lock processing for put or remove.
protected abstract IgniteInternalFuture<T>	IgniteTxLocalAdapter.PostMissClosure.postMiss(T t) Post lock callback.
void	IgniteInternalTx.prepare() Prepare state.
void	IgniteTxLocalAdapter.prepare() Prepare state.
void	IgniteTxManager.prepareTx(IgniteInternalTx<K,V> tx) Handles prepare stage of 2PC.
void	IgniteInternalTx.rollback() Rolls back this transaction.
protected void	IgniteTxManager.start0()
GridNearTxRemote<K,V>	IgniteTxHandler.startNearRemoteTx(ClassLoader ldr, UUID nodeId, GridDhtTxPrepareRequest<K,V> req) Called while processing dht tx prepare request.
void	IgniteTxEntry.unmarshal(GridCacheSharedContext<K,V> ctx, boolean near, ClassLoader clsLdr) Unmarshalls entry.
void	IgniteTxLocalEx.userCommit()
void	IgniteTxLocalAdapter.userCommit()
void	IgniteTxLocalAdapter.userPrepare()
void	IgniteTxLocalEx.userRollback()
void	IgniteTxLocalAdapter.userRollback()

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.cache.version

Methods in org.apache.ignite.internal.processors.cache.version that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridCacheRawVersionedEntry.marshal(Marshaller marsh) Perform internal marshal of this entry before it will be serialized.
protected void	GridCacheVersionManager.onKernalStart0()
<K,V> GridCacheVersionConflictContext<K,V>	GridCacheVersionAbstractConflictResolver.resolve(GridCacheVersionedEntryEx<K,V> oldEntry, GridCacheVersionedEntryEx<K,V> newEntry, boolean atomicVerComparator) Resolve the conflict.
protected abstract <K,V> void	GridCacheVersionAbstractConflictResolver.resolve0(GridCacheVersionConflictContext<K,V> ctx, GridCacheVersionedEntryEx<K,V> oldEntry, GridCacheVersionedEntryEx<K,V> newEntry, boolean atomicVerComparator) Internal conflict resolution routine.
protected <K,V> void	GridCacheVersionConflictResolver.resolve0(GridCacheVersionConflictContext<K,V> ctx, GridCacheVersionedEntryEx<K,V> oldEntry, GridCacheVersionedEntryEx<K,V> newEntry, boolean atomicVerComparator) Internal conflict resolution routine.
void	GridCacheVersionManager.start0()
void	GridCacheRawVersionedEntry.unmarshal(Marshaller marsh) Perform internal unmarshal of this entry.
void	GridCacheRawVersionedEntry.unmarshalKey(Marshaller marsh) Perform internal key unmarshal of this entry.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.clock

Methods in org.apache.ignite.internal.processors.clock that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridClockSyncProcessor.addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
static GridClockMessage	GridClockMessage.fromBytes(byte[] buf, int off, int len) Constructs message from bytes.
void	GridClockSyncProcessor.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	GridClockServer.sendPacket(GridClockMessage msg, InetAddress addr, int port) Sends packet to remote node.
void	GridClockSyncProcessor.start() Starts grid component.
void	GridClockServer.start(GridKernalContext ctx) Starts server.
void	GridClockSyncProcessor.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.closure

Methods in org.apache.ignite.internal.processors.closure that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridClosureProcessor.start() Starts grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.continuous

Methods in org.apache.ignite.internal.processors.continuous that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridContinuousProcessor.addNotification(UUID nodeId, UUID routineId, Object obj, Object orderedTopic, boolean sync)
void	GridContinuousHandler.p2pMarshal(GridKernalContext ctx) Deploys and marshals inner objects (called only if peer deployment is enabled).
void	GridContinuousHandler.p2pUnmarshal(UUID nodeId, GridKernalContext ctx) Unmarshals inner objects (called only if peer deployment is enabled).
boolean	GridContinuousHandler.register(UUID nodeId, UUID routineId, GridKernalContext ctx) Registers listener.
void	GridContinuousProcessor.start() Starts grid component.
void	GridContinuousProcessor.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.dataload

Methods in org.apache.ignite.internal.processors.dataload that throw IgniteCheckedException

Modifier and Type	Method and Description
void	IgniteDataLoaderImpl.closeEx(boolean cancel)
void	GridDataLoaderProcessor.start() Starts grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.datastructures

Methods in org.apache.ignite.internal.processors.datastructures that throw IgniteCheckedException

Modifier and Type	Method and Description
Object	GridCacheAnnotationHelper.annotatedValue(Object target) Returns annotated value.
IgniteAtomicLong	DataStructuresProcessor.atomicLong(String name, long initVal, boolean create) Gets an atomic long from cache or creates one if it's not cached.
<T> IgniteAtomicReference<T>	DataStructuresProcessor.atomicReference(String name, T initVal, boolean create) Gets an atomic reference from cache or creates one if it's not cached.
<T,S> IgniteAtomicStamped<T,S>	DataStructuresProcessor.atomicStamped(String name, T initVal, S initStamp, boolean create) Gets an atomic stamped from cache or creates one if it's not cached.
IgniteCountDownLatch	DataStructuresProcessor.countDownLatch(String name, int cnt, boolean autoDel, boolean create) Gets or creates count down latch.
<T> IgniteQueue<T>	DataStructuresProcessor.queue(String name, int cap, CollectionConfiguration cfg) Gets a queue from cache or creates one if it's not cached.
void	DataStructuresProcessor.removeAtomicLong(String name) Removes atomic long from cache.
void	DataStructuresProcessor.removeAtomicReference(String name) Removes atomic reference from cache.
void	DataStructuresProcessor.removeAtomicStamped(String name) Removes atomic stamped from cache.
void	DataStructuresProcessor.removeCountDownLatch(String name) Removes count down latch from cache.
protected abstract void	GridCacheQueueAdapter.removeItem(long rmvIdx) Removes item with given index from queue.
protected void	GridAtomicCacheQueueImpl.removeItem(long rmvIdx) Removes item with given index from queue.
protected void	GridTransactionalCacheQueueImpl.removeItem(long rmvIdx) Removes item with given index from queue.
void	DataStructuresProcessor.removeQueue(String name, GridCacheContext cctx)
void	DataStructuresProcessor.removeSequence(String name) Removes sequence from cache.
void	DataStructuresProcessor.removeSet(String name, GridCacheContext cctx)
static <R> R	DataStructuresProcessor.retry(IgniteLogger log, Callable<R> call)
IgniteAtomicSequence	DataStructuresProcessor.sequence(String name, long initVal, boolean create) Gets a sequence from cache or creates one if it's not cached.
<T> IgniteSet<T>	DataStructuresProcessor.set(String name, CollectionConfiguration cfg) Gets a set from cache or creates one if it's not cached.
void	DataStructuresProcessor.start() Starts grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.hadoop

Methods in org.apache.ignite.internal.processors.hadoop that throw IgniteCheckedException

Modifier and Type	Method and Description
abstract void	GridHadoopTaskContext.cleanupTaskEnvironment() Cleans up local environment of the task.
void	GridHadoopJob.cleanupTaskEnvironment(GridHadoopTaskInfo info) Cleans up local environment of the task.
void	GridHadoopTaskInput.close() Closes input.
void	GridHadoopSerialization.close() Finalise the internal objects.
void	GridHadoopTaskOutput.close() Closes output.
abstract GridHadoopCounters	IgniteHadoopProcessorAdapter.counters(GridHadoopJobId jobId) Returns Hadoop job counters.
GridHadoopCounters	GridHadoop.counters(GridHadoopJobId jobId) Returns job counters.
GridHadoopJob	GridHadoopJobInfo.createJob(GridHadoopJobId jobId, IgniteLogger log) Creates new job instance for the given ID.
void	GridHadoopJob.dispose(boolean external) Release all the resources.
abstract IgniteInternalFuture<?>	IgniteHadoopProcessorAdapter.finishFuture(GridHadoopJobId jobId) Gets Hadoop job finish future.
IgniteInternalFuture<?>	IgniteHadoopNoopProcessor.finishFuture(GridHadoopJobId jobId) Gets Hadoop job finish future.
IgniteInternalFuture<?>	GridHadoop.finishFuture(GridHadoopJobId jobId) Gets Hadoop finish future for particular job.
GridHadoopTaskContext	GridHadoopJob.getTaskContext(GridHadoopTaskInfo info) Returns context for task execution.
void	GridHadoopJob.initialize(boolean external, UUID locNodeId) Does all the needed initialization for the job.
Collection<GridHadoopInputSplit>	GridHadoopJob.input() Gets collection of input splits for this job.
abstract GridHadoopSerialization	GridHadoopTaskContext.keySerialization() Gets serializer for values.
abstract boolean	IgniteHadoopProcessorAdapter.kill(GridHadoopJobId jobId) Kills job.
boolean	IgniteHadoopNoopProcessor.kill(GridHadoopJobId jobId) Kills job.
boolean	GridHadoop.kill(GridHadoopJobId jobId) Kills job.
abstract GridHadoopPartitioner	GridHadoopTaskContext.partitioner() Gets partitioner.
GridHadoopMapReducePlan	GridHadoopMapReducePlanner.preparePlan(GridHadoopJob job, Collection<ClusterNode> top, GridHadoopMapReducePlan oldPlan) Prepares map-reduce execution plan for the given job and topology.
abstract void	GridHadoopTaskContext.prepareTaskEnvironment() Prepare local environment for the task.
void	GridHadoopJob.prepareTaskEnvironment(GridHadoopTaskInfo info) Prepare local environment for the task.
Object	GridHadoopSerialization.read(DataInput in, Object obj) Reads object from the given input optionally reusing given instance.
abstract void	GridHadoopTaskContext.run() Execute current task.
abstract void	GridHadoopTask.run(GridHadoopTaskContext taskCtx) Runs task.
abstract GridHadoopJobStatus	IgniteHadoopProcessorAdapter.status(GridHadoopJobId jobId) Gets Hadoop job execution status.
GridHadoopJobStatus	IgniteHadoopNoopProcessor.status(GridHadoopJobId jobId) Gets Hadoop job execution status.
GridHadoopJobStatus	GridHadoop.status(GridHadoopJobId jobId) Gets Hadoop job execution status.
abstract GridHadoopSerialization	GridHadoopTaskContext.valueSerialization() Gets serializer for values.
void	GridHadoopSerialization.write(DataOutput out, Object obj) Writes the given object to output.
void	GridHadoopCounterWriter.write(GridHadoopJobInfo jobInfo, GridHadoopJobId jobId, GridHadoopCounters cntrs) Writes counters of given job to some statistics storage.
void	GridHadoopTaskOutput.write(Object key, Object val) Writes key and value to the output.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.igfs

Subclasses of IgniteCheckedException in org.apache.ignite.internal.processors.igfs

Modifier and Type	Class and Description
class	IgfsInvalidRangeException Internal exception thrown when attempted to update range that is no longer present in file affinity map.

Methods in org.apache.ignite.internal.processors.igfs that return IgniteCheckedException

Modifier and Type	Method and Description
IgniteCheckedException	IgfsAckMessage.error()
IgniteCheckedException	IgfsDeleteMessage.error()

Methods in org.apache.ignite.internal.processors.igfs that throw IgniteCheckedException

Modifier and Type	Method and Description
void	IgfsProcessor.addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
Collection<IgfsBlockLocation>	IgfsDataManager.affinity(IgfsFileInfo info, long start, long len) Resolve affinity nodes for specified part of file.
Collection<IgfsBlockLocation>	IgfsDataManager.affinity(IgfsFileInfo info, long start, long len, long maxLen) Resolve affinity nodes for specified part of file.
IgfsSecondaryOutputStreamDescriptor	IgfsMetaManager.appendDual(Igfs fs, IgfsPath path, int bufSize) Append to a file in DUAL mode.
IgniteInternalFuture<?>	IgfsImpl.awaitDeletesAsync() Asynchronously await for all entries existing in trash to be removed.
IgniteInternalFuture<?>	IgfsEx.awaitDeletesAsync() Asynchronously await for all entries existing in trash to be removed.
IgniteInternalFuture<?>	IgfsAsyncImpl.awaitDeletesAsync() Asynchronously await for all entries existing in trash to be removed.
IgfsSecondaryOutputStreamDescriptor	IgfsMetaManager.createDual(Igfs fs, IgfsPath path, boolean simpleCreate, Map<String,String> props, boolean overwrite, int bufSize, short replication, long blockSize, IgniteUuid affKey) Create the file in DUAL mode.
IgniteInternalFuture<byte[]>	IgfsDataManager.dataBlock(IgfsFileInfo fileInfo, IgfsPath path, long blockIdx, IgfsReader secReader) Get data block for specified file ID and block index.
protected IgniteInternalFuture<byte[]>	IgfsInputStreamImpl.dataBlock(IgfsFileInfo fileInfo, long blockIdx) Get data block for specified block index.
boolean	IgfsMetaManager.deleteDual(Igfs fs, IgfsPath path, boolean recursive) Delete path in DUAL mode.
void	IgfsFileMap.deleteRange(IgfsFileAffinityRange range) Deletes range from map.
Map<String,IgfsListingEntry>	IgfsMetaManager.directoryListing(IgniteUuid fileId) List child files for specified file ID.
void	IgfsFileWorkerTask.execute() Execute task logic.
boolean	IgfsMetaManager.exists(IgniteUuid fileId) Ensure that entry with the given ID exists in meta cache.
IgfsFileInfo	IgfsMetaManager.fileForFragmentizer(Collection<IgniteUuid> exclude) Gets first available file info for fragmentizer.
IgniteUuid	IgfsMetaManager.fileId(IgfsPath path) Gets file ID for specified path.
IgniteUuid	IgfsMetaManager.fileId(IgniteUuid parentId, String fileName) Gets file ID by its name from parent directory listing.
List<IgniteUuid>	IgfsMetaManager.fileIds(IgfsPath path) Gets all file IDs for components of specified path.
void	IgfsCommunicationMessage.finishUnmarshal(Marshaller marsh, ClassLoader ldr)
void	IgfsAckMessage.finishUnmarshal(Marshaller marsh, ClassLoader ldr)
void	IgfsDeleteMessage.finishUnmarshal(Marshaller marsh, ClassLoader ldr)
void	IgfsImpl.globalSampling(Boolean val) Enables, disables or clears sampling flag.
void	IgfsEx.globalSampling(Boolean val) Enables, disables or clears sampling flag.
void	IgfsAsyncImpl.globalSampling(Boolean val) Enables, disables or clears sampling flag.
IgfsStatus	IgfsImpl.globalSpace() Gets global space counters.
IgfsStatus	IgfsEx.globalSpace() Gets global space counters.
IgfsStatus	IgfsAsyncImpl.globalSpace() Gets global space counters.
IgfsFileInfo	IgfsMetaManager.info(IgniteUuid fileId) Gets file info by its ID.
Map<IgniteUuid,IgfsFileInfo>	IgfsMetaManager.infos(Collection<IgniteUuid> fileIds) Gets files details by their IDs.
List<Long>	IgfsDataManager.listLocalDataBlocks(IgfsFileInfo fileInfo) Get list of local data blocks of the given file.
IgfsFileInfo	IgfsMetaManager.lock(IgniteUuid fileId) Lock the file explicitly outside of transaction.
IgfsFileInfo	IgfsMetaManager.lockInfo(IgfsFileInfo info) Set lock on file info.
boolean	IgfsMetaManager.mkdirsDual(Igfs fs, IgfsPath path, Map<String,String> props) Create directory in DUAL mode.
void	IgfsMetaManager.move(IgniteUuid fileId, String srcFileName, IgniteUuid srcParentId, String destFileName, IgniteUuid destParentId) Move or rename file.
void	IgfsProcessor.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	IgfsManager.onKernalStart()
protected void	IgfsMetaManager.onKernalStart0()
protected void	IgfsFragmentizerManager.onKernalStart0()
protected void	IgfsDataManager.onKernalStart0()
protected void	IgfsServerManager.onKernalStart0()
protected void	IgfsManager.onKernalStart0()
IgfsSecondaryInputStreamDescriptor	IgfsMetaManager.openDual(Igfs fs, IgfsPath path, int bufSize) Open file in DUAL mode.
Collection<IgniteUuid>	IgfsMetaManager.pendingDeletes() Check whether there are any pending deletes and return collection of pending delete entry IDs.
void	IgfsCommunicationMessage.prepareMarshal(Marshaller marsh)
void	IgfsAckMessage.prepareMarshal(Marshaller marsh)
void	IgfsDeleteMessage.prepareMarshal(Marshaller marsh)
IgniteUuid	IgfsMetaManager.putIfAbsent(IgniteUuid parentId, String fileName, IgfsFileInfo newFileInfo) Add file into file system structure.
IgfsFileInfo	IgfsMetaManager.removeIfEmpty(IgniteUuid parentId, String fileName, IgniteUuid fileId, IgfsPath path, boolean rmvLocked) Remove file from the file system structure.
boolean	IgfsMetaManager.renameDual(Igfs fs, IgfsPath src, IgfsPath dest) Rename path in DUAL mode.
Boolean	IgfsMetaManager.sampling() Get sampling flag state.
boolean	IgfsMetaManager.sampling(Boolean val) Set sampling flag.
void	IgfsContext.send(ClusterNode node, Object topic, IgfsCommunicationMessage msg, GridIoPolicy plc)
void	IgfsContext.send(UUID nodeId, Object topic, IgfsCommunicationMessage msg, GridIoPolicy plc)
void	IgfsServer.start() Starts this server.
void	IgfsProcessor.start() Starts grid component.
void	IgfsManager.start(IgfsContext igfsCtx) Called when IGFS processor is started.
protected void	IgfsMetaManager.start0() Start manager implementation.
protected void	IgfsFragmentizerManager.start0() Start manager implementation.
protected void	IgfsDataManager.start0() Start manager implementation.
protected void	IgfsServerManager.start0() Start manager implementation.
protected void	IgfsManager.start0() Start manager implementation.
void	IgfsServerHandler.stop() Stops handling of incoming requests.
byte[]	IgfsDataManager.storeDataBlocks(IgfsFileInfo fileInfo, long reservedLen, byte[] remainder, int remainderLen, ByteBuffer data, boolean flush, IgfsFileAffinityRange affinityRange, IgfsFileWorkerBatch batch) Store data blocks in file.
byte[]	IgfsDataManager.storeDataBlocks(IgfsFileInfo fileInfo, long reservedLen, byte[] remainder, int remainderLen, DataInput in, int len, boolean flush, IgfsFileAffinityRange affinityRange, IgfsFileWorkerBatch batch) Store data blocks in file.
IgfsFileInfo	IgfsMetaManager.synchronizeFileDual(Igfs fs, IgfsPath path) Synchronizes with secondary file system.
void	IgfsMetaManager.unlock(IgfsFileInfo info, long modificationTime) Remove explicit lock on file held by the current thread.
IgfsFileInfo	IgfsMetaManager.updateDual(Igfs fs, IgfsPath path, Map<String,String> props) Update path in DUAL mode.
IgfsFileInfo	IgfsMetaManager.updateInfo(IgniteUuid fileId, IgniteClosure<IgfsFileInfo,IgfsFileInfo> c) Update file info in cache.
IgfsFileInfo	IgfsMetaManager.updateProperties(IgniteUuid parentId, IgniteUuid fileId, String fileName, Map<String,String> props) Update file info (file properties) in cache.
void	IgfsFileMap.updateRangeStatus(IgfsFileAffinityRange range, int status) Updates range status in file map.
void	IgfsMetaManager.updateTimes(IgniteUuid parentId, IgniteUuid fileId, String fileName, long accessTime, long modificationTime) Updates last access and last modification times.
void	IgfsHelperImpl.validateCacheConfiguration(CacheConfiguration cfg) Validate cache configuration for IGFS.
void	IgfsNoopHelper.validateCacheConfiguration(CacheConfiguration cfg) Validate cache configuration for IGFS.
void	IgfsHelper.validateCacheConfiguration(CacheConfiguration cfg) Validate cache configuration for IGFS.

Constructors in org.apache.ignite.internal.processors.igfs with parameters of type IgniteCheckedException

Constructor and Description
IgfsAckMessage(IgniteUuid fileId, long id, IgniteCheckedException err)
IgfsDeleteMessage(IgniteUuid id, IgniteCheckedException err) Constructor.

Constructors in org.apache.ignite.internal.processors.igfs that throw IgniteCheckedException

Constructor and Description
IgfsContext(GridKernalContext ctx, IgfsConfiguration cfg, IgfsMetaManager metaMgr, IgfsDataManager dataMgr, IgfsServerManager srvMgr, IgfsFragmentizerManager fragmentizerMgr)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.job

Methods in org.apache.ignite.internal.processors.job that throw IgniteCheckedException

Modifier and Type	Method and Description
Collection<ComputeJobSibling>	GridJobProcessor.requestJobSiblings(ComputeTaskSession ses)
void	GridJobProcessor.setAttributes(GridJobSessionImpl ses, Map<?,?> attrs)
void	GridJobProcessor.start() Starts grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.jobmetrics

Methods in org.apache.ignite.internal.processors.jobmetrics that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridJobMetricsProcessor.start() Starts grid component.
void	GridJobMetricsProcessor.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.offheap

Methods in org.apache.ignite.internal.processors.offheap that throw IgniteCheckedException

Modifier and Type	Method and Description
boolean	GridOffHeapProcessor.contains(String spaceName, int part, Object key, byte[] keyBytes) Checks if offheap space contains value for the given key.
void	GridOffHeapProcessor.enableEviction(String spaceName, int part, Object key, byte[] keyBytes) Enables eviction for entry after GridOffHeapProcessor.valuePointer(java.lang.String, int, java.lang.Object, byte[]) was called.
byte[]	GridOffHeapProcessor.get(String spaceName, int part, Object key, byte[] keyBytes) Gets value bytes from offheap space for the given key.
<T> T	GridOffHeapProcessor.getValue(String spaceName, int part, Object key, byte[] keyBytes, ClassLoader ldr) Gets value from offheap space for the given key.
void	GridOffHeapProcessor.put(String spaceName, int part, Object key, byte[] keyBytes, byte[] valBytes) Puts the given value to offheap space for the given key.
byte[]	GridOffHeapProcessor.remove(String spaceName, int part, Object key, byte[] keyBytes) Removes value from offheap space for the given key.
boolean	GridOffHeapProcessor.removex(String spaceName, int part, Object key, byte[] keyBytes) Removes value from offheap space for the given key.
void	GridOffHeapProcessor.stop(boolean cancel) Stops grid component.
IgniteBiTuple<Long,Integer>	GridOffHeapProcessor.valuePointer(String spaceName, int part, Object key, byte[] keyBytes) Gets value pointer from offheap space for the given key.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.port

Methods in org.apache.ignite.internal.processors.port that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridPortProcessor.start() Starts grid component.
void	GridPortProcessor.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.query

Methods in org.apache.ignite.internal.processors.query that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridQueryProcessor.onSwap(String spaceName, Object key) Will be called when entry for key will be swapped.
void	GridQueryIndexing.onSwap(String spaceName, Object key) Will be called when entry with given key is swapped.
void	GridQueryProcessor.onUndeploy(String space, ClassLoader ldr) Removes index tables for all classes belonging to given class loader.
void	GridQueryProcessor.onUnswap(String spaceName, Object key, Object val, byte[] valBytes) Will be called when entry for key will be unswapped.
void	GridQueryIndexing.onUnswap(String spaceName, Object key, Object val, byte[] valBytes) Will be called when entry with given key is unswapped.
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>>	GridQueryIndexing.query(String spaceName, String qry, Collection<Object> params, GridQueryTypeDescriptor type, IndexingQueryFilter filters) Executes regular query.
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>>	GridQueryProcessor.query(String space, String clause, Collection<Object> params, String resType, IndexingQueryFilter filters)
<K,V> GridQueryFieldsResult	GridQueryProcessor.queryFields(String space, String clause, Collection<Object> params, IndexingQueryFilter filters)
<K,V> GridQueryFieldsResult	GridQueryIndexing.queryFields(String spaceName, String qry, Collection<Object> params, IndexingQueryFilter filters) Queries individual fields (generally used by JDBC drivers).
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>>	GridQueryIndexing.queryText(String spaceName, String qry, GridQueryTypeDescriptor type, IndexingQueryFilter filters) Executes text query.
<K,V> GridCloseableIterator<IgniteBiTuple<K,V>>	GridQueryProcessor.queryText(String space, String clause, String resType, IndexingQueryFilter filters)
boolean	GridQueryIndexing.registerType(String spaceName, GridQueryTypeDescriptor desc) Registers type if it was not known before or updates it otherwise.
void	GridQueryProcessor.remove(String space, Object key)
void	GridQueryIndexing.remove(String spaceName, Object key) Removes index entry by key.
long	GridQueryProcessor.size(String space, Class<?> valType) Returns number of objects of given type for given space of spi.
long	GridQueryIndexing.size(String spaceName, GridQueryTypeDescriptor desc, IndexingQueryFilter filters) Gets size of index for given type or -1 if it is a unknown type.
void	GridQueryProcessor.start() Starts grid component.
void	GridQueryIndexing.start(GridKernalContext ctx) Starts indexing.
void	GridQueryIndexing.stop() Stops indexing.
void	GridQueryProcessor.stop(boolean cancel) Stops grid component.
void	GridQueryIndexing.store(String spaceName, GridQueryTypeDescriptor type, Object key, Object val, byte[] ver, long expirationTime) Updates index.
<K,V> void	GridQueryProcessor.store(String space, K key, byte[] keyBytes, V val, byte[] valBytes, byte[] ver, long expirationTime) Writes key-value pair to index.
GridQueryTypeDescriptor	GridQueryProcessor.type(String space, String typeName) Gets type for space and type name.
void	GridQueryIndexing.unregisterType(String spaceName, GridQueryTypeDescriptor type) Unregisters type and removes all corresponding data.
<T> T	GridQueryTypeDescriptor.value(Object obj, String field) Gets field value for given object.

Constructors in org.apache.ignite.internal.processors.query that throw IgniteCheckedException

Constructor and Description
GridQueryProcessor(GridKernalContext ctx)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.resource

Methods in org.apache.ignite.internal.processors.resource that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridResourceProcessor.cleanup(IgniteSpi spi) Cleans up resources from given SPI implementation.
void	GridResourceProcessor.cleanup(LifecycleBean lifecycleBean) Cleans up resources from given lifecycle beans.
void	GridResourceProcessor.cleanup(Service svc) Cleans up resources from given service.
void	GridResourceProcessor.cleanupGeneric(Object obj)
void	GridResourceProcessor.inject(GridDeployment dep, Class<?> taskCls, ComputeJob job, ComputeTaskSession ses, GridJobContextImpl jobCtx) Injects held resources into given job.
void	GridResourceProcessor.inject(GridDeployment dep, Class<?> depCls, Object target) Injects resources into generic class.
void	GridResourceProcessor.inject(GridDeployment dep, ComputeTask<?,?> task, GridTaskSessionImpl ses, ComputeLoadBalancer balancer, ComputeTaskContinuousMapper mapper) Injects held resources into given grid task.
void	GridResourceJobContextInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field, Object target, Class<?> depCls, GridDeployment dep) Injects resource into field.
void	GridResourceLoggerInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field, Object target, Class<?> depCls, GridDeployment dep) Injects resource into field.
void	GridResourceServiceInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceField field, Object target, Class<?> depCls, GridDeployment dep) Injects resource into field.
void	GridResourceJobContextInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd, Object target, Class<?> depCls, GridDeployment dep) Injects resource with a setter method.
void	GridResourceLoggerInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd, Object target, Class<?> depCls, GridDeployment dep) Injects resource with a setter method.
void	GridResourceServiceInjector.inject(org.apache.ignite.internal.processors.resource.GridResourceMethod mtd, Object target, Class<?> depCls, GridDeployment dep) Injects resource with a setter method.
void	GridResourceProcessor.inject(IgniteSpi spi) Injects held resources into given SPI implementation.
void	GridResourceProcessor.inject(LifecycleBean lifecycleBean) Injects held resources into given lifecycle bean.
void	GridResourceProcessor.inject(Service svc) Injects resources into service.
void	GridResourceProcessor.injectBasicResource(Object target, Class<? extends Annotation> annCls, Object rsrc) This method is declared public as it is used from tests as well.
void	GridResourceProcessor.injectBasicResource(Object target, Class<? extends Annotation> annCls, Object rsrc, GridDeployment dep, Class<?> depCls) This method is declared public as it is used from tests as well.
void	GridResourceProcessor.injectCacheName(Object obj, String cacheName) Injects cache name into given object.
void	GridResourceProcessor.injectGeneric(Object obj)
boolean	GridResourceProcessor.injectStoreSession(Object obj, CacheStoreSession ses) Injects cache store session into given object.
void	GridResourceProcessor.invokeAnnotated(GridDeployment dep, Object target, Class<? extends Annotation> annCls)
void	GridResourceProcessor.start() Starts grid component.
Object	GridSpringResourceContext.unwrapTarget(Object target) Return original object if AOP used with proxy objects.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.rest

Methods in org.apache.ignite.internal.processors.rest that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridRestProcessor.addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
GridRestResponse	GridRestProtocolHandler.handle(GridRestRequest req)
void	GridRestProcessor.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	GridRestProcessor.start() Starts grid component.
void	GridRestProtocol.start(GridRestProtocolHandler hnd) Starts protocol.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.rest.handlers.cache

Methods in org.apache.ignite.internal.processors.rest.handlers.cache that throw IgniteCheckedException

Modifier and Type	Method and Description
protected GridCacheProjectionEx<Object,Object>	GridCacheCommandHandler.localCache(String cacheName) Used for test purposes.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.rest.protocols

Methods in org.apache.ignite.internal.processors.rest.protocols that throw IgniteCheckedException

Modifier and Type	Method and Description
protected void	GridRestProtocolAdapter.assertParameter(boolean cond, String condDesc)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.rest.protocols.tcp

Methods in org.apache.ignite.internal.processors.rest.protocols.tcp that throw IgniteCheckedException

Modifier and Type	Method and Description
GridClientMessage	GridTcpRestParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
ByteBuffer	GridTcpRestParser.encode(GridNioSession ses, Object msg0) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
protected GridClientMessage	GridTcpRestParser.parseClientMessage(GridNioSession ses, GridTcpRestParser.ParserState state) Parses GridClientMessage from raw bytes.
void	GridTcpRestProtocol.start(GridRestProtocolHandler hnd) Starts protocol.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.securesession

Methods in org.apache.ignite.internal.processors.securesession that throw IgniteCheckedException

Modifier and Type	Method and Description
byte[]	GridSecureSessionProcessor.updateSession(GridSecuritySubjectType subjType, UUID subjId, GridSecurityContext subjCtx, Object params) Generates secure session token.
GridSecureSession	GridSecureSessionProcessor.validateSession(GridSecuritySubjectType subjType, UUID subjId, byte[] tok, Object params)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.securesession.os

Methods in org.apache.ignite.internal.processors.securesession.os that throw IgniteCheckedException

Modifier and Type	Method and Description
GridSecureSession	GridOsSecureSessionProcessor.validateSession(GridSecuritySubjectType subjType, UUID subjId, byte[] tok, Object params)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.security

Methods in org.apache.ignite.internal.processors.security that throw IgniteCheckedException

Modifier and Type	Method and Description
GridSecurityContext	GridSecurityProcessor.authenticate(AuthenticationContext ctx) Authenticates subject via underlying Authenticator.
GridSecuritySubject	GridSecurityProcessor.authenticatedSubject(UUID subjId) Gets authenticated node subject.
Collection<GridSecuritySubject>	GridSecurityProcessor.authenticatedSubjects() Gets collection of authenticated nodes.
GridSecurityContext	GridSecurityProcessor.authenticateNode(ClusterNode node, GridSecurityCredentials cred) Authenticates grid node with it's attributes via underlying Authenticator.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.security.os

Methods in org.apache.ignite.internal.processors.security.os that throw IgniteCheckedException

Modifier and Type	Method and Description
GridSecurityContext	GridOsSecurityProcessor.authenticate(AuthenticationContext authCtx) Authenticates subject via underlying Authenticator.
GridSecurityContext	GridOsSecurityProcessor.authenticateNode(ClusterNode node, GridSecurityCredentials cred) Authenticates grid node with it's attributes via underlying Authenticator.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.service

Subclasses of IgniteCheckedException in org.apache.ignite.internal.processors.service

Modifier and Type	Class and Description
class	GridServiceNotFoundException Exception thrown if service is not found.

Methods in org.apache.ignite.internal.processors.service that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridServiceProcessor.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	GridServiceProcessor.start() Starts grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.session

Methods in org.apache.ignite.internal.processors.session that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridTaskSessionProcessor.start() Starts session processor.
void	GridTaskSessionProcessor.stop(boolean cancel) Stops session processor.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.spring

Methods in org.apache.ignite.internal.processors.spring that throw IgniteCheckedException

Modifier and Type	Method and Description
Map<Class<?>,Object>	IgniteSpringProcessor.loadBeans(URL cfgUrl, Class<?>... beanClasses) Loads bean instances that match the given types from given configuration file.
IgniteBiTuple<Collection<IgniteConfiguration>,? extends GridSpringResourceContext>	IgniteSpringProcessor.loadConfigurations(URL cfgUrl, String... excludedProps) Loads all grid configurations specified within given configuration file.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.streamer

Subclasses of IgniteCheckedException in org.apache.ignite.internal.processors.streamer

Modifier and Type	Class and Description
class	GridStreamerRouteFailedException Exception thrown when router did not return route map.

Methods in org.apache.ignite.internal.processors.streamer that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridStreamProcessor.addAttributes(Map<String,Object> attrs) Adds attributes from this component to map of all node attributes.
boolean	GridStreamerStageExecutionFuture.cancel() Default no-op implementation that always returns false.
void	GridStreamProcessor.onKernalStart() Callback that notifies that kernal has successfully started, including all managers and processors.
void	IgniteStreamerEx.scheduleExecutions(GridStreamerStageExecutionFuture fut, Map<UUID,GridStreamerExecutionBatch> execs) Schedules batch executions either on local or on remote nodes.
void	IgniteStreamerImpl.scheduleExecutions(GridStreamerStageExecutionFuture fut, Map<UUID,GridStreamerExecutionBatch> execs) Schedules batch executions either on local or on remote nodes.
void	GridStreamProcessor.start() Starts grid component.
void	IgniteStreamerImpl.start()
void	GridStreamProcessor.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.task

Methods in org.apache.ignite.internal.processors.task that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridTaskProcessor.setAttributes(GridTaskSessionImpl ses, Map<?,?> attrs)

Uses of IgniteCheckedException in org.apache.ignite.internal.processors.timeout

Methods in org.apache.ignite.internal.processors.timeout that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridTimeoutProcessor.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.internal.transactions

Subclasses of IgniteCheckedException in org.apache.ignite.internal.transactions

Modifier and Type	Class and Description
class	IgniteTxHeuristicCheckedException Exception thrown whenever grid transaction enters an unknown state.
class	IgniteTxOptimisticCheckedException Exception thrown whenever grid transactions fail optimistically.
class	IgniteTxRollbackCheckedException Exception thrown whenever grid transactions has been automatically rolled back.
class	IgniteTxTimeoutCheckedException Exception thrown whenever grid transactions time out.

Uses of IgniteCheckedException in org.apache.ignite.internal.util

Methods in org.apache.ignite.internal.util that return IgniteCheckedException

Modifier and Type	Method and Description
static IgniteCheckedException	IgniteUtils.cast(Throwable t) Casts this throwable as IgniteCheckedException.
static IgniteCheckedException	IgniteUtils.exceptionWithSuppressed(String msg, Collection<Throwable> suppressed) Creates IgniteCheckedException with the collection of suppressed exceptions.

Methods in org.apache.ignite.internal.util with parameters of type IgniteCheckedException

Modifier and Type	Method and Description
static IgniteException	IgniteUtils.convertException(IgniteCheckedException e)
static javax.cache.CacheException	IgniteUtils.convertToCacheException(IgniteCheckedException e)

Methods in org.apache.ignite.internal.util that throw IgniteCheckedException

Modifier and Type	Method and Description
T	GridCircularBuffer.add(T t, IgniteInClosureX<T> c)
static IgniteBiTuple<Object,Object>	IgniteUtils.addLog4jNoOpLogger() Adds no-op logger to remove no-appender warning.
void	GridEmptyCloseableIterator.close() Closes the iterator and frees all the resources held by the iterator.
void	GridCloseableIteratorAdapterEx.close() Closes the iterator and frees all the resources held by the iterator.
void	GridWeakIterator.close() Closes iterator.
void	GridCloseableIteratorAdapter.close() Closes the iterator and frees all the resources held by the iterator.
static byte[]	IgniteUtils.decodeHex(char[] data) Converts an array of characters representing hexidecimal values into an array of bytes of those same values.
static <T> T	IgniteUtils.field(Class<?> cls, String fieldName) Gets field value.
Object	GridReflectionCache.firstFieldValue(Object o) Gets field value for object.
Object	GridReflectionCache.firstMethodValue(Object o) Gets method return value for object.
static Constructor<?>	IgniteUtils.forceEmptyConstructor(Class<?> cls) Gets empty constructor for class even if the class does not have empty constructor declared.
static <T> T	IgniteUtils.forceNewInstance(Class<?> cls) Creates new instance of a class even if it does not have public constructor.
static <T> T	IgniteUtils.get(Future<T> fut) Gets result from the given future with right exception handling.
boolean	GridCloseableIteratorAdapterEx.hasNextX() This method is the same as Iterator.hasNext(), but allows for failure with exception.
boolean	GridCloseableIteratorAdapter.hasNextX() This method is the same as Iterator.hasNext(), but allows for failure with exception.
T	GridAtomicInitializer.init(Callable<T> c) Executes initialization operation only once.
static <T> T	IgniteUtils.invoke(Class<?> cls, Object obj, String mtdName, Class[] paramTypes, Object... params) Invokes method.
static <T> T	IgniteUtils.newInstance(Class<T> cls) Creates new instance of a class only if it has an empty constructor (can be non-public).
static <T> T	IgniteUtils.newInstance(String cls) Creates new instance of a class only if it has an empty constructor (can be non-public).
T	GridCloseableIteratorAdapterEx.nextX() This method is the same as Iterator.next(), but allows for failure with exception.
T	GridCloseableIteratorAdapter.nextX() This method is the same as Iterator.next(), but allows for failure with exception.
protected void	GridCloseableIteratorAdapterEx.onClose() Invoked on iterator close.
protected void	GridSpiCloseableIteratorWrapper.onClose() Invoked on iterator close.
protected void	GridCloseableIteratorAdapter.onClose() Invoked on iterator close.
protected abstract boolean	GridCloseableIteratorAdapterEx.onHasNext()
protected boolean	GridSpiCloseableIteratorWrapper.onHasNext()
protected abstract boolean	GridCloseableIteratorAdapter.onHasNext()
protected abstract T	GridCloseableIteratorAdapterEx.onNext()
protected T	GridSpiCloseableIteratorWrapper.onNext()
protected abstract T	GridCloseableIteratorAdapter.onNext()
protected void	GridCloseableIteratorAdapterEx.onRemove() Called on remove from iterator.
protected void	GridCloseableIteratorAdapter.onRemove() Called on remove from iterator.
static Calendar	IgniteUtils.parseIsoDate(String str)
static void	IgniteUtils.removeLog4jNoOpLogger(IgniteBiTuple<Object,Object> t) Removes previously added no-op logger via method IgniteUtils.addLog4jNoOpLogger().
void	GridCloseableIteratorAdapterEx.removeX() This method is the same as Iterator.remove(), but allows for failure with exception.
void	GridCloseableIteratorAdapter.removeX() This method is the same as Iterator.remove(), but allows for failure with exception.
static Collection<InetSocketAddress>	IgniteUtils.resolveAddresses(AddressResolver addrRslvr, Iterable<String> addrs, int port) Resolves all not loopback addresses and collect results.
static IgniteBiTuple<Collection<String>,Collection<String>>	IgniteUtils.resolveLocalAddresses(InetAddress locAddr) Returns host names consistent with IgniteUtils.resolveLocalHost(String).
static File	IgniteUtils.resolveWorkDirectory(String path, boolean delIfExist) Resolves work directory.
static void	IgniteUtils.setWorkDirectory(String userWorkDir, String userIgniteHome)
static void	IgniteUtils.startLifecycleAware(Iterable<?> objs) For each object provided by the given Iterable checks if it implements LifecycleAware interface and executes LifecycleAware.start() method.
static <T> T	IgniteUtils.staticField(Class<?> cls, String fieldName) Gets static field value.
static int	IgniteUtils.toDigit(char ch, int index) Converts a hexadecimal character to an integer.
static Collection<InetAddress>	IgniteUtils.toInetAddresses(ClusterNode node) Returns tha list of resolved inet addresses.
static Collection<InetAddress>	IgniteUtils.toInetAddresses(Collection<String> addrs, Collection<String> hostNames) Returns tha list of resolved inet addresses.
static <R> R	IgniteUtils.wrapThreadLoader(ClassLoader ldr, Callable<R> c) Sets thread context class loader to the given loader, executes the closure, and then resets thread context class loader to its initial value.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.future

Methods in org.apache.ignite.internal.util.future that throw IgniteCheckedException

Modifier and Type	Method and Description
boolean	GridEmbeddedFuture.cancel() Default no-op implementation that always returns false.
boolean	GridFutureAdapter.cancel() Default no-op implementation that always returns false.
boolean	GridCompoundFuture.cancel() Default no-op implementation that always returns false.
boolean	GridFutureAdapterEx.cancel() Default no-op implementation that always returns false.
R	GridFutureAdapter.get() Synchronously waits for completion of the computation and returns computation result.
T	GridFinishedFutureEx.get() Synchronously waits for completion of the computation and returns computation result.
R	GridFutureAdapterEx.get() Synchronously waits for completion of the computation and returns computation result.
T	GridFinishedFuture.get() Synchronously waits for completion of the computation and returns computation result.
R	GridFutureAdapter.get(long timeout) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
T	GridFinishedFutureEx.get(long timeout) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
R	GridFutureAdapterEx.get(long timeout) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
T	GridFinishedFuture.get(long timeout) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
R	GridFutureAdapter.get(long timeout, TimeUnit unit) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
T	GridFinishedFutureEx.get(long timeout, TimeUnit unit) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
R	GridFutureAdapterEx.get(long timeout, TimeUnit unit) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
T	GridFinishedFuture.get(long timeout, TimeUnit unit) Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.
protected R	GridFutureAdapter.get0(long nanosTimeout)
protected R	GridFutureAdapterEx.get0(long nanosTimeout)

Uses of IgniteCheckedException in org.apache.ignite.internal.util.gridify

Methods in org.apache.ignite.internal.util.gridify that throw IgniteCheckedException

Modifier and Type	Method and Description
GridifyRangeArgument	GridifyArgumentBuilder.createTaskArgument(GridifyRangeArgument arg, Collection<?> input) Create GridifyRangeArgument for task.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.ipc

Subclasses of IgniteCheckedException in org.apache.ignite.internal.util.ipc

Modifier and Type	Class and Description
class	IpcEndpointBindException Represents exception occurred during IPC endpoint binding.

Methods in org.apache.ignite.internal.util.ipc that throw IgniteCheckedException

Modifier and Type	Method and Description
IpcEndpoint	IpcServerEndpoint.accept() Accepts client IPC connection.
static IpcEndpoint	IpcEndpointFactory.connectEndpoint(String endpointAddr, IgniteLogger log) Connects to open server IPC endpoint.
static IpcServerEndpoint	IpcServerEndpointDeserializer.deserialize(Map<String,String> endpointCfg) Deserializes IPC server endpoint config into concrete instance of IpcServerEndpoint.
InputStream	IpcEndpoint.inputStream() Gets input stream associated with this IPC endpoint.
OutputStream	IpcEndpoint.outputStream() Gets output stream associated with this IPC endpoint.
void	IpcServerEndpoint.start() Starts configured endpoint implementation.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.ipc.loopback

Methods in org.apache.ignite.internal.util.ipc.loopback that throw IgniteCheckedException

Modifier and Type	Method and Description
IpcEndpoint	IpcServerTcpEndpoint.accept() Accepts client IPC connection.
InputStream	IpcClientTcpEndpoint.inputStream() Gets input stream associated with this IPC endpoint.
OutputStream	IpcClientTcpEndpoint.outputStream() Gets output stream associated with this IPC endpoint.
void	IpcServerTcpEndpoint.setupConfiguration(Map<String,String> endpointCfg) Sets configuration properties from the map.
void	IpcServerTcpEndpoint.start() Starts configured endpoint implementation.

Constructors in org.apache.ignite.internal.util.ipc.loopback that throw IgniteCheckedException

Constructor and Description
IpcClientTcpEndpoint(String host, int port) Creates and connects client IPC endpoint.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.ipc.shmem

Subclasses of IgniteCheckedException in org.apache.ignite.internal.util.ipc.shmem

Modifier and Type	Class and Description
class	IpcOutOfSystemResourcesException Thrown when IPC runs out of system resources (for example, no more free shared memory is available in operating system).
class	IpcSharedMemoryOperationTimedoutException Thrown when IPC operation (such as Object.wait(long)) has timed out.

Methods in org.apache.ignite.internal.util.ipc.shmem that throw IgniteCheckedException

Modifier and Type	Method and Description
IpcEndpoint	IpcSharedMemoryServerEndpoint.accept() Accepts client IPC connection.
static void	IpcSharedMemoryNativeLoader.load()
int	IpcSharedMemorySpace.read(byte[] buf, int off, int len, long timeout) Blocks until at least 1 byte is read.
int	IpcSharedMemorySpace.read(ByteBuffer buf, int off, int len, long timeout) Blocks until at least 1 byte is read.
void	IpcSharedMemoryServerEndpoint.setupConfiguration(Map<String,String> endpointCfg) Sets configuration properties from the map.
void	IpcSharedMemoryServerEndpoint.start() Starts configured endpoint implementation.
int	IpcSharedMemorySpace.unreadCount()
void	IpcSharedMemorySpace.write(byte[] buf, int off, int len, long timeout)
void	IpcSharedMemorySpace.write(ByteBuffer buf, int off, int len, long timeout)

Constructors in org.apache.ignite.internal.util.ipc.shmem that throw IgniteCheckedException

Constructor and Description
IpcSharedMemoryClientEndpoint(int port, IgniteLogger parent) Creates and connects client IPC endpoint and starts background checker thread to avoid deadlocks on other party crash.
IpcSharedMemoryClientEndpoint(int port, int timeout, IgniteLogger parent) Creates and connects client IPC endpoint and starts background checker thread to avoid deadlocks on other party crash.
IpcSharedMemorySpace(String tokFileName, int writerPid, int readerPid, int size, boolean reader, IgniteLogger parent) This will allocate system resources for the space.
IpcSharedMemorySpace(String tokFileName, int writerPid, int readerPid, int size, boolean reader, int shmemId, IgniteLogger parent) This should be called in order to attach to already allocated system resources.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.lang

Methods in org.apache.ignite.internal.util.lang that throw IgniteCheckedException

Modifier and Type	Method and Description
R	GridPlainOutClosure.apply()
void	GridPlainAbsClosure.apply() Applies this closure.
R	GridPlainClosure.apply(T arg)
void	GridPlainInClosure.apply(T arg)
R	GridPlainClosure2.apply(T1 arg1, T2 arg2)
abstract R	IgniteReducerX.applyx() Reducer body that can throw IgniteCheckedException.
abstract void	GridAbsClosureX.applyx() Closure body that can throw IgniteCheckedException.
abstract R	IgniteReducer3X.applyx() Reducer body that can throw IgniteCheckedException.
abstract boolean	GridAbsPredicateX.applyx() Predicate body that can throw IgniteCheckedException.
abstract R	IgniteReducer2X.applyx() Reducer body that can throw IgniteCheckedException.
abstract T	IgniteOutClosureX.applyx() Out-closure body that can throw IgniteCheckedException.
abstract R	IgniteClosureX.applyx(E e) Closure body that can throw IgniteCheckedException.
abstract boolean	IgnitePredicateX.applyx(E1 e) Predicate body that can throw IgniteCheckedException.
abstract void	IgniteInClosure2X.applyx(E1 e1, E2 e2) In-closure body that can throw IgniteCheckedException.
abstract boolean	IgnitePredicate2X.applyx(E1 e1, E2 e2) Predicate body that can throw IgniteCheckedException.
abstract R	IgniteClosure2X.applyx(E1 e1, E2 e2) Closure body that can throw IgniteCheckedException.
abstract boolean	GridPredicate3X.applyx(E1 e1, E2 e2, E3 e3) Predicate body that can throw IgniteCheckedException.
abstract R	GridClosure3X.applyx(E1 e1, E2 e2, E3 e3) Closure body that can throw IgniteCheckedException.
abstract void	GridInClosure3X.applyx(E1 e1, E2 e2, E3 e3) In-closure body that can throw IgniteCheckedException.
abstract void	IgniteInClosureX.applyx(T t) In-closure body that can throw IgniteCheckedException.
static <T> void	GridFunc.awaitAll(Collection<IgniteInternalFuture<T>> futs) Waits until all passed futures will be executed.
static <T> void	GridFunc.awaitAll(IgniteInternalFuture<T>... futs) Waits until all passed futures will be executed.
static <T> void	GridFunc.awaitAll(long timeout, Collection<IgniteInternalFuture<T>> futs) Waits until all passed futures will be executed.
static <T,R> R	GridFunc.awaitAll(long timeout, IgniteReducer<T,R> rdc, Collection<IgniteInternalFuture<T>> futs) Awaits for all futures to complete and optionally reduces all results into one.
void	GridCloseableIterator.close() Closes the iterator and frees all the resources held by the iterator.
R	GridPlainFutureAdapter.get() Synchronously waits for completion and returns result.
R	GridPlainFuture.get() Synchronously waits for completion and returns result.
R	GridPlainFutureAdapter.get(long timeout, TimeUnit unit) Synchronously waits for completion and returns result.
R	GridPlainFuture.get(long timeout, TimeUnit unit) Synchronously waits for completion and returns result.
boolean	GridIterableAdapter.hasNextX() This method is the same as Iterator.hasNext(), but allows for failure with exception.
boolean	GridIterator.hasNextX() This method is the same as Iterator.hasNext(), but allows for failure with exception.
T	GridIterableAdapter.nextX() This method is the same as Iterator.next(), but allows for failure with exception.
T	GridIterator.nextX() This method is the same as Iterator.next(), but allows for failure with exception.
void	GridIterableAdapter.removeX() This method is the same as Iterator.remove(), but allows for failure with exception.
void	GridIterator.removeX() This method is the same as Iterator.remove(), but allows for failure with exception.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.nio

Subclasses of IgniteCheckedException in org.apache.ignite.internal.util.nio

Modifier and Type	Class and Description
class	GridNioException Nio specific exception.

Methods in org.apache.ignite.internal.util.nio with parameters of type IgniteCheckedException

Modifier and Type	Method and Description
void	GridNioFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioFilterChain.onExceptionCaught(GridNioSession ses, IgniteCheckedException e) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioAsyncNotifyFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioCodecFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioFilter.proceedExceptionCaught(GridNioSession ses, IgniteCheckedException e) Forwards GridNioException event to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedExceptionCaught(GridNioSession ses, IgniteCheckedException e) Forwards GridNioException event to the next logical filter in filter chain.

Methods in org.apache.ignite.internal.util.nio that throw IgniteCheckedException

Modifier and Type	Method and Description
GridNioServer<T>	GridNioServer.Builder.build() Finishes building the instance.
boolean	GridNioFuture.cancel() Cancels this future.
boolean	GridNioFinishedFuture.cancel() Cancels this future.
boolean	GridNioFutureImpl.cancel() Default no-op implementation that always returns false.
Object	GridDirectParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
Object	GridNioParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
byte[]	GridBufferedParser.decode(GridNioSession ses, ByteBuffer buf) This method is called when input bytes are available on the underlying network connection.
void	GridTcpCommunicationClient.doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC) Executes the given handshake closure on opened client passing underlying IO streams.
void	GridTcpNioCommunicationClient.doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC) Executes the given handshake closure on opened client passing underlying IO streams.
void	GridShmemCommunicationClient.doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC) Executes the given handshake closure on opened client passing underlying IO streams.
void	GridCommunicationClient.doHandshake(IgniteInClosure2X<InputStream,OutputStream> handshakeC) Executes the given handshake closure on opened client passing underlying IO streams.
ByteBuffer	GridDirectParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
ByteBuffer	GridNioParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
ByteBuffer	GridBufferedParser.encode(GridNioSession ses, Object msg) This method is called whenever a message should be sent to the network connection and network buffer is ready to be filled with bytes.
R	GridNioFuture.get() Synchronously waits for completion of the operation and returns operation result.
R	GridNioFinishedFuture.get() Synchronously waits for completion of the operation and returns operation result.
R	GridNioFutureImpl.get() Synchronously waits for completion of the operation and returns operation result.
R	GridNioFuture.get(long timeout) Synchronously waits for completion of the operation for up to the timeout specified and returns operation result.
R	GridNioFinishedFuture.get(long timeout) Synchronously waits for completion of the operation for up to the timeout specified and returns operation result.
R	GridNioFutureImpl.get(long timeout) Synchronously waits for completion of the operation for up to the timeout specified and returns operation result.
R	GridNioFuture.get(long timeout, TimeUnit unit) Synchronously waits for completion of the operation for up to the timeout specified and returns operation result.
R	GridNioFinishedFuture.get(long timeout, TimeUnit unit) Synchronously waits for completion of the operation for up to the timeout specified and returns operation result.
R	GridNioFutureImpl.get(long timeout, TimeUnit unit) Synchronously waits for completion of the operation for up to the timeout specified and returns operation result.
protected R	GridNioFutureImpl.get0(long nanosTimeout)
void	GridNioFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridConnectionBytesVerifyFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioAsyncNotifyFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioCodecFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
void	GridNioFilterChain.onMessageReceived(GridNioSession ses, Object msg) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
void	GridNioAsyncNotifyFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
void	GridNioCodecFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
GridNioFuture<?>	GridNioFilter.onPauseReads(GridNioSession ses) Pauses reads for session.
GridNioFuture<?>	GridNioFilterAdapter.onPauseReads(GridNioSession ses) Pauses reads for session.
GridNioFuture<?>	GridNioFilterChain.onPauseReads(GridNioSession ses) Starts chain notification from tail to head.
GridNioFuture<?>	GridNioFilter.onResumeReads(GridNioSession ses) Resumes reads for session.
GridNioFuture<?>	GridNioFilterAdapter.onResumeReads(GridNioSession ses) Resumes reads for session.
GridNioFuture<?>	GridNioFilterChain.onResumeReads(GridNioSession ses) Starts chain notification from tail to head.
GridNioFuture<Boolean>	GridNioFilter.onSessionClose(GridNioSession ses) Invoked when a session close request is performed on session.
GridNioFuture<Boolean>	GridNioFilterChain.onSessionClose(GridNioSession ses) Starts chain notification from tail to head.
GridNioFuture<Boolean>	GridConnectionBytesVerifyFilter.onSessionClose(GridNioSession ses) Invoked when a session close request is performed on session.
GridNioFuture<Boolean>	GridNioAsyncNotifyFilter.onSessionClose(GridNioSession ses) Invoked when a session close request is performed on session.
GridNioFuture<Boolean>	GridNioCodecFilter.onSessionClose(GridNioSession ses) Invoked when a session close request is performed on session.
void	GridNioFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioFilterChain.onSessionClosed(GridNioSession ses) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioAsyncNotifyFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioCodecFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioFilterChain.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridConnectionBytesVerifyFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioAsyncNotifyFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioCodecFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
void	GridNioFilterChain.onSessionOpened(GridNioSession ses) Starts chain notification from head to tail.
void	GridConnectionBytesVerifyFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
void	GridNioAsyncNotifyFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
void	GridNioCodecFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
GridNioFuture<?>	GridNioFilter.onSessionWrite(GridNioSession ses, Object msg) Invoked when a write request is performed on a session.
GridNioFuture<?>	GridNioFilterChain.onSessionWrite(GridNioSession ses, Object msg) Starts chain notification from tail to head.
GridNioFuture<?>	GridConnectionBytesVerifyFilter.onSessionWrite(GridNioSession ses, Object msg) Invoked when a write request is performed on a session.
GridNioFuture<?>	GridNioAsyncNotifyFilter.onSessionWrite(GridNioSession ses, Object msg) Invoked when a write request is performed on a session.
GridNioFuture<?>	GridNioCodecFilter.onSessionWrite(GridNioSession ses, Object msg) Invoked when a write request is performed on a session.
void	GridNioFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioFilterChain.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridConnectionBytesVerifyFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioAsyncNotifyFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioCodecFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.
void	GridNioFilter.proceedExceptionCaught(GridNioSession ses, IgniteCheckedException e) Forwards GridNioException event to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedExceptionCaught(GridNioSession ses, IgniteCheckedException e) Forwards GridNioException event to the next logical filter in filter chain.
void	GridNioFilter.proceedMessageReceived(GridNioSession ses, Object msg) Forwards received message to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedMessageReceived(GridNioSession ses, Object msg) Forwards received message to the next logical filter in filter chain.
GridNioFuture<?>	GridNioFilter.proceedPauseReads(GridNioSession ses) Pauses reads for session.
GridNioFuture<?>	GridNioFilterAdapter.proceedPauseReads(GridNioSession ses) Pauses reads for session.
GridNioFuture<?>	GridNioFilter.proceedResumeReads(GridNioSession ses) Resumes reads for session.
GridNioFuture<?>	GridNioFilterAdapter.proceedResumeReads(GridNioSession ses) Resumes reads for session.
GridNioFuture<Boolean>	GridNioFilter.proceedSessionClose(GridNioSession ses) Forwards session close request to the next logical filter in filter chain.
GridNioFuture<Boolean>	GridNioFilterAdapter.proceedSessionClose(GridNioSession ses) Forwards session close request to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionClosed(GridNioSession ses) Forwards session closed event to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionClosed(GridNioSession ses) Forwards session closed event to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionIdleTimeout(GridNioSession ses) Forwards session idle notification to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionIdleTimeout(GridNioSession ses) Forwards session idle notification to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionOpened(GridNioSession ses) Forwards session opened event to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionOpened(GridNioSession ses) Forwards session opened event to the next logical filter in filter chain.
GridNioFuture<?>	GridNioFilter.proceedSessionWrite(GridNioSession ses, Object msg) Forwards write request to the next logical filter in filter chain.
GridNioFuture<?>	GridNioFilterAdapter.proceedSessionWrite(GridNioSession ses, Object msg) Forwards write request to the next logical filter in filter chain.
void	GridNioFilter.proceedSessionWriteTimeout(GridNioSession ses) Forwards session write timeout notification to the next logical filter in filter chain.
void	GridNioFilterAdapter.proceedSessionWriteTimeout(GridNioSession ses) Forwards session write timeout notification to the next logical filter in filter chain.
byte[]	GridNioServerBuffer.read(ByteBuffer buf)
void	GridTcpCommunicationClient.sendMessage(byte[] data, int len)
void	GridTcpNioCommunicationClient.sendMessage(byte[] data, int len)
void	GridShmemCommunicationClient.sendMessage(byte[] data, int len)
void	GridCommunicationClient.sendMessage(byte[] data, int len)
void	GridTcpCommunicationClient.sendMessage(ByteBuffer data)
void	GridTcpNioCommunicationClient.sendMessage(ByteBuffer data)
void	GridShmemCommunicationClient.sendMessage(ByteBuffer data)
void	GridCommunicationClient.sendMessage(ByteBuffer data)
boolean	GridTcpCommunicationClient.sendMessage(UUID nodeId, MessageAdapter msg)
boolean	GridTcpNioCommunicationClient.sendMessage(UUID nodeId, MessageAdapter msg)
boolean	GridShmemCommunicationClient.sendMessage(UUID nodeId, MessageAdapter msg)
boolean	GridCommunicationClient.sendMessage(UUID nodeId, MessageAdapter msg)

Constructors in org.apache.ignite.internal.util.nio that throw IgniteCheckedException

Constructor and Description
GridShmemCommunicationClient(GridNioMetricsListener metricsLsnr, int port, long connTimeout, IgniteLogger log, MessageFormatter formatter)
GridTcpCommunicationClient(GridNioMetricsListener metricsLsnr, InetSocketAddress addr, InetAddress locHost, long connTimeout, boolean tcpNoDelay, int sockRcvBuf, int sockSndBuf, int bufSize, int minBufferedMsgCnt, double bufSizeRatio, MessageFormatter formatter)

Uses of IgniteCheckedException in org.apache.ignite.internal.util.nio.ssl

Methods in org.apache.ignite.internal.util.nio.ssl with parameters of type IgniteCheckedException

Modifier and Type	Method and Description
void	GridNioSslFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.

Methods in org.apache.ignite.internal.util.nio.ssl that throw IgniteCheckedException

Modifier and Type	Method and Description
void	GridNioSslFilter.onExceptionCaught(GridNioSession ses, IgniteCheckedException ex) Invoked when exception is caught in filter processing.
void	GridNioSslFilter.onMessageReceived(GridNioSession ses, Object msg) Invoked when a new messages received.
GridNioFuture<Boolean>	GridNioSslFilter.onSessionClose(GridNioSession ses) Invoked when a session close request is performed on session.
void	GridNioSslFilter.onSessionClosed(GridNioSession ses) Invoked after session get closed.
void	GridNioSslFilter.onSessionIdleTimeout(GridNioSession ses) Called when session is idle for longer time that is allowed by NIO server.
void	GridNioSslFilter.onSessionOpened(GridNioSession ses) Invoked when a new session was created.
GridNioFuture<?>	GridNioSslFilter.onSessionWrite(GridNioSession ses, Object msg) Invoked when a write request is performed on a session.
void	GridNioSslFilter.onSessionWriteTimeout(GridNioSession ses) Called when session has not empty write buffer that has not been fully flushed during max timeout allowed by NIO server.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.nodestart

Methods in org.apache.ignite.internal.util.nodestart that throw IgniteCheckedException

Modifier and Type	Method and Description
static Set<String>	IgniteNodeStartUtils.expandHost(String addr) Parses and expands range of IPs, if needed.
static IgniteBiTuple<Collection<Map<String,Object>>,Map<String,Object>>	IgniteNodeStartUtils.parseFile(File file) Parses INI file.
static Map<String,Collection<IgniteRemoteStartSpecification>>	IgniteNodeStartUtils.specifications(Collection<Map<String,Object>> hosts, Map<String,Object> dflts) Makes specifications.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.typedef

Methods in org.apache.ignite.internal.util.typedef that throw IgniteCheckedException

Modifier and Type	Method and Description
static String	X.resolveIgniteHome() Tries to resolve Ignite installation home folder.
static void	X.waitAll(Iterable<IgniteFuture<?>> futs) Synchronously waits for all futures in the collection.

Uses of IgniteCheckedException in org.apache.ignite.internal.util.worker

Methods in org.apache.ignite.internal.util.worker that throw IgniteCheckedException

Modifier and Type	Method and Description
boolean	GridWorkerFuture.cancel() Default no-op implementation that always returns false.
void	GridWorkerPool.execute(GridWorker w) Schedules runnable task for execution.

Uses of IgniteCheckedException in org.apache.ignite.internal.visor.cache

Methods in org.apache.ignite.internal.visor.cache that throw IgniteCheckedException

Modifier and Type	Method and Description
static VisorCache	VisorCache.from(Ignite ignite, GridCache c, int sample)

Uses of IgniteCheckedException in org.apache.ignite.internal.visor.query

Methods in org.apache.ignite.internal.visor.query that throw IgniteCheckedException

Modifier and Type	Method and Description
static IgniteBiTuple<List<Object[]>,Map.Entry<Object,Object>>	VisorQueryUtils.fetchScanQueryRows(CacheQueryFuture<Map.Entry<Object,Object>> fut, Map.Entry<Object,Object> savedNext, int pageSize) Fetch rows from SCAN query future.
static IgniteBiTuple<List<Object[]>,List<?>>	VisorQueryUtils.fetchSqlQueryRows(CacheQueryFuture<List<?>> fut, List<?> savedNext, int pageSize) Collects rows from sql query future, first time creates meta and column names arrays.

Uses of IgniteCheckedException in org.apache.ignite.internal.visor.util

Methods in org.apache.ignite.internal.visor.util that throw IgniteCheckedException

Modifier and Type	Method and Description
static Path	VisorTaskUtils.resolveIgfsProfilerLogsDir(IgniteFs igfs) Resolve IGFS profiler logs directory.

Uses of IgniteCheckedException in org.apache.ignite.logger.java

Methods in org.apache.ignite.logger.java that throw IgniteCheckedException

Modifier and Type	Method and Description
void	JavaLoggerFileHandler.nodeId(UUID nodeId) Sets Node id and instantiates FileHandler delegate.

Uses of IgniteCheckedException in org.apache.ignite.marshaller

Methods in org.apache.ignite.marshaller that throw IgniteCheckedException

Modifier and Type	Method and Description
byte[]	AbstractMarshaller.marshal(Object obj) Marshals object to byte array.
byte[]	Marshaller.marshal(Object obj) Marshals object to byte array.
void	Marshaller.marshal(Object obj, OutputStream out) Marshals object to the output stream.
<T> T	AbstractMarshaller.unmarshal(byte[] arr, ClassLoader clsLdr) Unmarshals object from byte array using given class loader.
<T> T	Marshaller.unmarshal(byte[] arr, ClassLoader clsLdr) Unmarshals object from byte array using given class loader.
<T> T	Marshaller.unmarshal(InputStream in, ClassLoader clsLdr) Unmarshals object from the output stream using given class loader.

Uses of IgniteCheckedException in org.apache.ignite.marshaller.jdk

Methods in org.apache.ignite.marshaller.jdk that throw IgniteCheckedException

Modifier and Type	Method and Description
void	JdkMarshaller.marshal(Object obj, OutputStream out) Marshals object to the output stream.
<T> T	JdkMarshaller.unmarshal(InputStream in, ClassLoader clsLdr) Unmarshals object from the output stream using given class loader.

Uses of IgniteCheckedException in org.apache.ignite.marshaller.optimized

Methods in org.apache.ignite.marshaller.optimized that throw IgniteCheckedException

Modifier and Type	Method and Description
byte[]	OptimizedMarshaller.marshal(Object obj) Marshals object to byte array.
void	OptimizedMarshaller.marshal(Object obj, OutputStream out) Marshals object to the output stream.
void	OptimizedMarshaller.setClassNamesPath(String path) Specifies a name of the file which lists all class names to be optimized.
<T> T	OptimizedMarshaller.unmarshal(byte[] arr, ClassLoader clsLdr) Unmarshals object from byte array using given class loader.
<T> T	OptimizedMarshaller.unmarshal(InputStream in, ClassLoader clsLdr) Unmarshals object from the output stream using given class loader.

Constructors in org.apache.ignite.marshaller.optimized that throw IgniteCheckedException

Constructor and Description
OptimizedMarshaller(boolean requireSer, List<String> clsNames, String clsNamesPath, int poolSize) Initializes marshaller with given serialization flag.

Uses of IgniteCheckedException in org.apache.ignite.plugin

Methods in org.apache.ignite.plugin that throw IgniteCheckedException

Modifier and Type	Method and Description
void	PluginProvider.onIgniteStart() Callback that notifies that Ignite has successfully started, including all internal components.
void	PluginProvider.start(PluginContext ctx, Map<String,Object> attrs) Starts grid component.
void	PluginProvider.stop(boolean cancel) Stops grid component.

Uses of IgniteCheckedException in org.apache.ignite.plugin.security

Methods in org.apache.ignite.plugin.security that throw IgniteCheckedException

Modifier and Type	Method and Description
GridSecurityCredentials	GridSecurityCredentialsBasicProvider.credentials() Gets security credentials.
GridSecurityCredentials	GridSecurityCredentialsProvider.credentials() Gets security credentials.

Uses of IgniteCheckedException in org.apache.ignite.plugin.segmentation

Methods in org.apache.ignite.plugin.segmentation that throw IgniteCheckedException

Modifier and Type	Method and Description
boolean	GridSegmentationResolver.isValidSegment() Checks whether segment is valid.

Uses of IgniteCheckedException in org.apache.ignite.spi

Methods in org.apache.ignite.spi that throw IgniteCheckedException

Modifier and Type	Method and Description
void	IgniteSpiCloseableIterator.close() Closes the iterator and frees all the resources held by the iterator.

Uses of IgniteCheckedException in org.apache.ignite.spi.communication.tcp

Methods in org.apache.ignite.spi.communication.tcp that throw IgniteCheckedException

Modifier and Type	Method and Description
protected GridCommunicationClient	TcpCommunicationSpi.createNioClient(ClusterNode node)
protected GridCommunicationClient	TcpCommunicationSpi.createShmemClient(ClusterNode node, Integer port)
protected GridCommunicationClient	TcpCommunicationSpi.createTcpClient(ClusterNode node) Establish TCP connection to remote node and returns client.