Uses of Class
org.apache.ignite.IgniteException
-
-
Uses of IgniteException in org.apache.ignite
Subclasses of IgniteException in org.apache.ignite Modifier and Type Class Description classIgniteCacheRestartingExceptionException thrown from ignite cache API if cache is restarting.classIgniteClientDisconnectedExceptionException thrown from Ignite API when client node disconnected from cluster.classIgniteDataStreamerTimeoutExceptionException is thrown when timeout of someIgniteDataStreameroperations occurs.classIgniteDeploymentExceptionDeployment or re-deployment failed.classIgniteInterruptedExceptionThis exception is used to wrap standardInterruptedExceptionintoIgniteException.Methods in org.apache.ignite that throw IgniteException Modifier and Type Method Description booleanIgniteQueue. add(T item)booleanIgniteSet. add(T t)booleanIgniteQueue. addAll(Collection<? extends T> items)booleanIgniteSet. addAll(Collection<? extends T> c)longIgniteAtomicLong. addAndGet(long l)Addsland gets current value of atomic long.longIgniteAtomicSequence. addAndGet(long l)Addslelements to atomic sequence and gets value of atomic sequence.<R> RIgniteCompute. affinityCall(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job)Executes given job on the node where partition is located (the partition is primary on the node)<R> RIgniteCompute. affinityCall(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job)Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).<R> RIgniteCompute. affinityCall(String cacheName, Object affKey, IgniteCallable<R> job)Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).<R> RIgniteQueue. affinityCall(IgniteCallable<R> job)Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).<R> RIgniteSet. affinityCall(IgniteCallable<R> job)Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).<R> IgniteFuture<R>IgniteCompute. affinityCallAsync(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.<R> IgniteFuture<R>IgniteCompute. affinityCallAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<R> IgniteFuture<R>IgniteCompute. affinityCallAsync(String cacheName, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).voidIgniteCompute. affinityRun(@NotNull Collection<String> cacheNames, int partId, IgniteRunnable job)Executes given job on the node where partition is located (the partition is primary on the node)voidIgniteCompute. affinityRun(@NotNull Collection<String> cacheNames, Object affKey, IgniteRunnable job)Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).voidIgniteCompute. affinityRun(String cacheName, Object affKey, IgniteRunnable job)Executes given job on the node where data for provided affinity key is located (a.k.a. affinity co-location).voidIgniteQueue. affinityRun(IgniteRunnable job)Executes given job on collocated queue on the node where the queue is located (a.k.a. affinity co-location).voidIgniteSet. affinityRun(IgniteRunnable job)Executes given job on collocated set on the node where the set is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteCompute. affinityRunAsync(@NotNull Collection<String> cacheNames, int partId, IgniteRunnable job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.IgniteFuture<Void>IgniteCompute. affinityRunAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteCompute. affinityRunAsync(String cacheName, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<T,R>
Collection<R>IgniteCompute. apply(IgniteClosure<T,R> job, Collection<? extends T> args)Executes provided closure job on nodes within the underlying cluster group.<R,T>
RIgniteCompute. apply(IgniteClosure<T,R> job, T arg)Executes provided closure job on a node within the underlying cluster group.<R1,R2,T>
R2IgniteCompute. apply(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)Executes provided closure job on nodes within the underlying cluster group.<T,R>
IgniteFuture<Collection<R>>IgniteCompute. applyAsync(IgniteClosure<T,R> job, Collection<? extends T> args)Executes provided closure job asynchronously on nodes within the underlying cluster group.<R,T>
IgniteFuture<R>IgniteCompute. applyAsync(IgniteClosure<T,R> job, T arg)Executes provided closure job asynchronously on a node within the underlying cluster group.<R1,R2,T>
IgniteFuture<R2>IgniteCompute. applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)Executes provided closure job asynchronously on nodes within the underlying cluster group.IgniteAtomicLongIgnite. atomicLong(String name, long initVal, boolean create)Will get a atomic long from cache and create one if it has not been created yet andcreateflag istrue.IgniteAtomicLongIgnite. atomicLong(String name, AtomicConfiguration cfg, long initVal, boolean create)Will get a atomic long from cache and create one if it has not been created yet andcreateflag istrue.<T> IgniteAtomicReference<T>Ignite. atomicReference(String name, AtomicConfiguration cfg, T initVal, boolean create)Will get a atomic reference from cache and create one if it has not been created yet andcreateflag istrue.<T> IgniteAtomicReference<T>Ignite. atomicReference(String name, T initVal, boolean create)Will get a atomic reference from cache and create one if it has not been created yet andcreateflag istrue.IgniteAtomicSequenceIgnite. atomicSequence(String name, long initVal, boolean create)Will get an atomic sequence from cache and create one if it has not been created yet andcreateflag istrue.IgniteAtomicSequenceIgnite. atomicSequence(String name, AtomicConfiguration cfg, long initVal, boolean create)Will get an atomic sequence from cache and create one if it has not been created yet andcreateflag istrue.<T,S>
IgniteAtomicStamped<T,S>Ignite. atomicStamped(String name, AtomicConfiguration cfg, T initVal, S initStamp, boolean create)Will get a atomic stamped from cache and create one if it has not been created yet andcreateflag istrue.<T,S>
IgniteAtomicStamped<T,S>Ignite. atomicStamped(String name, T initVal, S initStamp, boolean create)Will get a atomic stamped from cache and create one if it has not been created yet andcreateflag istrue.voidIgniteCondition. await()Causes the current thread to wait until it is signalled or interrupted.booleanIgniteCondition. await(long time, TimeUnit unit)Causes the current thread to wait until it is signalled or interrupted, or the specified waiting time elapses.voidIgniteCountDownLatch. await()Causes the current thread to wait until the latch has counted down to zero, unless current thread is interrupted.booleanIgniteCountDownLatch. await(long timeout)Causes the current thread to wait until the latch has counted down to zero, unless the thread is interrupted, or the specified waiting time elapses.booleanIgniteCountDownLatch. await(long timeout, TimeUnit unit)Causes the current thread to wait until the latch has counted down to zero, unless the thread is interrupted, or the specified waiting time elapses.longIgniteCondition. awaitNanos(long nanosTimeout)Causes the current thread to wait until it is signalled or interrupted, or the specified waiting time elapses.voidIgniteCondition. awaitUninterruptibly()Causes the current thread to wait until it is signalled.booleanIgniteCondition. awaitUntil(Date deadline)Causes the current thread to wait until it is signalled or interrupted, or the specified deadline elapses.voidIgniteCluster. baselineAutoAdjustEnabled(boolean baselineAutoAdjustEnabled)voidIgniteCluster. baselineAutoAdjustTimeout(long baselineAutoAdjustTimeout)<R> Collection<R>IgniteCompute. broadcast(IgniteCallable<R> job)Broadcasts given job to all nodes in cluster group.<R,T>
Collection<R>IgniteCompute. broadcast(IgniteClosure<T,R> job, T arg)Broadcasts given closure job with passed in argument to all nodes in the cluster group.voidIgniteCompute. broadcast(IgniteRunnable job)Broadcasts given job to all nodes in the cluster group.<R> IgniteFuture<Collection<R>>IgniteCompute. broadcastAsync(IgniteCallable<R> job)Broadcasts given job asynchronously to all nodes in cluster group.<R,T>
IgniteFuture<Collection<R>>IgniteCompute. broadcastAsync(IgniteClosure<T,R> job, T arg)Broadcasts given closure job asynchronously with passed in argument to all nodes in the cluster group.IgniteFuture<Void>IgniteCompute. broadcastAsync(IgniteRunnable job)Broadcasts given job asynchronously to all nodes in the cluster group.<R> Collection<R>IgniteCompute. call(Collection<? extends IgniteCallable<R>> jobs)Executes collection of jobs on nodes within the underlying cluster group.<R1,R2>
R2IgniteCompute. call(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc)Executes collection of jobs on nodes within the underlying cluster group.<R> RIgniteCompute. call(IgniteCallable<R> job)Executes provided job on a node within the underlying cluster group.<R> IgniteFuture<Collection<R>>IgniteCompute. callAsync(Collection<? extends IgniteCallable<R>> jobs)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R1,R2>
IgniteFuture<R2>IgniteCompute. callAsync(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R> IgniteFuture<R>IgniteCompute. callAsync(IgniteCallable<R> job)Executes provided job asynchronously on a node within the underlying cluster group.voidIgniteServices. cancel(String name)Cancels service deployment.voidIgniteServices. cancelAll()Cancels all deployed services.voidIgniteServices. cancelAll(Collection<String> names)Cancels services with specified names.voidIgniteQueue. clear()voidIgniteQueue. clear(int batchSize)Removes all of the elements from this queue.voidIgniteSet. clear()voidIgnite. close()Closesthisinstance of grid.voidIgniteQueue. close()Removes this queue.voidIgniteSet. close()Removes this set.booleanIgniteAtomicLong. compareAndSet(long expVal, long newVal)Atomically compares current value to the expected value, and if they are equal, sets current value to new value.booleanIgniteAtomicReference. compareAndSet(T expVal, T newVal)Conditionally sets the new value.booleanIgniteAtomicStamped. compareAndSet(T expVal, T newVal, S expStamp, S newStamp)Conditionally sets the new value and new stamp.booleanIgniteQueue. contains(Object item)booleanIgniteSet. contains(Object o)booleanIgniteQueue. containsAll(Collection<?> items)booleanIgniteSet. containsAll(Collection<?> c)intIgniteCountDownLatch. countDown()Decrements the count of the latch, releasing all waiting threads on all nodes if the count reaches zero.intIgniteCountDownLatch. countDown(int val)Decreases the count of the latch using passed in value, releasing all waiting threads on all nodes if the count reaches zero.voidIgniteCountDownLatch. countDownAll()Counts down this latch to zero, releasing all waiting threads on all nodes.IgniteCountDownLatchIgnite. countDownLatch(String name, int cnt, boolean autoDel, boolean create)Gets or creates count down latch.longIgniteAtomicLong. decrementAndGet()Decrements and gets current value of atomic long.booleanIgniteCluster. disableWal(String cacheName)Disables write-ahead logging for specified cache.booleanIgniteCluster. enableWal(String cacheName)Enables write-ahead logging for specified cache.<T,R>
RIgniteCompute. execute(Class<? extends ComputeTask<T,R>> taskCls, T arg)Executes given task on within the cluster group.<T,R>
RIgniteCompute. execute(String taskName, T arg)Executes given task within the cluster group.<T,R>
RIgniteCompute. execute(ComputeTask<T,R> task, T arg)Executes given task within the cluster group.<T,R>
ComputeTaskFuture<R>IgniteCompute. executeAsync(Class<? extends ComputeTask<T,R>> taskCls, T arg)Executes given task asynchronously on within the cluster group.<T,R>
ComputeTaskFuture<R>IgniteCompute. executeAsync(String taskName, T arg)Executes given task asynchronously within the cluster group.<T,R>
ComputeTaskFuture<R>IgniteCompute. executeAsync(ComputeTask<T,R> task, T arg)Executes given task asynchronously within the cluster group.longIgniteAtomicLong. get()Gets current value of atomic long.TIgniteAtomicReference. get()Gets current value of an atomic reference.longIgniteAtomicSequence. get()Gets current value of atomic sequence.IgniteBiTuple<T,S>IgniteAtomicStamped. get()Gets both current value and current stamp of atomic stamped.longIgniteAtomicLong. getAndAdd(long l)Gets current value of atomic long and addsl.longIgniteAtomicSequence. getAndAdd(long l)Gets current value of atomic sequence and addslelements.longIgniteAtomicLong. getAndDecrement()Gets and decrements current value of atomic long.longIgniteAtomicLong. getAndIncrement()Gets and increments current value of atomic long.longIgniteAtomicSequence. getAndIncrement()Gets and increments current value of atomic sequence.longIgniteAtomicLong. getAndSet(long l)Gets current value of atomic long and sets new valuelof atomic long.intIgniteLock. getHoldCount()Queries the number of holds on this lock by the current thread.IgniteConditionIgniteLock. getOrCreateCondition(String name)Returns aConditioninstance for use with thisIgniteLockinstance.static IgniteIgnition. getOrStart(IgniteConfiguration cfg)Gets or starts new grid instance if it hasn't been started yet.intIgniteLock. getWaitQueueLength(IgniteCondition condition)Returns an estimate of the number of threads on this node that are waiting on the given condition associated with this lock.booleanIgniteLock. hasQueuedThread(Thread thread)Queries whether the given thread is waiting to acquire this lock.booleanIgniteLock. hasQueuedThreads()Queries whether any threads on this node are waiting to acquire this lock.booleanIgniteLock. hasWaiters(IgniteCondition condition)Queries whether any threads on this node are waiting on the given condition associated with this lock.longIgniteAtomicLong. incrementAndGet()Increments and gets current value of atomic long.longIgniteAtomicSequence. incrementAndGet()Increments and returns the value of atomic sequence.booleanIgniteLock. isBroken()Returns true if any node that owned the locked failed before releasing the lock.booleanIgniteQueue. isEmpty()booleanIgniteSet. isEmpty()booleanIgniteLock. isHeldByCurrentThread()Queries if this lock is held by the current thread.booleanIgniteLock. isLocked()Queries if this lock is held by any thread on any node.Iterator<T>IgniteQueue. iterator()Iterator<T>IgniteSet. iterator()static <T> TIgnition. loadSpringBean(InputStream springXmlStream, String beanName)Loads Spring bean by its name from given Spring XML configuration file.static <T> TIgnition. loadSpringBean(String springXmlPath, String beanName)Loads Spring bean by its name from given Spring XML configuration file.static <T> TIgnition. loadSpringBean(URL springXmlUrl, String beanName)Loads Spring bean by its name from given Spring XML configuration file.voidIgniteCompute. localDeployTask(Class<? extends ComputeTask> taskCls, ClassLoader clsLdr)Explicitly deploys a task with given class loader on the local node.voidIgniteLock. lock()Acquires the distributed reentrant lock.voidIgniteLock. lockInterruptibly()Acquires the lock unless the current thread is interrupted.booleanIgniteQueue. offer(T item)booleanIgniteQueue. offer(T item, long timeout, TimeUnit unit)TIgniteQueue. peek()TIgniteQueue. poll()TIgniteQueue. poll(long timeout, TimeUnit unit)voidIgniteQueue. put(T item)<T> IgniteQueue<T>Ignite. queue(String name, int cap, @Nullable CollectionConfiguration cfg)Will get a named queue from cache and create one if it has not been created yet andcfgis notnull.IgniteLockIgnite. reentrantLock(String name, boolean failoverSafe, boolean fair, boolean create)Gets or creates reentrant lock.<T extends Event>
UUIDIgniteEvents. remoteListen(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).<T extends Event>
UUIDIgniteEvents. remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).UUIDIgniteMessaging. remoteListen(@Nullable Object topic, IgniteBiPredicate<UUID,?> p)Adds a message listener for a given topic to all nodes in the cluster group (possibly including this node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<UUID>IgniteEvents. remoteListenAsync(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<UUID>IgniteEvents. remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).IgniteFuture<UUID>IgniteMessaging. remoteListenAsync(@Nullable Object topic, IgniteBiPredicate<UUID,?> p)Asynchronously adds a message listener for a given topic to all nodes in the cluster group (possibly including this node if it belongs to the cluster group as well).<T extends Event>
List<T>IgniteEvents. remoteQuery(IgnitePredicate<T> p, long timeout, @org.jetbrains.annotations.Nullable int... types)Queries nodes in this cluster group for events using passed in predicate filter for event selection.<T extends Event>
IgniteFuture<List<T>>IgniteEvents. remoteQueryAsync(IgnitePredicate<T> p, long timeout, @org.jetbrains.annotations.Nullable int... types)Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.booleanIgniteQueue. remove(Object item)booleanIgniteSet. remove(Object o)booleanIgniteQueue. removeAll(Collection<?> items)booleanIgniteSet. removeAll(Collection<?> c)voidIgniteCluster. restartNodes()Restarts nodes satisfying optional set of predicates.voidIgniteCluster. restartNodes(Collection<UUID> ids)Restarts nodes defined by provided IDs.booleanIgniteQueue. retainAll(Collection<?> items)booleanIgniteSet. retainAll(Collection<?> c)voidIgniteCompute. run(Collection<? extends IgniteRunnable> jobs)Executes collection of jobs on grid nodes within the underlying cluster group.voidIgniteCompute. run(IgniteRunnable job)Executes provided job on a node within the underlying cluster group.IgniteFuture<Void>IgniteCompute. runAsync(Collection<? extends IgniteRunnable> jobs)Executes collection of jobs asynchronously on grid nodes within the underlying cluster group.IgniteFuture<Void>IgniteCompute. runAsync(IgniteRunnable job)Executes provided job asynchronously on a node within the underlying cluster group.IgniteSemaphoreIgnite. semaphore(String name, int cnt, boolean failoverSafe, boolean create)Gets or creates semaphore.voidIgniteMessaging. send(@Nullable Object topic, Object msg)Sends given message with specified topic to the nodes in the underlying cluster group.voidIgniteMessaging. send(@Nullable Object topic, Collection<?> msgs)Sends given messages with the specified topic to the nodes in the underlying cluster group.voidIgniteMessaging. sendOrdered(@Nullable Object topic, Object msg, long timeout)Sends given message with specified topic to the nodes in the underlying cluster group.<T> TIgniteServices. serviceProxy(String name, Class<? super T> svcItf, boolean sticky)Gets a handle on remote or local service.<T> TIgniteServices. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, long timeout)Gets a handle on remote or local service with the timeout.<T> TIgniteServices. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, ServiceCallContext callCtx)Gets a handle on remote or local service with the specified caller context.<T> TIgniteServices. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, ServiceCallContext callCtx, long timeout)Gets a handle on remote or local service with the specified caller context and the timeout.<T> IgniteSet<T>Ignite. set(String name, @Nullable CollectionConfiguration cfg)Will get a named set from cache and create one if it has not been created yet andcfgis notnull.voidIgniteAtomicReference. set(T val)Unconditionally sets the value.voidIgniteAtomicStamped. set(T val, S stamp)Unconditionally sets the value and the stamp.voidIgniteCondition. signal()Wakes up one waiting thread.voidIgniteCondition. signalAll()Wakes up all waiting threads.intIgniteQueue. size()intIgniteSet. size()SIgniteAtomicStamped. stamp()Gets current stamp.static IgniteIgnition. start()Starts grid with default configuration.static IgniteIgnition. start(InputStream springCfgStream)Starts all grids specified within given Spring XML configuration input stream.static IgniteIgnition. start(String springCfgPath)Starts all grids specified within given Spring XML configuration file.static IgniteIgnition. start(URL springCfgUrl)Starts all grids specified within given Spring XML configuration file URL.static IgniteIgnition. start(IgniteConfiguration cfg)Starts grid with given configuration.Collection<ClusterStartNodeResult>IgniteCluster. startNodes(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s).Collection<ClusterStartNodeResult>IgniteCluster. startNodes(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s).IgniteFuture<Collection<ClusterStartNodeResult>>IgniteCluster. startNodesAsync(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteCluster. startNodesAsync(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.voidIgniteCluster. state(ClusterState newState)Changes current cluster state to givennewStatecluster state.voidIgniteCluster. stopNodes()Stops nodes satisfying optional set of predicates.voidIgniteCluster. stopNodes(Collection<UUID> ids)Stops nodes defined by provided IDs.voidIgniteEvents. stopRemoteListen(UUID opId)Stops listening to remote events.voidIgniteMessaging. stopRemoteListen(UUID opId)Unregisters all listeners identified with provided operation ID on all nodes in the cluster group.IgniteFuture<Void>IgniteEvents. stopRemoteListenAsync(UUID opId)Asynchronously stops listening to remote events.IgniteFuture<Void>IgniteMessaging. stopRemoteListenAsync(UUID opId)Asynchronously unregisters all listeners identified with provided operation ID on all nodes in the cluster group.TIgniteQueue. take()Object[]IgniteQueue. toArray()<T> T[]IgniteQueue. toArray(T[] a)Object[]IgniteSet. toArray()<T1> T1[]IgniteSet. toArray(T1[] a)booleanIgniteLock. tryLock()Acquires the lock only if it is free at the time of invocation.booleanIgniteLock. tryLock(long timeout, TimeUnit unit)Acquires the lock if it is not held by another thread within the given waiting time and the current thread has not been interrupted.voidIgniteCompute. undeployTask(String taskName)Makes the best attempt to undeploy a task with given name within the underlying cluster group.TIgniteAtomicStamped. value()Gets current value.<T extends Event>
TIgniteEvents. waitForLocal(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Waits for the specified events.<T extends Event>
IgniteFuture<T>IgniteEvents. waitForLocalAsync(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Create future to wait for the specified events. -
Uses of IgniteException in org.apache.ignite.binary
Subclasses of IgniteException in org.apache.ignite.binary Modifier and Type Class Description classBinaryInvalidTypeExceptionException indicating that class needed for deserialization of binary object does not exist.classBinaryObjectExceptionException indicating binary object serialization error. -
Uses of IgniteException in org.apache.ignite.cache.query
Subclasses of IgniteException in org.apache.ignite.cache.query Modifier and Type Class Description classQueryRetryExceptionThe exception is thrown if a query was cancelled or timed out while executing. -
Uses of IgniteException in org.apache.ignite.cache.store.jdbc
Methods in org.apache.ignite.cache.store.jdbc that throw IgniteException Modifier and Type Method Description voidCacheAbstractJdbcStore. start()Starts grid component, called on grid start.voidCacheJdbcStoreSessionListener. start()Starts grid component, called on grid start.voidCacheAbstractJdbcStore. stop()Stops grid component, called on grid shutdown.voidCacheJdbcStoreSessionListener. stop()Stops grid component, called on grid shutdown. -
Uses of IgniteException in org.apache.ignite.client
Methods in org.apache.ignite.client that throw IgniteException Modifier and Type Method Description longClientAtomicLong. addAndGet(long l)Addsland gets current value of atomic long.booleanClientAtomicLong. compareAndSet(long expVal, long newVal)Atomically compares current value to the expected value, and if they are equal, sets current value to new value.longClientAtomicLong. decrementAndGet()Decrements and gets current value of atomic long.longClientAtomicLong. get()Gets current value of atomic long.longClientAtomicLong. getAndAdd(long l)Gets current value of atomic long and addsl.longClientAtomicLong. getAndDecrement()Gets and decrements current value of atomic long.longClientAtomicLong. getAndIncrement()Gets and increments current value of atomic long.longClientAtomicLong. getAndSet(long l)Gets current value of atomic long and sets new valuelof atomic long.longClientAtomicLong. incrementAndGet()Increments and gets current value of atomic long. -
Uses of IgniteException in org.apache.ignite.cluster
Subclasses of IgniteException in org.apache.ignite.cluster Modifier and Type Class Description classClusterGroupEmptyExceptionThis exception defines illegal call on empty cluster group.classClusterTopologyExceptionThis exception is used to indicate error with the cluster topology (e.g., crashed node, etc.).Methods in org.apache.ignite.cluster that throw IgniteException Modifier and Type Method Description ClusterMetricsClusterGroup. metrics()Gets a metrics snapshot for this cluster group. -
Uses of IgniteException in org.apache.ignite.compute
Subclasses of IgniteException in org.apache.ignite.compute Modifier and Type Class Description classComputeExecutionRejectedExceptionThis exception defines execution rejection.classComputeJobFailoverExceptionThis runtime exception can be thrown fromComputeJob.execute()method to force job failover to another node within task topology.classComputeTaskCancelledExceptionThis exception indicates that grid task was cancelled.classComputeTaskTimeoutExceptionThis exception indicates that task execution timed out.classComputeUserUndeclaredExceptionThis exception is thrown when user's code throws undeclared runtime exception.Methods in org.apache.ignite.compute that return IgniteException Modifier and Type Method Description IgniteExceptionComputeJobResult. getException()Gets exception produced by execution of remote job, ornullif remote execution finished normally and did not produce any exceptions.Methods in org.apache.ignite.compute that throw IgniteException Modifier and Type Method Description voidComputeJobSibling. cancel()Sends a request to cancel this sibling.ObjectComputeJob. execute()Executes this job.@Nullable ClusterNodeComputeLoadBalancer. getBalancedNode(ComputeJob job, @Nullable Collection<ClusterNode> exclNodes)Gets the next balanced node according to the underlying load balancing policy.@Nullable ComputeJobSiblingComputeTaskSession. getJobSibling(IgniteUuid jobId)Gets job sibling for a given ID.Collection<ComputeJobSibling>ComputeTaskSession. getJobSiblings()Gets a collection of all grid job siblings.<T> TComputeTaskSession. loadCheckpoint(String key)Loads job's state previously saved viaComputeTaskSession.saveCheckpoint(String, Object, ComputeTaskSessionScope, long)method from an underlying storage for a givenkey.@NotNull Map<? extends ComputeJob,ClusterNode>ComputeTask. map(List<ClusterNode> subgrid, T arg)This method is called to map or split grid task into multiple grid jobs.voidComputeJobMasterLeaveAware. onMasterNodeLeft(ComputeTaskSession ses)A method which is executed in case master node has left topology during job execution.RComputeTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.Collection<ComputeJobSibling>ComputeTaskSession. refreshJobSiblings()Refreshes collection of job siblings.booleanComputeTaskSession. removeCheckpoint(String key)Removes previously saved job's state for a givenkeyfrom an underlying storage.ComputeJobResultPolicyComputeTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Asynchronous callback invoked every time a result from remote execution is received.ComputeJobResultPolicyComputeTaskAdapter. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.voidComputeTaskSession. saveCheckpoint(String key, Object state)Saves intermediate state of a job or task to a storage.voidComputeTaskSession. saveCheckpoint(String key, Object state, ComputeTaskSessionScope scope, long timeout)Saves intermediate state of a job to a storage.voidComputeTaskSession. saveCheckpoint(String key, Object state, ComputeTaskSessionScope scope, long timeout, boolean overwrite)Saves intermediate state of a job or task to a storage.voidComputeTaskContinuousMapper. send(Collection<? extends ComputeJob> jobs)Sends collection of jobs to nodes automatically picked by the underlying load balancer.voidComputeTaskContinuousMapper. send(Map<? extends ComputeJob,ClusterNode> mappedJobs)Sends collection of grid jobs to assigned nodes.voidComputeTaskContinuousMapper. send(ComputeJob job)Sends job to a node automatically picked by the underlying load balancer.voidComputeTaskContinuousMapper. send(ComputeJob job, ClusterNode node)Sends given job to a specific grid node.voidComputeTaskSession. setAttribute(Object key, @Nullable Object val)Sets session attributed.voidComputeTaskSession. setAttributes(Map<?,?> attrs)Sets task attributes.protected abstract Collection<? extends ComputeJob>ComputeTaskSplitAdapter. split(int gridSize, T arg)This is a simplified version ofComputeTask.map(List, Object)method. -
Uses of IgniteException in org.apache.ignite.internal
Subclasses of IgniteException in org.apache.ignite.internal Modifier and Type Class Description classIgniteTooManyOpenFilesExceptionCustom exception forSocketExceptionwith Too many open files error message.classUnregisteredBinaryTypeExceptionException thrown during serialization if binary metadata isn't registered and it's registration isn't allowed.classUnregisteredClassExceptionException thrown during serialization if class isn't registered and it's registration isn't allowed.Methods in org.apache.ignite.internal that return IgniteException Modifier and Type Method Description @Nullable IgniteExceptionGridJobExecuteResponse. getException()IgniteExceptionGridJobResultImpl. getException()Gets exception produced by execution of remote job, ornullif remote execution finished normally and did not produce any exceptions.IgniteExceptionGridJobExecuteResponse. getFakeException()Methods in org.apache.ignite.internal with parameters of type IgniteException Modifier and Type Method Description voidGridJobResultImpl. onResponse(@Nullable Object data, @Nullable IgniteException ex, @Nullable Map<Object,Object> jobAttrs, boolean isCancelled)voidGridJobExecuteResponse. setFakeException(IgniteException fakeEx)Methods in org.apache.ignite.internal that throw IgniteException Modifier and Type Method Description <R> IgniteFuture<R>IgniteComputeImpl. affinityCallAsync(@NotNull Collection<String> cacheNames, int partId, IgniteCallable<R> job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.<R> IgniteFuture<R>IgniteComputeImpl. affinityCallAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<R> IgniteFuture<R>IgniteComputeImpl. affinityCallAsync(String cacheName, Object affKey, IgniteCallable<R> job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteComputeImpl. affinityRunAsync(@NotNull Collection<String> cacheNames, int partId, IgniteRunnable job)Executes given job asynchronously on the node where partition is located (the partition is primary on the node) The data of the partition will not be migrated from the target node while the job is executed.IgniteFuture<Void>IgniteComputeImpl. affinityRunAsync(@NotNull Collection<String> cacheNames, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).IgniteFuture<Void>IgniteComputeImpl. affinityRunAsync(String cacheName, Object affKey, IgniteRunnable job)Executes given job asynchronously on the node where data for provided affinity key is located (a.k.a. affinity co-location).<T,R>
IgniteFuture<Collection<R>>IgniteComputeImpl. applyAsync(IgniteClosure<T,R> job, Collection<? extends T> args)Executes provided closure job asynchronously on nodes within the underlying cluster group.<R,T>
IgniteFuture<R>IgniteComputeImpl. applyAsync(IgniteClosure<T,R> job, T arg)Executes provided closure job asynchronously on a node within the underlying cluster group.<R1,R2,T>
IgniteFuture<R2>IgniteComputeImpl. applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)Executes provided closure job asynchronously on nodes within the underlying cluster group.@Nullable IgniteAtomicLongIgniteKernal. atomicLong(String name, AtomicConfiguration cfg, long initVal, boolean create)Will get a atomic long from cache and create one if it has not been created yet andcreateflag istrue.<T> IgniteAtomicReference<T>IgniteKernal. atomicReference(String name, AtomicConfiguration cfg, T initVal, boolean create)Will get a atomic reference from cache and create one if it has not been created yet andcreateflag istrue.@Nullable IgniteAtomicSequenceIgniteKernal. atomicSequence(String name, AtomicConfiguration cfg, long initVal, boolean create)Will get an atomic sequence from cache and create one if it has not been created yet andcreateflag istrue.<T,S>
IgniteAtomicStamped<T,S>IgniteKernal. atomicStamped(String name, AtomicConfiguration cfg, T initVal, S initStamp, boolean create)Will get a atomic stamped from cache and create one if it has not been created yet andcreateflag istrue.<R> IgniteFuture<Collection<R>>IgniteComputeImpl. broadcastAsync(IgniteCallable<R> job)Broadcasts given job asynchronously to all nodes in cluster group.<R,T>
IgniteFuture<Collection<R>>IgniteComputeImpl. broadcastAsync(IgniteClosure<T,R> job, T arg)Broadcasts given closure job asynchronously with passed in argument to all nodes in the cluster group.IgniteFuture<Void>IgniteComputeImpl. broadcastAsync(IgniteRunnable job)Broadcasts given job asynchronously to all nodes in the cluster group.<R> IgniteFuture<Collection<R>>IgniteComputeImpl. callAsync(Collection<? extends IgniteCallable<R>> jobs)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R1,R2>
IgniteFuture<R2>IgniteComputeImpl. callAsync(Collection<? extends IgniteCallable<R1>> jobs, IgniteReducer<R1,R2> rdc)Executes collection of jobs asynchronously on nodes within the underlying cluster group.<R> IgniteFuture<R>IgniteComputeImpl. callAsync(IgniteCallable<R> job)Executes provided job asynchronously on a node within the underlying cluster group.voidIgniteKernal. close()Closesthisinstance of grid.<T,R>
ComputeTaskFuture<R>IgniteComputeImpl. executeAsync(Class<? extends ComputeTask<T,R>> taskCls, T arg)Executes given task asynchronously on within the cluster group.<T,R>
ComputeTaskFuture<R>IgniteComputeImpl. executeAsync(String taskName, T arg)Executes given task asynchronously within the cluster group.<T,R>
ComputeTaskFuture<R>IgniteComputeImpl. executeAsync(ComputeTask<T,R> task, T arg)Executes given task asynchronously within the cluster group.static T2<Ignite,Boolean>IgnitionEx. getOrStart(IgniteConfiguration cfg)Gets or starts new grid instance if it hasn't been started yet.Map<org.apache.ignite.internal.CheckCpHistTask.CheckCpHistClosureJob,ClusterNode>CheckCpHistTask. map(List<ClusterNode> subgrid, Map<UUID,Map<Integer,Set<Integer>>> arg)This method is called to map or split grid task into multiple grid jobs.BooleanCheckCpHistTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.<T extends Event>
IgniteFuture<UUID>IgniteEventsImpl. remoteListenAsync(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<UUID>IgniteEventsImpl. remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, @org.jetbrains.annotations.Nullable int... types)Asynchronously adds event listener for specified events to all nodes in the cluster group (possibly including local node if it belongs to the cluster group as well).IgniteFuture<UUID>IgniteMessagingImpl. remoteListenAsync(@Nullable Object topic, IgniteBiPredicate<UUID,?> p)Asynchronously adds a message listener for a given topic to all nodes in the cluster group (possibly including this node if it belongs to the cluster group as well).<T extends Event>
IgniteFuture<List<T>>IgniteEventsImpl. remoteQueryAsync(IgnitePredicate<T> p, long timeout, @org.jetbrains.annotations.Nullable int... types)Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event selection.protected booleanGridTaskSessionImpl. removeCheckpoint0(GridTaskSessionInternal ses, String key)ComputeJobResultPolicyCheckCpHistTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.IgniteFuture<Void>IgniteComputeImpl. runAsync(Collection<? extends IgniteRunnable> jobs)Executes collection of jobs asynchronously on grid nodes within the underlying cluster group.IgniteFuture<Void>IgniteComputeImpl. runAsync(IgniteRunnable job)Executes provided job asynchronously on a node within the underlying cluster group.protected voidGridTaskSessionImpl. saveCheckpoint0(GridTaskSessionInternal ses, String key, Object state, ComputeTaskSessionScope scope, long timeout, boolean overwrite)<T> TIgniteServicesEx. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, @Nullable Supplier<Map<String,Object>> callAttrsProvider, long timeout)Gets a remote handle on the service.<T> TIgniteServicesImpl. serviceProxy(String name, Class<? super T> svcItf, boolean sticky)Gets a handle on remote or local service.<T> TIgniteServicesImpl. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, long timeout)Gets a handle on remote or local service with the timeout.<T> TIgniteServicesImpl. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, long timeout, boolean keepBinary)<T> TIgniteServicesImpl. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, @Nullable Supplier<Map<String,Object>> callAttrsProvider, long timeout)Gets a remote handle on the service.<T> TIgniteServicesImpl. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, @Nullable ServiceCallContext callCtx)Gets a handle on remote or local service with the specified caller context.<T> TIgniteServicesImpl. serviceProxy(String name, Class<? super T> svcItf, boolean sticky, @Nullable ServiceCallContext callCtx, long timeout)Gets a handle on remote or local service with the specified caller context and the timeout.<T> IgniteSet<T>IgniteEx. set(String name, int cacheId, boolean collocated, boolean separated)Gets a set from cache by known cache id.<T> IgniteSet<T>IgniteKernal. set(String name, int cacheId, boolean collocated, boolean separated)Gets a set from cache by known cache id.IgniteFuture<Void>IgniteEventsImpl. stopRemoteListenAsync(UUID opId)Asynchronously stops listening to remote events.IgniteFuture<Void>IgniteMessagingImpl. stopRemoteListenAsync(UUID opId)Asynchronously unregisters all listeners identified with provided operation ID on all nodes in the cluster group.<T extends Event>
IgniteFuture<T>IgniteEventsImpl. waitForLocalAsync(@Nullable IgnitePredicate<T> filter, @org.jetbrains.annotations.Nullable int... types)Create future to wait for the specified events.Constructors in org.apache.ignite.internal with parameters of type IgniteException Constructor Description GridJobExecuteResponse(UUID nodeId, IgniteUuid sesId, IgniteUuid jobId, byte[] gridExBytes, IgniteException gridEx, byte[] resBytes, Object res, byte[] jobAttrsBytes, Map<Object,Object> jobAttrs, boolean isCancelled, AffinityTopologyVersion retry) -
Uses of IgniteException in org.apache.ignite.internal.cache.query.index.sorted.client
Methods in org.apache.ignite.internal.cache.query.index.sorted.client that return IgniteException Modifier and Type Method Description IgniteExceptionAbstractClientIndex. unsupported() -
Uses of IgniteException in org.apache.ignite.internal.client.router.impl
Methods in org.apache.ignite.internal.client.router.impl that throw IgniteException Modifier and Type Method Description voidGridTcpRouterImpl. start()Starts router. -
Uses of IgniteException in org.apache.ignite.internal.client.thin
Methods in org.apache.ignite.internal.client.thin that throw IgniteException Modifier and Type Method Description longClientAtomicLongImpl. addAndGet(long l)Addsland gets current value of atomic long.booleanClientAtomicLongImpl. compareAndSet(long expVal, long newVal)Atomically compares current value to the expected value, and if they are equal, sets current value to new value.longClientAtomicLongImpl. decrementAndGet()Decrements and gets current value of atomic long.longClientAtomicLongImpl. get()Gets current value of atomic long.longClientAtomicLongImpl. getAndAdd(long l)Gets current value of atomic long and addsl.longClientAtomicLongImpl. getAndDecrement()Gets and decrements current value of atomic long.longClientAtomicLongImpl. getAndIncrement()Gets and increments current value of atomic long.longClientAtomicLongImpl. getAndSet(long l)Gets current value of atomic long and sets new valuelof atomic long.longClientAtomicLongImpl. incrementAndGet()Increments and gets current value of atomic long. -
Uses of IgniteException in org.apache.ignite.internal.cluster
Methods in org.apache.ignite.internal.cluster that throw IgniteException Modifier and Type Method Description voidIgniteClusterAsyncImpl. baselineAutoAdjustEnabled(boolean baselineAutoAdjustEnabled)voidIgniteClusterAsyncImpl. baselineAutoAdjustTimeout(long baselineAutoAdjustTimeout)booleanIgniteClusterAsyncImpl. disableWal(String cacheName)Disables write-ahead logging for specified cache.booleanIgniteClusterImpl. disableWal(String cacheName)Disables write-ahead logging for specified cache.booleanIgniteClusterAsyncImpl. enableWal(String cacheName)Enables write-ahead logging for specified cache.booleanIgniteClusterImpl. enableWal(String cacheName)Enables write-ahead logging for specified cache.booleanIgniteClusterImpl. isWalEnabled(String cacheName)Checks if write-ahead logging is enabled for specified cache.voidIgniteClusterImpl. restartNodes()Restarts nodes satisfying optional set of predicates.voidIgniteClusterImpl. restartNodes(Collection<UUID> ids)Restarts nodes defined by provided IDs.Collection<ClusterStartNodeResult>IgniteClusterImpl. startNodes(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s).Collection<ClusterStartNodeResult>IgniteClusterImpl. startNodes(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s).IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterAsyncImpl. startNodesAsync(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterAsyncImpl. startNodesAsync(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterImpl. startNodesAsync(File file, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.IgniteFuture<Collection<ClusterStartNodeResult>>IgniteClusterImpl. startNodesAsync(Collection<Map<String,Object>> hosts, @Nullable Map<String,Object> dflts, boolean restart, int timeout, int maxConn)Starts one or more nodes on remote host(s) asynchronously.voidIgniteClusterAsyncImpl. state(ClusterState newState)Changes current cluster state to givennewStatecluster state.voidIgniteClusterEx. state(ClusterState newState, boolean force)Changes current cluster state to givennewStatecluster state.voidIgniteClusterImpl. state(ClusterState newState)Changes current cluster state to givennewStatecluster state.voidIgniteClusterImpl. state(ClusterState newState, boolean force)Changes current cluster state to givennewStatecluster state.voidIgniteClusterImpl. stopNodes()Stops nodes satisfying optional set of predicates.voidIgniteClusterImpl. stopNodes(Collection<UUID> ids)Stops nodes defined by provided IDs. -
Uses of IgniteException in org.apache.ignite.internal.commandline.cache.distribution
Methods in org.apache.ignite.internal.commandline.cache.distribution that throw IgniteException Modifier and Type Method Description protected @Nullable CacheDistributionTaskResultCacheDistributionTask. reduce0(List<ComputeJobResult> list)Actual reduce logic. -
Uses of IgniteException in org.apache.ignite.internal.management
Methods in org.apache.ignite.internal.management that throw IgniteException Modifier and Type Method Description protected @Nullable SystemViewTaskResultSystemViewTask. reduce0(List<ComputeJobResult> results)Actual reduce logic. -
Uses of IgniteException in org.apache.ignite.internal.management.cache
Subclasses of IgniteException in org.apache.ignite.internal.management.cache Modifier and Type Class Description classIdleVerifyExceptionThis exception is used to collect exceptions occured inVerifyBackupPartitionsTaskV2execution.classNoMatchingCachesExceptionRuntime exception that can be thrown inVerifyBackupPartitionsTaskV2when no caches matching given filter options can be found.Methods in org.apache.ignite.internal.management.cache that return types with arguments of type IgniteException Modifier and Type Method Description Collection<IgniteException>IdleVerifyException. exceptions()Methods in org.apache.ignite.internal.management.cache that throw IgniteException Modifier and Type Method Description @NotNull Map<? extends ComputeJob,ClusterNode>VerifyBackupPartitionsDumpTask. map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)This method is called to map or split grid task into multiple grid jobs.@NotNull Map<? extends ComputeJob,ClusterNode>VerifyBackupPartitionsTaskV2. map(List<ClusterNode> subgrid, CacheIdleVerifyCommandArg arg)This method is called to map or split grid task into multiple grid jobs.@Nullable StringVerifyBackupPartitionsDumpTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.@Nullable IdleVerifyResultV2VerifyBackupPartitionsTaskV2. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.protected @Nullable Map<String,CacheConfiguration>CacheConfigurationCollectorTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable ContentionTaskResultContentionTask. reduce0(List<ComputeJobResult> list)Actual reduce logic.protected @Nullable FindAndDeleteGarbageInPersistenceTaskResultFindAndDeleteGarbageInPersistenceTask. reduce0(List<ComputeJobResult> list)Actual reduce logic.protected Map<UUID,IndexForceRebuildTaskRes>IndexForceRebuildTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable Map<UUID,Set<IndexRebuildStatusInfoContainer>>IndexRebuildStatusTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected ScheduleIndexRebuildTaskResScheduleIndexRebuildTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable ValidateIndexesTaskResultValidateIndexesTask. reduce0(List<ComputeJobResult> list)Actual reduce logic.ComputeJobResultPolicyVerifyBackupPartitionsDumpTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.ComputeJobResultPolicyVerifyBackupPartitionsTaskV2. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.Constructor parameters in org.apache.ignite.internal.management.cache with type arguments of type IgniteException Constructor Description IdleVerifyException(Collection<IgniteException> exceptions) -
Uses of IgniteException in org.apache.ignite.internal.management.cdc
Methods in org.apache.ignite.internal.management.cdc that throw IgniteException Modifier and Type Method Description protected @Nullable VoidCdcCacheDataResendTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable VoidCdcDeleteLostSegmentsTask. reduce0(List<ComputeJobResult> results)Actual reduce logic. -
Uses of IgniteException in org.apache.ignite.internal.management.consistency
Methods in org.apache.ignite.internal.management.consistency that throw IgniteException Modifier and Type Method Description protected ConsistencyTaskResultAbstractConsistencyTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected ConsistencyTaskResultConsistencyStatusTask. reduce0(List<ComputeJobResult> results)Actual reduce logic. -
Uses of IgniteException in org.apache.ignite.internal.management.diagnostic
Methods in org.apache.ignite.internal.management.diagnostic that throw IgniteException Modifier and Type Method Description protected @Nullable Map<ClusterNode,ConnectivityResult>ConnectivityTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable Map<ClusterNode,PageLocksResult>PageLocksTask. reduce0(List<ComputeJobResult> results)Actual reduce logic. -
Uses of IgniteException in org.apache.ignite.internal.management.encryption
Methods in org.apache.ignite.internal.management.encryption that return types with arguments of type IgniteException Modifier and Type Method Description Map<UUID,IgniteException>CacheGroupEncryptionTaskResult. exceptions()Methods in org.apache.ignite.internal.management.encryption that throw IgniteException Modifier and Type Method Description protected CacheGroupEncryptionTask.SingleFieldDto<T>CacheGroupEncryptionTask.ReencryptionBaseJob. run(EncryptionCacheGroupArg arg)Execution logic of concrete job. -
Uses of IgniteException in org.apache.ignite.internal.management.kill
Methods in org.apache.ignite.internal.management.kill that throw IgniteException Modifier and Type Method Description protected VoidClientConnectionDropTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable Map<ClusterNode,TxTaskResult>KillTransactionTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable VoidQueryCancelOnInitiatorTask. reduce0(List<ComputeJobResult> results)Actual reduce logic. -
Uses of IgniteException in org.apache.ignite.internal.management.tx
Methods in org.apache.ignite.internal.management.tx that throw IgniteException Modifier and Type Method Description protected GridCacheVersionFetchNearXidVersionTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected @Nullable Map<ClusterNode,TxTaskResult>TxTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected TxTaskResultTxTask.TxJob. run(@Nullable TxCommand.AbstractTxCommandArg arg)Execution logic of concrete job. -
Uses of IgniteException in org.apache.ignite.internal.management.wal
Methods in org.apache.ignite.internal.management.wal that throw IgniteException Modifier and Type Method Description protected @Nullable WalTaskResultWalTask. reduce0(List<ComputeJobResult> results)Actual reduce logic. -
Uses of IgniteException in org.apache.ignite.internal.managers.communication
Subclasses of IgniteException in org.apache.ignite.internal.managers.communication Modifier and Type Class Description classTransmissionCancelledExceptionException is used to cancel a file transmission operation on the receiver.Method parameters in org.apache.ignite.internal.managers.communication with type arguments of type IgniteException Modifier and Type Method Description voidGridIoManager. sendOrderedMessage(ClusterNode node, Object topic, Message msg, byte plc, long timeout, boolean skipOnTimeout, IgniteInClosure<IgniteException> ackC)voidGridIoManager. sendToGridTopic(ClusterNode node, GridTopic topic, Message msg, byte plc, IgniteInClosure<IgniteException> ackC)Methods in org.apache.ignite.internal.managers.communication that throw IgniteException Modifier and Type Method Description voidIgniteMessageFactoryImpl. register(short directType, Supplier<Message> supplier)Register message factory with given direct type. -
Uses of IgniteException in org.apache.ignite.internal.managers.loadbalancer
Methods in org.apache.ignite.internal.managers.loadbalancer that throw IgniteException Modifier and Type Method Description ClusterNodeGridLoadBalancerManager. getBalancedNode(GridTaskSessionImpl ses, List<ClusterNode> top, ComputeJob job) -
Uses of IgniteException in org.apache.ignite.internal.mem
Subclasses of IgniteException in org.apache.ignite.internal.mem Modifier and Type Class Description classIgniteOutOfMemoryException -
Uses of IgniteException in org.apache.ignite.internal.pagemem
Methods in org.apache.ignite.internal.pagemem that throw IgniteException Modifier and Type Method Description voidPageMemory. start()Start page memory.voidPageMemory. stop(boolean deallocate)Stop page memory. -
Uses of IgniteException in org.apache.ignite.internal.pagemem.impl
Methods in org.apache.ignite.internal.pagemem.impl that throw IgniteException Modifier and Type Method Description voidPageMemoryNoStoreImpl. start()Start page memory.voidPageMemoryNoStoreImpl. stop(boolean deallocate)Stop page memory. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.binary
Methods in org.apache.ignite.internal.processors.cache.binary that throw IgniteException Modifier and Type Method Description IgniteBinaryCacheObjectBinaryProcessorImpl. binary()@Nullable ObjectCacheObjectBinaryProcessorImpl. toBinary(@Nullable Object obj, boolean failIfUnregistered) -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.distributed.dht.preloader
Subclasses of IgniteException in org.apache.ignite.internal.processors.cache.distributed.dht.preloader Modifier and Type Class Description classIgniteHistoricalIteratorExceptionThrown whenIgniteHistoricalIteratorcannot iterate over WAL for some reason. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.defragmentation
Methods in org.apache.ignite.internal.processors.cache.persistence.defragmentation that throw IgniteException Modifier and Type Method Description static voidDefragmentationFileUtils. batchRenameDefragmentedCacheGroupPartitions(File workDir, IgniteLogger log)Failure-tolerant batch rename of defragmented partition files.static voidDefragmentationFileUtils. renameTempIndexFile(File workDir)Rename temporary index defragmentation file to a finalized one.static voidDefragmentationFileUtils. renameTempPartitionFile(File workDir, int partId)Rename temporary partition defragmentation file to a finalized one.static booleanDefragmentationFileUtils. skipAlreadyDefragmentedCacheGroup(File workDir, int grpId, IgniteLogger log)Checks whether cache group defragmentation completed or not.static booleanDefragmentationFileUtils. skipAlreadyDefragmentedPartition(File workDir, int grpId, int partId, IgniteLogger log)Checks whether partition has already been defragmented or not.static voidDefragmentationFileUtils. writeDefragmentationCompletionMarker(FileIOFactory ioFactory, File workDir, IgniteLogger log)Creates empty completion marker file in given directory. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.diagnostic.pagelocktracker
Methods in org.apache.ignite.internal.processors.cache.persistence.diagnostic.pagelocktracker that throw IgniteException Modifier and Type Method Description voidPageLockTrackerManager. start()Starts grid component, called on grid start.voidPageLockTrackerManager. stop()Stops grid component, called on grid shutdown. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.evict
Methods in org.apache.ignite.internal.processors.cache.persistence.evict that throw IgniteException Modifier and Type Method Description voidFairFifoPageEvictionTracker. start()Starts grid component, called on grid start.voidNoOpPageEvictionTracker. start()Starts grid component, called on grid start.voidRandom2LruPageEvictionTracker. start()Starts grid component, called on grid start.voidRandomLruPageEvictionTracker. start()Starts grid component, called on grid start.voidFairFifoPageEvictionTracker. stop()Stops grid component, called on grid shutdown.voidNoOpPageEvictionTracker. stop()Stops grid component, called on grid shutdown.voidRandom2LruPageEvictionTracker. stop()Stops grid component, called on grid shutdown.voidRandomLruPageEvictionTracker. stop()Stops grid component, called on grid shutdown. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.migration
Methods in org.apache.ignite.internal.processors.cache.persistence.migration that throw IgniteException Modifier and Type Method Description BooleanUpgradePendingTreeToPerPartitionTask. call() -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.pagemem
Methods in org.apache.ignite.internal.processors.cache.persistence.pagemem that throw IgniteException Modifier and Type Method Description GridMultiCollectionWrapper<FullPageId>PageMemoryEx. beginCheckpoint(IgniteInternalFuture allowToReplace)Gets a collection of dirty page IDs since the last checkpoint.GridMultiCollectionWrapper<FullPageId>PageMemoryImpl. beginCheckpoint(IgniteInternalFuture allowToReplace)Gets a collection of dirty page IDs since the last checkpoint.voidPageMemoryImpl. start()Start page memory.voidPageMemoryImpl. stop(boolean deallocate)Stop page memory. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.snapshot
Subclasses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.snapshot Modifier and Type Class Description classIgniteSnapshotVerifyExceptionCompound snapshot verification exception from the nodes where the verification process executed.Methods in org.apache.ignite.internal.processors.cache.persistence.snapshot that throw IgniteException Modifier and Type Method Description @NotNull Map<? extends ComputeJob,ClusterNode>SnapshotMetadataVerificationTask. map(List<ClusterNode> subgrid, SnapshotMetadataVerificationTaskArg arg)This method is called to map or split grid task into multiple grid jobs.SnapshotPartitionsVerifyTaskResultIncrementalSnapshotVerificationTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.SnapshotMetadataVerificationTaskResultSnapshotMetadataVerificationTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.@Nullable SnapshotPartitionsVerifyTaskResultSnapshotPartitionsVerifyTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.ComputeJobResultPolicyAbstractSnapshotVerificationTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method.ComputeJobResultPolicySnapshotMetadataVerificationTask. result(ComputeJobResult res, List<ComputeJobResult> rcvd)Default implementation which will wait for all jobs to complete before callingComputeTask.reduce(List)method. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.wal.crc
Subclasses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.wal.crc Modifier and Type Class Description classIgniteDataIntegrityViolationExceptionWill be thrown if data integrity violation is found -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.persistence.wal.reader
Methods in org.apache.ignite.internal.processors.cache.persistence.wal.reader that throw IgniteException Modifier and Type Method Description voidStandaloneNoopDiscoverySpi. sendCustomEvent(DiscoverySpiCustomMessage msg)Sends custom message across the ring. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.transactions
Methods in org.apache.ignite.internal.processors.cache.transactions that throw IgniteException Modifier and Type Method Description voidTransactionEventProxyImpl. close()Ends the transaction.voidTransactionEventProxyImpl. commit()Commits this transaction by initiatingtwo-phase-commitprocess.IgniteFuture<Void>TransactionEventProxyImpl. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.IgniteFuture<Void>TransactionProxyImpl. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.IgniteFuture<Void>TransactionProxyRollbackOnlyImpl. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.voidTransactionEventProxyImpl. resume()Resume a transaction if it was previously suspended.voidTransactionProxyImpl. resume()Resume a transaction if it was previously suspended.voidTransactionProxyRollbackOnlyImpl. resume()Resume a transaction if it was previously suspended.voidTransactionEventProxyImpl. rollback()Rolls back this transaction.IgniteFuture<Void>TransactionEventProxyImpl. rollbackAsync()Asynchronously rolls back this transaction.IgniteFuture<Void>TransactionProxyImpl. rollbackAsync()Asynchronously rolls back this transaction.voidTransactionEventProxyImpl. suspend()Suspends a transaction.voidTransactionProxyImpl. suspend()Suspends a transaction.voidTransactionProxyRollbackOnlyImpl. suspend()Suspends a transaction. -
Uses of IgniteException in org.apache.ignite.internal.processors.cache.verify
Subclasses of IgniteException in org.apache.ignite.internal.processors.cache.verify Modifier and Type Class Description classGridNotIdleExceptionThis exception defines not idle cluster state, when idle state expected.Methods in org.apache.ignite.internal.processors.cache.verify that throw IgniteException Modifier and Type Method Description Map<PartitionHashRecord,List<PartitionEntryHashRecord>>CollectConflictPartitionKeysTask.CollectPartitionEntryHashesJob. execute()Executes this job.Map<PartitionHashRecord,List<PartitionEntryHashRecord>>RetrieveConflictPartitionValuesTask.RetrieveConflictValuesJob. execute()Executes this job.@NotNull Map<? extends ComputeJob,ClusterNode>CollectConflictPartitionKeysTask. map(List<ClusterNode> subgrid, PartitionKey partKey)This method is called to map or split grid task into multiple grid jobs.@NotNull Map<? extends ComputeJob,ClusterNode>RetrieveConflictPartitionValuesTask. map(List<ClusterNode> subgrid, Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)This method is called to map or split grid task into multiple grid jobs.@Nullable Map<PartitionHashRecord,List<PartitionEntryHashRecord>>CollectConflictPartitionKeysTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method.@Nullable Map<PartitionHashRecord,List<PartitionEntryHashRecord>>RetrieveConflictPartitionValuesTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method. -
Uses of IgniteException in org.apache.ignite.internal.processors.cacheobject
Methods in org.apache.ignite.internal.processors.cacheobject that throw IgniteException Modifier and Type Method Description voidIgniteCacheObjectProcessor. addMeta(int typeId, BinaryType newMeta, boolean failIfUnregistered)voidIgniteCacheObjectProcessor. addMetaLocally(int typeId, BinaryType newMeta)Adds metadata locally without triggering discovery exchange.IgniteBinaryIgniteCacheObjectProcessor. binary()BinaryObjectIgniteCacheObjectProcessor. buildEnum(String typeName, int ord)BinaryObjectIgniteCacheObjectProcessor. buildEnum(String typeName, String name)ObjectIgniteCacheObjectProcessor. marshalToBinary(Object obj, boolean failIfUnregistered)Collection<BinaryType>IgniteCacheObjectProcessor. metadata()@Nullable BinaryTypeIgniteCacheObjectProcessor. metadata(int typeId)@Nullable BinaryTypeIgniteCacheObjectProcessor. metadata(int typeId, int schemaId)Map<Integer,BinaryType>IgniteCacheObjectProcessor. metadata(Collection<Integer> typeIds)BinaryTypeIgniteCacheObjectProcessor. registerEnum(String typeName, Map<String,Integer> vals)Register enum type@Nullable ObjectIgniteCacheObjectProcessor. unwrapTemporary(GridCacheContext ctx, @Nullable Object obj)Converts temporary off-heap object to heap-based.voidIgniteCacheObjectProcessor. updateMetadata(int typeId, String typeName, @Nullable String affKeyFieldName, Map<String,BinaryFieldMetadata> fieldTypeIds, boolean isEnum, @Nullable Map<String,Integer> enumMap) -
Uses of IgniteException in org.apache.ignite.internal.processors.cluster
Subclasses of IgniteException in org.apache.ignite.internal.processors.cluster Modifier and Type Class Description classBaselineAdjustForbiddenExceptionException which would be throw during force changing baseline if cluster has incorrect configuration. -
Uses of IgniteException in org.apache.ignite.internal.processors.datastructures
Methods in org.apache.ignite.internal.processors.datastructures that return IgniteException Modifier and Type Method Description protected IgniteExceptionAtomicDataStructureProxy. checkRemovedAfterFail(Exception cause)Checks removed status after fail.Methods in org.apache.ignite.internal.processors.datastructures that throw IgniteException Modifier and Type Method Description protected voidAtomicDataStructureProxy. checkRemoved()Check removed status.voidGridCacheQueueAdapter. clear(int batchSize)Removes all of the elements from this queue.booleanGridAtomicCacheQueueImpl. offer(T item)booleanGridCacheQueueAdapter. offer(T item, long timeout, TimeUnit unit)booleanGridTransactionalCacheQueueImpl. offer(T item)TGridCacheQueueAdapter. peek()TGridAtomicCacheQueueImpl. poll()TGridCacheQueueAdapter. poll(long timeout, TimeUnit unit)TGridTransactionalCacheQueueImpl. poll()voidGridCacheQueueAdapter. put(T item)TGridCacheQueueAdapter. take()booleanGridCacheSemaphoreImpl. tryAcquire(long timeout, TimeUnit unit)Acquires a permit from this semaphore, if one becomes available within the given waiting time and the current thread has not been interrupted. -
Uses of IgniteException in org.apache.ignite.internal.processors.platform.cache.affinity
Methods in org.apache.ignite.internal.processors.platform.cache.affinity that throw IgniteException Modifier and Type Method Description voidPlatformAffinityFunction. start()Starts grid component, called on grid start.voidPlatformAffinityFunction. stop()Stops grid component, called on grid shutdown. -
Uses of IgniteException in org.apache.ignite.internal.processors.platform.client
Subclasses of IgniteException in org.apache.ignite.internal.processors.platform.client Modifier and Type Class Description classIgniteClientExceptionClient exception. -
Uses of IgniteException in org.apache.ignite.internal.processors.platform.datastreamer
Methods in org.apache.ignite.internal.processors.platform.datastreamer that throw IgniteException Modifier and Type Method Description voidPlatformStreamReceiverImpl. receive(IgniteCache<Object,Object> cache, Collection<Map.Entry<Object,Object>> collection)Updates cache with batch of entries. -
Uses of IgniteException in org.apache.ignite.internal.processors.platform.dotnet
Methods in org.apache.ignite.internal.processors.platform.dotnet that throw IgniteException Modifier and Type Method Description voidPlatformDotNetCacheStore. start()Starts grid component, called on grid start.voidPlatformDotNetCacheStore. stop()Stops grid component, called on grid shutdown. -
Uses of IgniteException in org.apache.ignite.internal.processors.query
Subclasses of IgniteException in org.apache.ignite.internal.processors.query Modifier and Type Class Description classIgniteSQLExceptionSpecific exception bearing information about query processing errors for more detailed errors in JDBC driver.Methods in org.apache.ignite.internal.processors.query that throw IgniteException Modifier and Type Method Description GridQueryIndexingGridQueryProcessor. getIndexing()RunningQueryManagerGridQueryProcessor. runningQueryManager() -
Uses of IgniteException in org.apache.ignite.internal.processors.query.stat
Subclasses of IgniteException in org.apache.ignite.internal.processors.query.stat Modifier and Type Class Description classGatherStatisticCancelException -
Uses of IgniteException in org.apache.ignite.internal.processors.security.sandbox
Methods in org.apache.ignite.internal.processors.security.sandbox that throw IgniteException Modifier and Type Method Description <T> TAccessControllerSandbox. execute(Callable<T> c)Executescallablewith constraints defined by currentSecuritySubject.<T> TIgniteSandbox. execute(Callable<T> call)Executescallablewith constraints defined by currentSecuritySubject.<T> TNoOpSandbox. execute(Callable<T> call)Executescallablewith constraints defined by currentSecuritySubject. -
Uses of IgniteException in org.apache.ignite.internal.processors.service
Subclasses of IgniteException in org.apache.ignite.internal.processors.service Modifier and Type Class Description classGridServiceMethodNotFoundExceptionException thrown if service is not found.Methods in org.apache.ignite.internal.processors.service that throw IgniteException Modifier and Type Method Description <T> TIgniteServiceProcessor. serviceProxy(ClusterGroup prj, String name, Class<? super T> srvcCls, boolean sticky, @Nullable Supplier<Map<String,Object>> callAttrsProvider, long timeout, boolean keepBinary) -
Uses of IgniteException in org.apache.ignite.internal.processors.tracing.configuration
Methods in org.apache.ignite.internal.processors.tracing.configuration that throw IgniteException Modifier and Type Method Description voidGridTracingConfigurationManager. resetAll(@Nullable Scope scope)Reset tracing configuration for the specific scope, or all tracing configurations if scope not specified.voidNoopTracingConfigurationManager. resetAll(@Nullable Scope scope)Reset tracing configuration for the specific scope, or all tracing configurations if scope not specified. -
Uses of IgniteException in org.apache.ignite.internal.sql
Subclasses of IgniteException in org.apache.ignite.internal.sql Modifier and Type Class Description classSqlParseExceptionParse exception.classSqlStrictParseExceptionParse exception guarantees parse error without. -
Uses of IgniteException in org.apache.ignite.internal.util
Methods in org.apache.ignite.internal.util that return IgniteException Modifier and Type Method Description static IgniteExceptionIgniteUtils. convertException(IgniteCheckedException e)Methods in org.apache.ignite.internal.util that return types with arguments of type IgniteException Modifier and Type Method Description static C1<IgniteCheckedException,IgniteException>IgniteUtils. getExceptionConverter(Class<? extends IgniteCheckedException> clazz)Gets IgniteClosure for an IgniteCheckedException class.Methods in org.apache.ignite.internal.util that throw IgniteException Modifier and Type Method Description static voidIgniteUtils. assertParameter(boolean cond, String condDesc)Throws exception with uniform error message if given parameter's assertion condition isfalse. -
Uses of IgniteException in org.apache.ignite.internal.util.future
Methods in org.apache.ignite.internal.util.future that throw IgniteException Modifier and Type Method Description booleanIgniteFutureImpl. cancel()Cancels this future.@NotNull Map<? extends ComputeJob,ClusterNode>IgniteRemoteMapTask. map(List<ClusterNode> subgrid, T arg)This method is called to map or split grid task into multiple grid jobs.RIgniteRemoteMapTask. reduce(List<ComputeJobResult> results)Reduces (or aggregates) results received so far into one compound result to be returned to caller viaComputeTaskFuture.get()method. -
Uses of IgniteException in org.apache.ignite.internal.util.lang
Subclasses of IgniteException in org.apache.ignite.internal.util.lang Modifier and Type Class Description classGridClosureExceptionThis exception provides closures with facility to throw exceptions. -
Uses of IgniteException in org.apache.ignite.internal.util.nio
Fields in org.apache.ignite.internal.util.nio with type parameters of type IgniteException Modifier and Type Field Description protected IgniteInClosure<IgniteException>GridNioFutureImpl. ackCMethods in org.apache.ignite.internal.util.nio that return types with arguments of type IgniteException Modifier and Type Method Description IgniteInClosure<IgniteException>GridNioFinishedFuture. ackClosure()IgniteInClosure<IgniteException>GridNioFuture. ackClosure()IgniteInClosure<IgniteException>GridNioFutureImpl. ackClosure()IgniteInClosure<IgniteException>SessionWriteRequest. ackClosure()Method parameters in org.apache.ignite.internal.util.nio with type arguments of type IgniteException Modifier and Type Method Description GridNioFuture<?>GridConnectionBytesVerifyFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioAsyncNotifyFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioCodecFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioFilterChain. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Starts chain notification from tail to head.GridNioFuture<?>GridNioTracerFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session.GridNioFuture<?>GridNioFilter. proceedSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Forwards write request to the next logical filter in filter chain.GridNioFuture<?>GridNioFilterAdapter. proceedSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Forwards write request to the next logical filter in filter chain.booleanGridCommunicationClient. sendMessage(@Nullable UUID nodeId, Message msg, @Nullable IgniteInClosure<IgniteException> c)booleanGridTcpNioCommunicationClient. sendMessage(@Nullable UUID nodeId, Message msg, IgniteInClosure<IgniteException> c)voidGridNioSession. sendNoFuture(Object msg, @Nullable IgniteInClosure<IgniteException> ackC)voidGridNioSessionImpl. sendNoFuture(Object msg, IgniteInClosure<IgniteException> ackC)Constructor parameters in org.apache.ignite.internal.util.nio with type arguments of type IgniteException Constructor Description GridNioFutureImpl(IgniteInClosure<IgniteException> ackC) -
Uses of IgniteException in org.apache.ignite.internal.util.nio.ssl
Method parameters in org.apache.ignite.internal.util.nio.ssl with type arguments of type IgniteException Modifier and Type Method Description GridNioFuture<?>GridNioSslFilter. onSessionWrite(GridNioSession ses, Object msg, boolean fut, IgniteInClosure<IgniteException> ackC)Invoked when a write request is performed on a session. -
Uses of IgniteException in org.apache.ignite.internal.visor
Methods in org.apache.ignite.internal.visor that throw IgniteException Modifier and Type Method Description protected abstract RVisorMultiNodeTask. reduce0(List<ComputeJobResult> results)Actual reduce logic.protected abstract RVisorJob. run(A arg)Execution logic of concrete job. -
Uses of IgniteException in org.apache.ignite.internal.visor.util
Subclasses of IgniteException in org.apache.ignite.internal.visor.util Modifier and Type Class Description classVisorClusterGroupEmptyExceptionException to throw from Visor tasks in case of empty topology. -
Uses of IgniteException in org.apache.ignite.lang
Subclasses of IgniteException in org.apache.ignite.lang Modifier and Type Class Description classIgniteFutureCancelledExceptionFuture computation cannot be retrieved because it was cancelled.classIgniteFutureTimeoutExceptionFuture computation completion is timed out.Methods in org.apache.ignite.lang that throw IgniteException Modifier and Type Method Description booleanIgniteFuture. cancel()Cancels this future.VIgniteFuture. get()Synchronously waits for completion of the computation and returns computation result.VIgniteFuture. get(long timeout)Synchronously waits for completion of the computation for up to the timeout specified and returns computation result.VIgniteFuture. get(long timeout, TimeUnit unit)Synchronously waits for completion of the computation for up to the timeout specified and returns computation result. -
Uses of IgniteException in org.apache.ignite.lifecycle
Methods in org.apache.ignite.lifecycle that throw IgniteException Modifier and Type Method Description voidLifecycleBean. onLifecycleEvent(LifecycleEventType evt)This method is called when lifecycle event occurs.voidLifecycleAware. start()Starts grid component, called on grid start.voidLifecycleAware. stop()Stops grid component, called on grid shutdown. -
Uses of IgniteException in org.apache.ignite.messaging
Methods in org.apache.ignite.messaging that throw IgniteException Modifier and Type Method Description protected voidMessagingListenActor. respond(@Nullable Object respMsg)Responds to the original sender node with given message and continues to listen for the new messages.protected voidMessagingListenActor. respond(UUID id, @Nullable Object respMsg)Responds to the provided node with given message and continues to listen for the new messages.protected voidMessagingListenActor. stop(@Nullable Object respMsg)This method sends the response message to the original sender node and instructs underlying implementation to stop receiving new messages and unregister the message listener. -
Uses of IgniteException in org.apache.ignite.mxbean
Methods in org.apache.ignite.mxbean that throw IgniteException Modifier and Type Method Description voidMetricsMxBean. configureHistogramMetric(String name, long[] bounds)Deprecated.ChangeHistogramMetricconfiguration.voidMetricsMxBean. configureHitRateMetric(String name, long rateTimeInterval)Deprecated.ChangeHitRateMetricconfiguration. -
Uses of IgniteException in org.apache.ignite.platform.dotnet
Methods in org.apache.ignite.platform.dotnet that throw IgniteException Modifier and Type Method Description voidPlatformDotNetAffinityFunction. start()Starts grid component, called on grid start.voidPlatformDotNetAffinityFunction. stop()Stops grid component, called on grid shutdown. -
Uses of IgniteException in org.apache.ignite.plugin
Subclasses of IgniteException in org.apache.ignite.plugin Modifier and Type Class Description classPluginNotFoundExceptionException thrown if plugin is not found.classPluginValidationExceptionPlugin validation exception. -
Uses of IgniteException in org.apache.ignite.plugin.extensions.communication
Methods in org.apache.ignite.plugin.extensions.communication that throw IgniteException Modifier and Type Method Description voidMessageFactory. register(short directType, Supplier<Message> supplier)Register message factory with given direct type. -
Uses of IgniteException in org.apache.ignite.plugin.security
Subclasses of IgniteException in org.apache.ignite.plugin.security Modifier and Type Class Description classSecurityExceptionCommon security exception for the grid. -
Uses of IgniteException in org.apache.ignite.scheduler
Methods in org.apache.ignite.scheduler that throw IgniteException Modifier and Type Method Description RSchedulerFuture. last()Gets result of the last execution of scheduled task, ornullif task has not been executed, or has not produced a result yet.longSchedulerFuture. nextExecutionTime()Gets next execution time of scheduled task.long[]SchedulerFuture. nextExecutionTimes(int cnt, long start)Gets an array of the next execution times after passedstarttimestamp. -
Uses of IgniteException in org.apache.ignite.services
Subclasses of IgniteException in org.apache.ignite.services Modifier and Type Class Description classServiceDeploymentExceptionException indicating service deployment failure. -
Uses of IgniteException in org.apache.ignite.spi
Subclasses of IgniteException in org.apache.ignite.spi Modifier and Type Class Description classIgniteSpiExceptionException thrown by SPI implementations.classIgniteSpiMultiExceptionGrid SPI exception which may contain more than one failure.classIgniteSpiVersionCheckExceptionGrid SPI exception for version check failure.Methods in org.apache.ignite.spi that throw IgniteException Modifier and Type Method Description SecuritySubjectIgniteSpiContext. authenticatedSubject(UUID subjId)Gets security subject based on subject ID.Collection<SecuritySubject>IgniteSpiContext. authenticatedSubjects()Gets collection of authenticated subjects together with their permissions. -
Uses of IgniteException in org.apache.ignite.spi.communication.tcp
Method parameters in org.apache.ignite.spi.communication.tcp with type arguments of type IgniteException Modifier and Type Method Description voidTcpCommunicationSpi. sendMessage(ClusterNode node, Message msg, IgniteInClosure<IgniteException> ackC)Sends given message to destination node. -
Uses of IgniteException in org.apache.ignite.spi.communication.tcp.internal
Subclasses of IgniteException in org.apache.ignite.spi.communication.tcp.internal Modifier and Type Class Description classNodeUnreachableExceptionException is thrown byTcpCommunicationSpiwhen some or all addresses of a node are unreachable and direct communication connection cannot be established. -
Uses of IgniteException in org.apache.ignite.spi.discovery
Methods in org.apache.ignite.spi.discovery that throw IgniteException Modifier and Type Method Description SecurityContextDiscoverySpiNodeAuthenticator. authenticateNode(ClusterNode node, SecurityCredentials cred)Security credentials.voidDiscoverySpi. sendCustomEvent(DiscoverySpiCustomMessage msg)Sends custom message across the ring. -
Uses of IgniteException in org.apache.ignite.spi.discovery.isolated
Methods in org.apache.ignite.spi.discovery.isolated that throw IgniteException Modifier and Type Method Description voidIsolatedDiscoverySpi. sendCustomEvent(DiscoverySpiCustomMessage msg)Sends custom message across the ring. -
Uses of IgniteException in org.apache.ignite.spi.discovery.tcp
Methods in org.apache.ignite.spi.discovery.tcp that throw IgniteException Modifier and Type Method Description voidTcpDiscoverySpi. sendCustomEvent(DiscoverySpiCustomMessage msg)Sends custom message across the ring. -
Uses of IgniteException in org.apache.ignite.spi.encryption
Methods in org.apache.ignite.spi.encryption that throw IgniteException Modifier and Type Method Description SerializableEncryptionSpi. create()Creates new key for an encryption/decryption of cache persistent data: pages, WAL records. -
Uses of IgniteException in org.apache.ignite.spi.encryption.keystore
Methods in org.apache.ignite.spi.encryption.keystore that throw IgniteException Modifier and Type Method Description KeystoreEncryptionKeyKeystoreEncryptionSpi. create()Creates new key for an encryption/decryption of cache persistent data: pages, WAL records. -
Uses of IgniteException in org.apache.ignite.spi.encryption.noop
Methods in org.apache.ignite.spi.encryption.noop that throw IgniteException Modifier and Type Method Description SerializableNoopEncryptionSpi. create()Creates new key for an encryption/decryption of cache persistent data: pages, WAL records. -
Uses of IgniteException in org.apache.ignite.spi.failover
Methods in org.apache.ignite.spi.failover that throw IgniteException Modifier and Type Method Description ClusterNodeFailoverContext. getBalancedNode(List<ClusterNode> top)Gets the next balanced node for failed job. -
Uses of IgniteException in org.apache.ignite.spi.loadbalancing
Methods in org.apache.ignite.spi.loadbalancing that throw IgniteException Modifier and Type Method Description ClusterNodeLoadBalancingSpi. getBalancedNode(ComputeTaskSession ses, List<ClusterNode> top, ComputeJob job)Gets balanced node for specified job within given task session. -
Uses of IgniteException in org.apache.ignite.spi.tracing
Methods in org.apache.ignite.spi.tracing that throw IgniteException Modifier and Type Method Description default @NotNull TracingConfigurationParametersTracingConfigurationManager. get(@NotNull TracingConfigurationCoordinates coordinates)Get the most specific tracing parameters for the specified tracing coordinates (scope, label, etc.).@NotNull Map<TracingConfigurationCoordinates,TracingConfigurationParameters>TracingConfigurationManager. getAll(@Nullable Scope scope)List all pairs of tracing configuration coordinates and tracing configuration parameters or list all pairs of tracing configuration and parameters for the specific scope.voidTracingConfigurationManager. reset(@NotNull TracingConfigurationCoordinates coordinates)Reset tracing configuration for the specific tracing coordinates (scope, label, etc.) to default values.voidTracingConfigurationManager. resetAll(@Nullable Scope scope)Reset tracing configuration for the specific scope, or all tracing configurations if scope not specified.voidTracingConfigurationManager. set(@NotNull TracingConfigurationCoordinates coordinates, @NotNull TracingConfigurationParameters parameters)Set new tracing configuration for the specific tracing coordinates (scope, label, etc.). -
Uses of IgniteException in org.apache.ignite.stream
Methods in org.apache.ignite.stream that throw IgniteException Modifier and Type Method Description voidStreamReceiver. receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries)Updates cache with batch of entries.voidStreamTransformer. receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries)Updates cache with batch of entries.voidStreamVisitor. receive(IgniteCache<K,V> cache, Collection<Map.Entry<K,V>> entries)Updates cache with batch of entries. -
Uses of IgniteException in org.apache.ignite.transactions
Subclasses of IgniteException in org.apache.ignite.transactions Modifier and Type Class Description classTransactionDeadlockExceptionTransaction deadlock exception.classTransactionExceptionBase class for all transaction related exceptions.classTransactionHeuristicExceptionException thrown whenever grid transaction enters an unknown state.classTransactionOptimisticExceptionException thrown whenever grid transactions fail optimistically.classTransactionRollbackExceptionException thrown whenever grid transactions has been automatically rolled back.classTransactionTimeoutExceptionException thrown whenever transactions time out.Methods in org.apache.ignite.transactions that throw IgniteException Modifier and Type Method Description voidTransaction. close()Ends the transaction.voidTransaction. commit()Commits this transaction by initiatingtwo-phase-commitprocess.IgniteFuture<Void>Transaction. commitAsync()Asynchronously commits this transaction by initiatingtwo-phase-commitprocess.voidTransaction. resume()Resume a transaction if it was previously suspended.voidTransaction. rollback()Rolls back this transaction.IgniteFuture<Void>Transaction. rollbackAsync()Asynchronously rolls back this transaction.voidTransaction. suspend()Suspends a transaction.
-