| Modifier and Type | Class and Description |
|---|---|
class |
IgniteCacheRestartingException
Exception thrown from ignite cache API if cache is restarting.
|
class |
IgniteClientDisconnectedException
Exception thrown from Ignite API when client node disconnected from cluster.
|
class |
IgniteDataStreamerTimeoutException
Exception is thrown when timeout of some
IgniteDataStreamer operations occurs. |
class |
IgniteDeploymentException
Deployment or re-deployment failed.
|
class |
IgniteInterruptedException
This exception is used to wrap standard
InterruptedException into IgniteException. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
IgniteQueue.add(T item) |
boolean |
IgniteSet.add(T t) |
boolean |
IgniteQueue.addAll(Collection<? extends T> items) |
boolean |
IgniteSet.addAll(Collection<? extends T> c) |
long |
IgniteAtomicSequence.addAndGet(long l)
Adds
l elements to atomic sequence and gets value of atomic sequence. |
long |
IgniteAtomicLong.addAndGet(long l)
Adds
l and gets current value of atomic long. |
<R> R |
IgniteCompute.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)
It's guaranteed that the data of all the partitions of all participating caches,
the affinity key belongs to, will present on the destination node throughout the job execution.
|
<R> R |
IgniteCompute.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> R |
IgniteQueue.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> R |
IgniteSet.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> R |
IgniteCompute.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> 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).
|
void |
IgniteCompute.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)
It's guaranteed that the data of all the partitions of all participating caches,
the affinity key belongs to, will present on the destination node throughout the job execution.
|
void |
IgniteCompute.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).
|
void |
IgniteQueue.affinityRun(IgniteRunnable job)
Executes given job on collocated queue on the node where the queue is located
(a.k.a. affinity co-location).
|
void |
IgniteSet.affinityRun(IgniteRunnable job)
Executes given job on collocated set on the node where the set is located
(a.k.a. affinity co-location).
|
void |
IgniteCompute.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).
|
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> R |
IgniteCompute.apply(IgniteClosure<T,R> job,
T arg)
Executes provided closure job on a node within the underlying cluster group.
|
<R1,R2,T> R2 |
IgniteCompute.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.
|
IgniteAtomicLong |
Ignite.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 and
create flag
is true. |
IgniteAtomicLong |
Ignite.atomicLong(String name,
long initVal,
boolean create)
Will get a atomic long from cache and create one if it has not been created yet and
create flag
is true. |
<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 and
create flag
is true. |
<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 and
create flag
is true. |
IgniteAtomicSequence |
Ignite.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 and
create flag
is true. |
IgniteAtomicSequence |
Ignite.atomicSequence(String name,
long initVal,
boolean create)
Will get an atomic sequence from cache and create one if it has not been created yet and
create flag
is true. |
<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 and
create flag
is true. |
<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 and
create flag
is true. |
void |
IgniteCountDownLatch.await()
Causes the current thread to wait until the latch has counted down to
zero, unless current thread is interrupted.
|
void |
IgniteCondition.await()
Causes the current thread to wait until it is signalled or
interrupted.
|
boolean |
IgniteCountDownLatch.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.
|
boolean |
IgniteCountDownLatch.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.
|
boolean |
IgniteCondition.await(long time,
TimeUnit unit)
Causes the current thread to wait until it is signalled or interrupted,
or the specified waiting time elapses.
|
long |
IgniteCondition.awaitNanos(long nanosTimeout)
Causes the current thread to wait until it is signalled or interrupted,
or the specified waiting time elapses.
|
void |
IgniteCondition.awaitUninterruptibly()
Causes the current thread to wait until it is signalled.
|
boolean |
IgniteCondition.awaitUntil(Date deadline)
Causes the current thread to wait until it is signalled or interrupted,
or the specified deadline elapses.
|
void |
IgniteCluster.baselineAutoAdjustEnabled(boolean baselineAutoAdjustEnabled) |
void |
IgniteCluster.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.
|
void |
IgniteCompute.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> R2 |
IgniteCompute.call(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs on nodes within the underlying cluster group.
|
<R> R |
IgniteCompute.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.
|
void |
IgniteServices.cancel(String name)
Cancels service deployment.
|
void |
IgniteServices.cancelAll()
Cancels all deployed services.
|
void |
IgniteServices.cancelAll(Collection<String> names)
Cancels services with specified names.
|
void |
IgniteQueue.clear() |
void |
IgniteSet.clear() |
void |
IgniteQueue.clear(int batchSize)
Removes all of the elements from this queue.
|
void |
IgniteQueue.close()
Removes this queue.
|
void |
IgniteSet.close()
Removes this set.
|
void |
Ignite.close()
Closes
this instance of grid. |
boolean |
IgniteAtomicLong.compareAndSet(long expVal,
long newVal)
Atomically compares current value to the expected value, and if they are equal, sets current value
to new value.
|
boolean |
IgniteAtomicReference.compareAndSet(T expVal,
T newVal)
Conditionally sets the new value.
|
boolean |
IgniteAtomicStamped.compareAndSet(T expVal,
T newVal,
S expStamp,
S newStamp)
Conditionally sets the new value and new stamp.
|
boolean |
IgniteQueue.contains(Object item) |
boolean |
IgniteSet.contains(Object o) |
boolean |
IgniteQueue.containsAll(Collection<?> items) |
boolean |
IgniteSet.containsAll(Collection<?> c) |
int |
IgniteCountDownLatch.countDown()
Decrements the count of the latch, releasing all waiting threads
on all nodes if the count reaches zero.
|
int |
IgniteCountDownLatch.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.
|
void |
IgniteCountDownLatch.countDownAll()
Counts down this latch to zero, releasing all waiting threads on all nodes.
|
IgniteCountDownLatch |
Ignite.countDownLatch(String name,
int cnt,
boolean autoDel,
boolean create)
Gets or creates count down latch.
|
long |
IgniteAtomicLong.decrementAndGet()
Decrements and gets current value of atomic long.
|
boolean |
IgniteCluster.disableWal(String cacheName)
Disables write-ahead logging for specified cache.
|
boolean |
IgniteCluster.enableWal(String cacheName)
Enables write-ahead logging for specified cache.
|
<T,R> R |
IgniteCompute.execute(Class<? extends ComputeTask<T,R>> taskCls,
T arg)
Executes given task on within the cluster group.
|
<T,R> R |
IgniteCompute.execute(ComputeTask<T,R> task,
T arg)
Executes given task within the cluster group.
|
<T,R> R |
IgniteCompute.execute(String taskName,
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(ComputeTask<T,R> task,
T arg)
Executes given task asynchronously within the cluster group.
|
<T,R> ComputeTaskFuture<R> |
IgniteCompute.executeAsync(String taskName,
T arg)
Executes given task asynchronously within the cluster group.
|
long |
IgniteAtomicSequence.get()
Gets current value of atomic sequence.
|
long |
IgniteAtomicLong.get()
Gets current value of atomic long.
|
IgniteBiTuple<T,S> |
IgniteAtomicStamped.get()
Gets both current value and current stamp of atomic stamped.
|
T |
IgniteAtomicReference.get()
Gets current value of an atomic reference.
|
long |
IgniteAtomicSequence.getAndAdd(long l)
Gets current value of atomic sequence and adds
l elements. |
long |
IgniteAtomicLong.getAndAdd(long l)
Gets current value of atomic long and adds
l. |
long |
IgniteAtomicLong.getAndDecrement()
Gets and decrements current value of atomic long.
|
long |
IgniteAtomicSequence.getAndIncrement()
Gets and increments current value of atomic sequence.
|
long |
IgniteAtomicLong.getAndIncrement()
Gets and increments current value of atomic long.
|
long |
IgniteAtomicLong.getAndSet(long l)
Gets current value of atomic long and sets new value
l of atomic long. |
int |
IgniteLock.getHoldCount()
Queries the number of holds on this lock by the current thread.
|
IgniteCondition |
IgniteLock.getOrCreateCondition(String name)
Returns a
Condition instance for use with this
IgniteLock instance. |
static Ignite |
Ignition.getOrStart(IgniteConfiguration cfg)
Gets or starts new grid instance if it hasn't been started yet.
|
int |
IgniteLock.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.
|
boolean |
IgniteLock.hasQueuedThread(Thread thread)
Queries whether the given thread is waiting to acquire this
lock.
|
boolean |
IgniteLock.hasQueuedThreads()
Queries whether any threads on this node are waiting to acquire this lock.
|
boolean |
IgniteLock.hasWaiters(IgniteCondition condition)
Queries whether any threads on this node are waiting on the given condition
associated with this lock.
|
long |
IgniteAtomicSequence.incrementAndGet()
Increments and returns the value of atomic sequence.
|
long |
IgniteAtomicLong.incrementAndGet()
Increments and gets current value of atomic long.
|
boolean |
IgniteLock.isBroken()
Returns true if any node that owned the locked failed before releasing the lock.
|
boolean |
IgniteQueue.isEmpty() |
boolean |
IgniteSet.isEmpty() |
boolean |
IgniteLock.isHeldByCurrentThread()
Queries if this lock is held by the current thread.
|
boolean |
IgniteLock.isLocked()
Queries if this lock is held by any thread on any node.
|
Iterator<T> |
IgniteQueue.iterator() |
Iterator<T> |
IgniteSet.iterator() |
static <T> T |
Ignition.loadSpringBean(InputStream springXmlStream,
String beanName)
Loads Spring bean by its name from given Spring XML configuration file.
|
static <T> T |
Ignition.loadSpringBean(String springXmlPath,
String beanName)
Loads Spring bean by its name from given Spring XML configuration file.
|
static <T> T |
Ignition.loadSpringBean(URL springXmlUrl,
String beanName)
Loads Spring bean by its name from given Spring XML configuration file.
|
void |
IgniteCompute.localDeployTask(Class<? extends ComputeTask> taskCls,
ClassLoader clsLdr)
Explicitly deploys a task with given class loader on the local node.
|
void |
IgniteLock.lock()
Acquires the distributed reentrant lock.
|
void |
IgniteLock.lockInterruptibly()
Acquires the lock unless the current thread is
interrupted.
|
boolean |
IgniteQueue.offer(T item) |
boolean |
IgniteQueue.offer(T item,
long timeout,
TimeUnit unit) |
T |
IgniteQueue.peek() |
T |
IgniteQueue.poll() |
T |
IgniteQueue.poll(long timeout,
TimeUnit unit) |
void |
IgniteQueue.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 and
cfg is not
null. |
IgniteLock |
Ignite.reentrantLock(String name,
boolean failoverSafe,
boolean fair,
boolean create)
Gets or creates reentrant lock.
|
<T extends Event> |
IgniteEvents.remoteListen(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
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> |
IgniteEvents.remoteListen(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
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).
|
UUID |
IgniteMessaging.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> |
IgniteEvents.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
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> |
IgniteEvents.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
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> |
IgniteEvents.remoteQuery(IgnitePredicate<T> p,
long timeout,
int... types)
Queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
<T extends Event> |
IgniteEvents.remoteQueryAsync(IgnitePredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
boolean |
IgniteQueue.remove(Object item) |
boolean |
IgniteSet.remove(Object o) |
boolean |
IgniteQueue.removeAll(Collection<?> items) |
boolean |
IgniteSet.removeAll(Collection<?> c) |
void |
IgniteCluster.restartNodes()
Restarts nodes satisfying optional set of predicates.
|
void |
IgniteCluster.restartNodes(Collection<UUID> ids)
Restarts nodes defined by provided IDs.
|
boolean |
IgniteQueue.retainAll(Collection<?> items) |
boolean |
IgniteSet.retainAll(Collection<?> c) |
void |
IgniteCompute.run(Collection<? extends IgniteRunnable> jobs)
Executes collection of jobs on grid nodes within the underlying cluster group.
|
void |
IgniteCompute.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.
|
IgniteSemaphore |
Ignite.semaphore(String name,
int cnt,
boolean failoverSafe,
boolean create)
Gets or creates semaphore.
|
void |
IgniteMessaging.send(@Nullable Object topic,
Collection<?> msgs)
Sends given messages with the specified topic to the nodes in the underlying cluster group.
|
void |
IgniteMessaging.send(@Nullable Object topic,
Object msg)
Sends given message with specified topic to the nodes in the underlying cluster group.
|
void |
IgniteMessaging.sendOrdered(@Nullable Object topic,
Object msg,
long timeout)
Sends given message with specified topic to the nodes in the underlying cluster group.
|
<T> T |
IgniteServices.serviceProxy(String name,
Class<? super T> svcItf,
boolean sticky)
Gets a remote handle on the service.
|
<T> T |
IgniteServices.serviceProxy(String name,
Class<? super T> svcItf,
boolean sticky,
long timeout)
Gets a remote handle on the service with 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 and
cfg is not
null. |
void |
IgniteAtomicReference.set(T val)
Unconditionally sets the value.
|
void |
IgniteAtomicStamped.set(T val,
S stamp)
Unconditionally sets the value and the stamp.
|
void |
IgniteCondition.signal()
Wakes up one waiting thread.
|
void |
IgniteCondition.signalAll()
Wakes up all waiting threads.
|
int |
IgniteQueue.size() |
int |
IgniteSet.size() |
S |
IgniteAtomicStamped.stamp()
Gets current stamp.
|
static Ignite |
Ignition.start()
Starts grid with default configuration.
|
static Ignite |
Ignition.start(IgniteConfiguration cfg)
Starts grid with given configuration.
|
static Ignite |
Ignition.start(InputStream springCfgStream)
Starts all grids specified within given Spring XML configuration input stream.
|
static Ignite |
Ignition.start(String springCfgPath)
Starts all grids specified within given Spring XML configuration file.
|
static Ignite |
Ignition.start(URL springCfgUrl)
Starts all grids specified within given Spring XML configuration file URL.
|
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).
|
Collection<ClusterStartNodeResult> |
IgniteCluster.startNodes(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
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.
|
IgniteFuture<Collection<ClusterStartNodeResult>> |
IgniteCluster.startNodesAsync(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s) asynchronously.
|
void |
IgniteCluster.state(ClusterState newState)
Changes current cluster state to given
newState cluster state. |
void |
IgniteCluster.stopNodes()
Stops nodes satisfying optional set of predicates.
|
void |
IgniteCluster.stopNodes(Collection<UUID> ids)
Stops nodes defined by provided IDs.
|
void |
IgniteEvents.stopRemoteListen(UUID opId)
Stops listening to remote events.
|
void |
IgniteMessaging.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.
|
T |
IgniteQueue.take() |
Object[] |
IgniteQueue.toArray() |
Object[] |
IgniteSet.toArray() |
<T> T[] |
IgniteQueue.toArray(T[] a) |
<T1> T1[] |
IgniteSet.toArray(T1[] a) |
boolean |
IgniteLock.tryLock()
Acquires the lock only if it is free at the time of invocation.
|
boolean |
IgniteLock.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.
|
void |
IgniteCompute.undeployTask(String taskName)
Makes the best attempt to undeploy a task with given name within the underlying cluster group.
|
T |
IgniteAtomicStamped.value()
Gets current value.
|
<T extends Event> |
IgniteEvents.waitForLocal(@Nullable IgnitePredicate<T> filter,
int... types)
Waits for the specified events.
|
<T extends Event> |
IgniteEvents.waitForLocalAsync(@Nullable IgnitePredicate<T> filter,
int... types)
Create future to wait for the specified events.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BinaryInvalidTypeException
Exception indicating that class needed for deserialization of binary object does not exist.
|
class |
BinaryObjectException
Exception indicating binary object serialization error.
|
| Modifier and Type | Class and Description |
|---|---|
class |
QueryRetryException
The exception is thrown if a query was cancelled or timed out while executing.
|
| Modifier and Type | Method and Description |
|---|---|
void |
CacheAbstractJdbcStore.start()
Starts grid component, called on grid start.
|
void |
CacheJdbcStoreSessionListener.start()
Starts grid component, called on grid start.
|
void |
CacheAbstractJdbcStore.stop()
Stops grid component, called on grid shutdown.
|
void |
CacheJdbcStoreSessionListener.stop()
Stops grid component, called on grid shutdown.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClusterGroupEmptyException
This exception defines illegal call on empty cluster group.
|
class |
ClusterTopologyException
This exception is used to indicate error with the cluster topology (e.g., crashed node, etc.).
|
| Modifier and Type | Method and Description |
|---|---|
ClusterMetrics |
ClusterGroup.metrics()
Gets a metrics snapshot for this cluster group.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ComputeExecutionRejectedException
This exception defines execution rejection.
|
class |
ComputeJobFailoverException
This runtime exception can be thrown from
ComputeJob.execute() method to force
job failover to another node within task topology. |
class |
ComputeTaskCancelledException
This exception indicates that grid task was cancelled.
|
class |
ComputeTaskTimeoutException
This exception indicates that task execution timed out.
|
class |
ComputeUserUndeclaredException
This exception is thrown when user's code throws undeclared runtime exception.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteException |
ComputeJobResult.getException()
Gets exception produced by execution of remote job, or
null if
remote execution finished normally and did not produce any exceptions. |
| Modifier and Type | Method and Description |
|---|---|
void |
ComputeJobSibling.cancel()
Sends a request to cancel this sibling.
|
Object |
ComputeJob.execute()
Executes this job.
|
@Nullable ClusterNode |
ComputeLoadBalancer.getBalancedNode(ComputeJob job,
@Nullable Collection<ClusterNode> exclNodes)
Gets the next balanced node according to the underlying load balancing policy.
|
@Nullable ComputeJobSibling |
ComputeTaskSession.getJobSibling(IgniteUuid jobId)
Gets job sibling for a given ID.
|
Collection<ComputeJobSibling> |
ComputeTaskSession.getJobSiblings()
Gets a collection of all grid job siblings.
|
<T> T |
ComputeTaskSession.loadCheckpoint(String key)
Loads job's state previously saved via
ComputeTaskSession.saveCheckpoint(String, Object, ComputeTaskSessionScope, long)
method from an underlying storage for a given key. |
@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.
|
void |
ComputeJobMasterLeaveAware.onMasterNodeLeft(ComputeTaskSession ses)
A method which is executed in case master node has left topology during job execution.
|
R |
ComputeTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
Collection<ComputeJobSibling> |
ComputeTaskSession.refreshJobSiblings()
Refreshes collection of job siblings.
|
boolean |
ComputeTaskSession.removeCheckpoint(String key)
Removes previously saved job's state for a given
key from an underlying storage. |
ComputeJobResultPolicy |
ComputeTaskAdapter.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
ComputeJobResultPolicy |
ComputeTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
void |
ComputeTaskSession.saveCheckpoint(String key,
Object state)
Saves intermediate state of a job or task to a storage.
|
void |
ComputeTaskSession.saveCheckpoint(String key,
Object state,
ComputeTaskSessionScope scope,
long timeout)
Saves intermediate state of a job to a storage.
|
void |
ComputeTaskSession.saveCheckpoint(String key,
Object state,
ComputeTaskSessionScope scope,
long timeout,
boolean overwrite)
Saves intermediate state of a job or task to a storage.
|
void |
ComputeTaskContinuousMapper.send(Collection<? extends ComputeJob> jobs)
Sends collection of jobs to nodes automatically picked by the underlying load balancer.
|
void |
ComputeTaskContinuousMapper.send(ComputeJob job)
Sends job to a node automatically picked by the underlying load balancer.
|
void |
ComputeTaskContinuousMapper.send(ComputeJob job,
ClusterNode node)
Sends given job to a specific grid node.
|
void |
ComputeTaskContinuousMapper.send(Map<? extends ComputeJob,ClusterNode> mappedJobs)
Sends collection of grid jobs to assigned nodes.
|
void |
ComputeTaskSession.setAttribute(Object key,
@Nullable Object val)
Sets session attributed.
|
void |
ComputeTaskSession.setAttributes(Map<?,?> attrs)
Sets task attributes.
|
protected abstract Collection<? extends ComputeJob> |
ComputeTaskSplitAdapter.split(int gridSize,
T arg)
This is a simplified version of
ComputeTask.map(List, Object) method. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridifyRuntimeException
This defines gridify exception.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteTooManyOpenFilesException
Custom exception for
SocketException with Too many open files error message. |
class |
UnregisteredBinaryTypeException
Exception thrown during serialization if binary metadata isn't registered and it's registration isn't allowed.
|
class |
UnregisteredClassException
Exception thrown during serialization if class isn't registered and it's registration isn't allowed.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteException |
GridJobResultImpl.getException()
Gets exception produced by execution of remote job, or
null if
remote execution finished normally and did not produce any exceptions. |
@Nullable IgniteException |
GridJobExecuteResponse.getException() |
IgniteException |
GridJobExecuteResponse.getFakeException() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridJobResultImpl.onResponse(@Nullable Object data,
@Nullable IgniteException ex,
@Nullable Map<Object,Object> jobAttrs,
boolean isCancelled) |
void |
GridJobExecuteResponse.setFakeException(IgniteException fakeEx) |
| Modifier and Type | Method and 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 IgniteAtomicLong |
IgniteKernal.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 and
create flag
is true. |
<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 and
create flag
is true. |
@Nullable IgniteAtomicSequence |
IgniteKernal.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 and
create flag
is true. |
<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 and
create flag
is true. |
<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.
|
void |
IgniteKernal.close()
Closes
this instance 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(ComputeTask<T,R> task,
T arg)
Executes given task asynchronously within the cluster group.
|
<T,R> ComputeTaskFuture<R> |
IgniteComputeImpl.executeAsync(String taskName,
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.
|
Boolean |
CheckCpHistTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
<T extends Event> |
IgniteEventsImpl.remoteListenAsync(@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
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> |
IgniteEventsImpl.remoteListenAsync(int bufSize,
long interval,
boolean autoUnsubscribe,
@Nullable IgniteBiPredicate<UUID,T> locLsnr,
@Nullable IgnitePredicate<T> rmtFilter,
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> |
IgniteEventsImpl.remoteQueryAsync(IgnitePredicate<T> p,
long timeout,
int... types)
Asynchronously queries nodes in this cluster group for events using passed in predicate filter for event
selection.
|
protected boolean |
GridTaskSessionImpl.removeCheckpoint0(GridTaskSessionInternal ses,
String key) |
ComputeJobResultPolicy |
CheckCpHistTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.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 void |
GridTaskSessionImpl.saveCheckpoint0(GridTaskSessionInternal ses,
String key,
Object state,
ComputeTaskSessionScope scope,
long timeout,
boolean overwrite) |
<T> T |
IgniteServicesImpl.serviceProxy(String name,
Class<? super T> svcItf,
boolean sticky)
Gets a remote handle on the service.
|
<T> T |
IgniteServicesImpl.serviceProxy(String name,
Class<? super T> svcItf,
boolean sticky,
long timeout)
Gets a remote handle on the service with timeout.
|
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> |
IgniteEventsImpl.waitForLocalAsync(@Nullable IgnitePredicate<T> filter,
int... types)
Create future to wait for the specified events.
|
| Constructor and 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) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridTcpRouterImpl.start()
Starts router.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteClusterAsyncImpl.baselineAutoAdjustEnabled(boolean baselineAutoAdjustEnabled) |
void |
IgniteClusterAsyncImpl.baselineAutoAdjustTimeout(long baselineAutoAdjustTimeout) |
boolean |
IgniteClusterImpl.disableWal(String cacheName)
Disables write-ahead logging for specified cache.
|
boolean |
IgniteClusterAsyncImpl.disableWal(String cacheName)
Disables write-ahead logging for specified cache.
|
boolean |
IgniteClusterImpl.enableWal(String cacheName)
Enables write-ahead logging for specified cache.
|
boolean |
IgniteClusterAsyncImpl.enableWal(String cacheName)
Enables write-ahead logging for specified cache.
|
boolean |
IgniteClusterImpl.isWalEnabled(String cacheName)
Checks if write-ahead logging is enabled for specified cache.
|
void |
IgniteClusterImpl.restartNodes()
Restarts nodes satisfying optional set of predicates.
|
void |
IgniteClusterImpl.restartNodes(Collection<UUID> ids)
Restarts nodes defined by provided IDs.
|
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).
|
Collection<ClusterStartNodeResult> |
IgniteClusterImpl.startNodes(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s).
|
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.
|
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>> |
IgniteClusterAsyncImpl.startNodesAsync(File file,
boolean restart,
int timeout,
int maxConn)
Starts one or more nodes on remote host(s) asynchronously.
|
void |
IgniteClusterImpl.state(ClusterState newState)
Changes current cluster state to given
newState cluster state. |
void |
IgniteClusterAsyncImpl.state(ClusterState newState)
Changes current cluster state to given
newState cluster state. |
void |
IgniteClusterImpl.stopNodes()
Stops nodes satisfying optional set of predicates.
|
void |
IgniteClusterImpl.stopNodes(Collection<UUID> ids)
Stops nodes defined by provided IDs.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable CacheDistributionTaskResult |
CacheDistributionTask.reduce0(List<ComputeJobResult> list)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
@Nullable Boolean |
JdbcConnectionValidationTask.reduce(List<ComputeJobResult> results)
Deprecated.
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
protected Collection<? extends ComputeJob> |
JdbcConnectionValidationTask.split(int gridSize,
Object arg)
Deprecated.
This is a simplified version of
ComputeTask.map(List, Object) method. |
| Modifier and Type | Class and Description |
|---|---|
class |
TransmissionCancelledException
Exception is used to cancel a file transmission operation on the receiver.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackC) |
void |
GridIoManager.sendToGridTopic(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackC) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteMessageFactoryImpl.register(short directType,
Supplier<Message> supplier)
Register message factory with given direct type.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
GridLoadBalancerManager.getBalancedNode(GridTaskSessionImpl ses,
List<ClusterNode> top,
ComputeJob job) |
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteOutOfMemoryException |
| Modifier and Type | Method and Description |
|---|---|
void |
PageMemory.start()
Start page memory.
|
void |
PageMemory.stop(boolean deallocate)
Stop page memory.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PageMemoryNoStoreImpl.start()
Start page memory.
|
void |
PageMemoryNoStoreImpl.stop(boolean deallocate)
Stop page memory.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteBinary |
CacheObjectBinaryProcessorImpl.binary() |
@Nullable Object |
CacheObjectBinaryProcessorImpl.toBinary(@Nullable Object obj,
boolean failIfUnregistered) |
| Modifier and Type | Method and Description |
|---|---|
GridDhtTxLocal |
GridDhtTransactionalCacheAdapter.initTxTopologyVersion(UUID nodeId,
ClusterNode nearNode,
GridCacheVersion nearLockVer,
IgniteUuid nearFutId,
int nearMiniId,
boolean firstClientReq,
AffinityTopologyVersion topVer,
long nearThreadId,
long timeout,
UUID txSubjectId,
int txTaskNameHash,
MvccSnapshot snapshot) |
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteHistoricalIteratorException
Thrown when
IgniteHistoricalIterator cannot iterate over WAL for some reason. |
| Modifier and Type | Method and Description |
|---|---|
static void |
DefragmentationFileUtils.batchRenameDefragmentedCacheGroupPartitions(File workDir,
IgniteLogger log)
Failure-tolerant batch rename of defragmented partition files.
|
static void |
DefragmentationFileUtils.renameTempIndexFile(File workDir)
Rename temporary index defragmentation file to a finalized one.
|
static void |
DefragmentationFileUtils.renameTempPartitionFile(File workDir,
int partId)
Rename temporary partition defragmentation file to a finalized one.
|
static boolean |
DefragmentationFileUtils.skipAlreadyDefragmentedCacheGroup(File workDir,
int grpId,
IgniteLogger log)
Checks whether cache group defragmentation completed or not.
|
static boolean |
DefragmentationFileUtils.skipAlreadyDefragmentedPartition(File workDir,
int grpId,
int partId,
IgniteLogger log)
Checks whether partition has already been defragmented or not.
|
static void |
DefragmentationFileUtils.writeDefragmentationCompletionMarker(FileIOFactory ioFactory,
File workDir,
IgniteLogger log)
Creates empty completion marker file in given directory.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PageLockTrackerManager.start()
Starts grid component, called on grid start.
|
void |
SharedPageLockTracker.start()
Starts grid component, called on grid start.
|
void |
PageLockTrackerManager.stop()
Stops grid component, called on grid shutdown.
|
void |
SharedPageLockTracker.stop()
Stops grid component, called on grid shutdown.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Random2LruPageEvictionTracker.start()
Starts grid component, called on grid start.
|
void |
FairFifoPageEvictionTracker.start()
Starts grid component, called on grid start.
|
void |
RandomLruPageEvictionTracker.start()
Starts grid component, called on grid start.
|
void |
NoOpPageEvictionTracker.start()
Starts grid component, called on grid start.
|
void |
Random2LruPageEvictionTracker.stop()
Stops grid component, called on grid shutdown.
|
void |
FairFifoPageEvictionTracker.stop()
Stops grid component, called on grid shutdown.
|
void |
RandomLruPageEvictionTracker.stop()
Stops grid component, called on grid shutdown.
|
void |
NoOpPageEvictionTracker.stop()
Stops grid component, called on grid shutdown.
|
| Modifier and Type | Method and Description |
|---|---|
Boolean |
UpgradePendingTreeToPerPartitionTask.call() |
| Modifier and Type | Method and Description |
|---|---|
GridMultiCollectionWrapper<FullPageId> |
PageMemoryImpl.beginCheckpoint(IgniteInternalFuture allowToReplace)
Gets a collection of dirty page IDs since the last checkpoint.
|
GridMultiCollectionWrapper<FullPageId> |
PageMemoryEx.beginCheckpoint(IgniteInternalFuture allowToReplace)
Gets a collection of dirty page IDs since the last checkpoint.
|
void |
PageMemoryImpl.start()
Start page memory.
|
void |
PageMemoryImpl.stop(boolean deallocate)
Stop page memory.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteDataIntegrityViolationException
Will be thrown if data integrity violation is found
|
| Modifier and Type | Method and Description |
|---|---|
void |
StandaloneNoopDiscoverySpi.sendCustomEvent(DiscoverySpiCustomMessage msg)
Sends custom message across the ring.
|
| Modifier and Type | Method and Description |
|---|---|
byte[] |
GridCacheQueryJdbcTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
| Modifier and Type | Method and Description |
|---|---|
void |
TransactionEventProxyImpl.close()
Ends the transaction.
|
void |
TransactionEventProxyImpl.commit()
Commits this transaction by initiating
two-phase-commit process. |
IgniteFuture<Void> |
TransactionProxyRollbackOnlyImpl.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
IgniteFuture<Void> |
TransactionProxyImpl.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
IgniteFuture<Void> |
TransactionEventProxyImpl.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
void |
TransactionProxyRollbackOnlyImpl.resume()
Resume a transaction if it was previously suspended.
|
void |
TransactionProxyImpl.resume()
Resume a transaction if it was previously suspended.
|
void |
TransactionEventProxyImpl.resume()
Resume a transaction if it was previously suspended.
|
void |
TransactionEventProxyImpl.rollback()
Rolls back this transaction.
|
IgniteFuture<Void> |
TransactionProxyImpl.rollbackAsync()
Asynchronously rolls back this transaction.
|
IgniteFuture<Void> |
TransactionEventProxyImpl.rollbackAsync()
Asynchronously rolls back this transaction.
|
void |
TransactionProxyRollbackOnlyImpl.suspend()
Suspends a transaction.
|
void |
TransactionProxyImpl.suspend()
Suspends a transaction.
|
void |
TransactionEventProxyImpl.suspend()
Suspends a transaction.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridNotIdleException
This exception defines not idle cluster state, when idle state expected.
|
class |
IdleVerifyException
This exception is used to collect exceptions occured in
VerifyBackupPartitionsTaskV2 execution. |
class |
NoMatchingCachesException
Runtime exception that can be thrown in
VerifyBackupPartitionsTaskV2 when no caches matching given
filter options can be found. |
| Modifier and Type | Method and Description |
|---|---|
Collection<IgniteException> |
IdleVerifyException.exceptions() |
| Modifier and Type | Method and 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> |
RetrieveConflictPartitionValuesTask.map(List<ClusterNode> subgrid,
Map<PartitionHashRecord,List<PartitionEntryHashRecord>> collectTaskRes)
This method is called to map or split grid task into multiple grid jobs.
|
@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> |
VerifyBackupPartitionsTask.map(List<ClusterNode> subgrid,
Set<String> cacheNames)
Deprecated.
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
VerifyBackupPartitionsTaskV2.map(List<ClusterNode> subgrid,
VisorIdleVerifyTaskArg arg)
This method is called to map or split grid task into multiple grid jobs.
|
@NotNull Map<? extends ComputeJob,ClusterNode> |
VerifyBackupPartitionsDumpTask.map(List<ClusterNode> subgrid,
VisorIdleVerifyTaskArg arg)
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 via
ComputeTaskFuture.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 via
ComputeTaskFuture.get() method. |
@Nullable Map<PartitionKey,List<PartitionHashRecord>> |
VerifyBackupPartitionsTask.reduce(List<ComputeJobResult> results)
Deprecated.
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
@Nullable IdleVerifyResultV2 |
VerifyBackupPartitionsTaskV2.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
@Nullable String |
VerifyBackupPartitionsDumpTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
ComputeJobResultPolicy |
VerifyBackupPartitionsTaskV2.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
ComputeJobResultPolicy |
VerifyBackupPartitionsDumpTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Default implementation which will wait for all jobs to complete before
calling
ComputeTask.reduce(List) method. |
| Constructor and Description |
|---|
IdleVerifyException(Collection<IgniteException> exceptions) |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteCacheObjectProcessor.addMeta(int typeId,
BinaryType newMeta,
boolean failIfUnregistered) |
void |
IgniteCacheObjectProcessor.addMetaLocally(int typeId,
BinaryType newMeta)
Adds metadata locally without triggering discovery exchange.
|
IgniteBinary |
IgniteCacheObjectProcessor.binary() |
BinaryObject |
IgniteCacheObjectProcessor.buildEnum(String typeName,
int ord) |
BinaryObject |
IgniteCacheObjectProcessor.buildEnum(String typeName,
String name) |
Object |
IgniteCacheObjectProcessor.marshalToBinary(Object obj,
boolean failIfUnregistered) |
Collection<BinaryType> |
IgniteCacheObjectProcessor.metadata() |
Map<Integer,BinaryType> |
IgniteCacheObjectProcessor.metadata(Collection<Integer> typeIds) |
@Nullable BinaryType |
IgniteCacheObjectProcessor.metadata(int typeId) |
@Nullable BinaryType |
IgniteCacheObjectProcessor.metadata(int typeId,
int schemaId) |
BinaryType |
IgniteCacheObjectProcessor.registerEnum(String typeName,
Map<String,Integer> vals)
Register enum type
|
@Nullable Object |
IgniteCacheObjectProcessor.unwrapTemporary(GridCacheContext ctx,
@Nullable Object obj)
Converts temporary off-heap object to heap-based.
|
void |
IgniteCacheObjectProcessor.updateMetadata(int typeId,
String typeName,
@Nullable String affKeyFieldName,
Map<String,BinaryFieldMetadata> fieldTypeIds,
boolean isEnum,
@Nullable Map<String,Integer> enumMap) |
| Modifier and Type | Class and Description |
|---|---|
class |
BaselineAdjustForbiddenException
Exception which would be throw during force changing baseline if cluster has incorrect configuration.
|
| Modifier and Type | Method and Description |
|---|---|
protected IgniteException |
AtomicDataStructureProxy.checkRemovedAfterFail(Exception cause)
Checks removed status after fail.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheQueueAdapter.clear(int batchSize)
Removes all of the elements from this queue.
|
boolean |
GridTransactionalCacheQueueImpl.offer(T item) |
boolean |
GridAtomicCacheQueueImpl.offer(T item) |
boolean |
GridCacheQueueAdapter.offer(T item,
long timeout,
TimeUnit unit) |
T |
GridCacheQueueAdapter.peek() |
T |
GridTransactionalCacheQueueImpl.poll() |
T |
GridAtomicCacheQueueImpl.poll() |
T |
GridCacheQueueAdapter.poll(long timeout,
TimeUnit unit) |
void |
GridCacheQueueAdapter.put(T item) |
T |
GridCacheQueueAdapter.take() |
boolean |
GridCacheSemaphoreImpl.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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformAffinityFunction.start()
Starts grid component, called on grid start.
|
void |
PlatformAffinityFunction.stop()
Stops grid component, called on grid shutdown.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteClientException
Client exception.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformStreamReceiverImpl.receive(IgniteCache<Object,Object> cache,
Collection<Map.Entry<Object,Object>> collection)
Updates cache with batch of entries.
|
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformDotNetCacheStore.start()
Starts grid component, called on grid start.
|
void |
PlatformDotNetCacheStore.stop()
Stops grid component, called on grid shutdown.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteSQLException
Specific exception bearing information about query processing errors for more detailed
errors in JDBC driver.
|
| Modifier and Type | Method and Description |
|---|---|
GridQueryIndexing |
GridQueryProcessor.getIndexing() |
| Modifier and Type | Method and Description |
|---|---|
<T> T |
AccessControllerSandbox.execute(Callable<T> c)
Executes
callable with constraints defined by current SecuritySubject. |
<T> T |
IgniteSandbox.execute(Callable<T> call)
Executes
callable with constraints defined by current SecuritySubject. |
<T> T |
NoOpSandbox.execute(Callable<T> call)
Executes
callable with constraints defined by current SecuritySubject. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridServiceMethodNotFoundException
Exception thrown if service is not found.
|
| Modifier and Type | Method and Description |
|---|---|
abstract <T> T |
ServiceProcessorAdapter.serviceProxy(ClusterGroup prj,
String name,
Class<? super T> srvcCls,
boolean sticky,
long timeout) |
<T> T |
IgniteServiceProcessor.serviceProxy(ClusterGroup prj,
String name,
Class<? super T> srvcCls,
boolean sticky,
long timeout) |
<T> T |
GridServiceProcessor.serviceProxy(ClusterGroup prj,
String name,
Class<? super T> srvcCls,
boolean sticky,
long timeout)
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridTracingConfigurationManager.resetAll(@Nullable Scope scope)
Reset tracing configuration for the specific scope, or all tracing configurations if scope not specified.
|
void |
NoopTracingConfigurationManager.resetAll(@Nullable Scope scope)
Reset tracing configuration for the specific scope, or all tracing configurations if scope not specified.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SqlParseException
Parse exception.
|
class |
SqlStrictParseException
Parse exception guarantees parse error without.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteException |
IgniteUtils.convertException(IgniteCheckedException e) |
| Modifier and Type | Method and Description |
|---|---|
static C1<IgniteCheckedException,IgniteException> |
IgniteUtils.getExceptionConverter(Class<? extends IgniteCheckedException> clazz)
Gets IgniteClosure for an IgniteCheckedException class.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
IgniteUtils.assertParameter(boolean cond,
String condDesc)
Throws exception with uniform error message if given parameter's assertion condition
is
false. |
| Modifier and Type | Method and Description |
|---|---|
boolean |
IgniteFutureImpl.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.
|
R |
IgniteRemoteMapTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
| Modifier and Type | Method and Description |
|---|---|
GridifyArgument |
GridifyArgumentBuilder.createJobArgument(GridifyRangeArgument arg,
Collection<?> input)
Create
GridifyArgument for job. |
| Modifier and Type | Class and Description |
|---|---|
class |
GridClosureException
This exception provides closures with facility to throw exceptions.
|
| Modifier and Type | Field and Description |
|---|---|
protected IgniteInClosure<IgniteException> |
GridNioFutureImpl.ackC |
| Modifier and Type | Method and Description |
|---|---|
IgniteInClosure<IgniteException> |
GridNioFinishedFuture.ackClosure() |
IgniteInClosure<IgniteException> |
GridNioFuture.ackClosure() |
IgniteInClosure<IgniteException> |
SessionWriteRequest.ackClosure() |
IgniteInClosure<IgniteException> |
GridNioFutureImpl.ackClosure() |
| Modifier and Type | Method and Description |
|---|---|
GridNioFuture<?> |
GridNioCodecFilter.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<?> |
GridNioTracerFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridConnectionBytesVerifyFilter.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<?> |
GridNioFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
GridNioFuture<?> |
GridNioFilterAdapter.proceedSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Forwards write request to the next logical filter in filter chain.
|
GridNioFuture<?> |
GridNioFilter.proceedSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Forwards write request to the next logical filter in filter chain.
|
boolean |
GridTcpNioCommunicationClient.sendMessage(@Nullable UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
boolean |
GridShmemCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> c) |
void |
GridNioSessionImpl.sendNoFuture(Object msg,
IgniteInClosure<IgniteException> ackC) |
| Constructor and Description |
|---|
GridNioFutureImpl(IgniteInClosure<IgniteException> ackC) |
| Modifier and Type | Method and Description |
|---|---|
GridNioFuture<?> |
GridNioSslFilter.onSessionWrite(GridNioSession ses,
Object msg,
boolean fut,
IgniteInClosure<IgniteException> ackC)
Invoked when a write request is performed on a session.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract R |
VisorMultiNodeTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected abstract R |
VisorJob.run(A arg)
Execution logic of concrete job.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<UUID,IgniteException> |
VisorCacheStartTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Map<String,VisorCacheConfiguration> |
VisorCacheConfigurationCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable VisorFindAndDeleteGarbageInPersistenceTaskResult |
VisorFindAndDeleteGarbageInPersistenceTask.reduce0(List<ComputeJobResult> list)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<UUID,Set<IndexRebuildStatusInfoContainer>> |
IndexRebuildStatusTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
@NotNull Map<? extends ComputeJob,ClusterNode> |
VisorGatewayTask.map(List<ClusterNode> subgrid,
@Nullable Object[] args)
This method is called to map or split grid task into multiple grid jobs.
|
@Nullable Object |
VisorGatewayTask.reduce(List<ComputeJobResult> results)
Reduces (or aggregates) results received so far into one compound result to be returned to
caller via
ComputeTaskFuture.get() method. |
ComputeJobResultPolicy |
VisorGatewayTask.result(ComputeJobResult res,
List<ComputeJobResult> rcvd)
Asynchronous callback invoked every time a result from remote execution is
received.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<ClusterNode,VisorPageLocksResult> |
VisorPageLocksTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<ClusterNode,VisorConnectivityResult> |
VisorConnectivityTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
Map<UUID,IgniteException> |
VisorCacheGroupEncryptionTaskResult.exceptions() |
| Modifier and Type | Method and Description |
|---|---|
protected VisorCacheGroupEncryptionTask.VisorSingleFieldDto<T> |
VisorCacheGroupEncryptionTask.VisorReencryptionBaseJob.run(VisorCacheGroupEncryptionTaskArg arg)
Execution logic of concrete job.
|
| Constructor and Description |
|---|
VisorCacheGroupEncryptionTaskResult(Map<UUID,T> results,
Map<UUID,IgniteException> exceptions) |
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable VisorWalTaskResult |
VisorWalTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
static VisorQueryHolder |
VisorQueryUtils.getQueryHolder(IgniteEx ignite,
String qryId)
Get holder for query or throw exception if not found.
|
protected @Nullable Void |
VisorQueryCancelTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Collection<VisorQueryDetailMetrics> |
VisorQueryDetailMetricsCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Void |
VisorQueryCancelOnInitiatorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected @Nullable Map<UUID,Collection<VisorRunningQuery>> |
VisorRunningQueriesCollectorTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable Map<ClusterNode,VisorTxTaskResult> |
VisorTxTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
protected GridCacheVersion |
FetchNearXidVersionTask.reduce0(List<ComputeJobResult> results)
Actual reduce logic.
|
| Modifier and Type | Class and Description |
|---|---|
class |
VisorClusterGroupEmptyException
Exception to throw from Visor tasks in case of empty topology.
|
| Modifier and Type | Method and Description |
|---|---|
protected @Nullable VisorContentionTaskResult |
VisorContentionTask.reduce0(List<ComputeJobResult> list)
Actual reduce logic.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteFutureCancelledException
Future computation cannot be retrieved because it was cancelled.
|
class |
IgniteFutureTimeoutException
Future computation completion is timed out.
|
| Modifier and Type | Method and Description |
|---|---|
boolean |
IgniteFuture.cancel()
Cancels this future.
|
V |
IgniteFuture.get()
Synchronously waits for completion of the computation and
returns computation result.
|
V |
IgniteFuture.get(long timeout)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
V |
IgniteFuture.get(long timeout,
TimeUnit unit)
Synchronously waits for completion of the computation for
up to the timeout specified and returns computation result.
|
| Modifier and Type | Method and Description |
|---|---|
void |
LifecycleBean.onLifecycleEvent(LifecycleEventType evt)
This method is called when lifecycle event occurs.
|
void |
LifecycleAware.start()
Starts grid component, called on grid start.
|
void |
LifecycleAware.stop()
Stops grid component, called on grid shutdown.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
MessagingListenActor.respond(@Nullable Object respMsg)
Responds to the original sender node with given message and continues to listen for the new messages.
|
protected void |
MessagingListenActor.respond(UUID id,
@Nullable Object respMsg)
Responds to the provided node with given message and continues to listen for the new messages.
|
protected void |
MessagingListenActor.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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
MetricsMxBean.configureHistogramMetric(String name,
long[] bounds)
Change
HistogramMetric configuration. |
void |
MetricsMxBean.configureHitRateMetric(String name,
long rateTimeInterval)
Change
HitRateMetric configuration. |
| Modifier and Type | Method and Description |
|---|---|
void |
PlatformDotNetAffinityFunction.start()
Starts grid component, called on grid start.
|
void |
PlatformDotNetAffinityFunction.stop()
Stops grid component, called on grid shutdown.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PluginNotFoundException
Exception thrown if plugin is not found.
|
class |
PluginValidationException
Plugin validation exception.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteMessageFactory.register(short directType,
Supplier<Message> supplier)
Register message factory with given direct type.
|
| Modifier and Type | Class and Description |
|---|---|
class |
SecurityException
Common security exception for the grid.
|
| Modifier and Type | Method and Description |
|---|---|
R |
SchedulerFuture.last()
Gets result of the last execution of scheduled task, or
null if task has not been executed, or has not
produced a result yet. |
long |
SchedulerFuture.nextExecutionTime()
Gets next execution time of scheduled task.
|
long[] |
SchedulerFuture.nextExecutionTimes(int cnt,
long start)
Gets an array of the next execution times after passed
start timestamp. |
| Modifier and Type | Class and Description |
|---|---|
class |
ServiceDeploymentException
Exception indicating service deployment failure.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteSpiException
Exception thrown by SPI implementations.
|
class |
IgniteSpiMultiException
Grid SPI exception which may contain more than one failure.
|
class |
IgniteSpiVersionCheckException
Grid SPI exception for version check failure.
|
| Modifier and Type | Method and Description |
|---|---|
SecuritySubject |
IgniteSpiContext.authenticatedSubject(UUID subjId)
Gets security subject based on subject ID.
|
Collection<SecuritySubject> |
IgniteSpiContext.authenticatedSubjects()
Gets collection of authenticated subjects together with their permissions.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg,
IgniteInClosure<IgniteException> ackC)
Sends given message to destination node.
|
| Modifier and Type | Class and Description |
|---|---|
class |
NodeUnreachableException
Exception is thrown by
TcpCommunicationSpi when some or all addresses of a node are unreachable and
direct communication connection cannot be established. |
| Modifier and Type | Method and Description |
|---|---|
SecurityContext |
DiscoverySpiNodeAuthenticator.authenticateNode(ClusterNode node,
SecurityCredentials cred)
Security credentials.
|
void |
DiscoverySpi.sendCustomEvent(DiscoverySpiCustomMessage msg)
Sends custom message across the ring.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IsolatedDiscoverySpi.sendCustomEvent(DiscoverySpiCustomMessage msg)
Sends custom message across the ring.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoverySpi.sendCustomEvent(DiscoverySpiCustomMessage msg)
Sends custom message across the ring.
|
| Modifier and Type | Method and Description |
|---|---|
Serializable |
EncryptionSpi.create()
Creates new key for an encryption/decryption of cache persistent data: pages, WAL records.
|
| Modifier and Type | Method and Description |
|---|---|
KeystoreEncryptionKey |
KeystoreEncryptionSpi.create()
Creates new key for an encryption/decryption of cache persistent data: pages, WAL records.
|
| Modifier and Type | Method and Description |
|---|---|
Serializable |
NoopEncryptionSpi.create()
Creates new key for an encryption/decryption of cache persistent data: pages, WAL records.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
FailoverContext.getBalancedNode(List<ClusterNode> top)
Gets the next balanced node for failed job.
|
| Modifier and Type | Method and Description |
|---|---|
ClusterNode |
LoadBalancingSpi.getBalancedNode(ComputeTaskSession ses,
List<ClusterNode> top,
ComputeJob job)
Gets balanced node for specified job within given task session.
|
| Modifier and Type | Method and Description |
|---|---|
default @NotNull TracingConfigurationParameters |
TracingConfigurationManager.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.
|
void |
TracingConfigurationManager.reset(@NotNull TracingConfigurationCoordinates coordinates)
Reset tracing configuration for the specific tracing coordinates (scope, label, etc.) to default values.
|
void |
TracingConfigurationManager.resetAll(@Nullable Scope scope)
Reset tracing configuration for the specific scope, or all tracing configurations if scope not specified.
|
void |
TracingConfigurationManager.set(@NotNull TracingConfigurationCoordinates coordinates,
@NotNull TracingConfigurationParameters parameters)
Set new tracing configuration for the specific tracing coordinates (scope, label, etc.).
|
| Modifier and Type | Method and Description |
|---|---|
void |
StreamReceiver.receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
void |
StreamTransformer.receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
void |
StreamVisitor.receive(IgniteCache<K,V> cache,
Collection<Map.Entry<K,V>> entries)
Updates cache with batch of entries.
|
| Modifier and Type | Class and Description |
|---|---|
class |
TransactionAlreadyCompletedException
Exception thrown whenever Mvcc transaction has been finished before operation finished.
|
class |
TransactionDeadlockException
Transaction deadlock exception.
|
class |
TransactionDuplicateKeyException
Exception thrown whenever transaction tries to inserts entry with same mvcc version more than once.
|
class |
TransactionException
Base class for all transaction related exceptions.
|
class |
TransactionHeuristicException
Exception thrown whenever grid transaction enters an unknown state.
|
class |
TransactionMixedModeException
Exception thrown whenever transaction spans over MVCC and non-MVCC caches.
|
class |
TransactionOptimisticException
Exception thrown whenever grid transactions fail optimistically.
|
class |
TransactionRollbackException
Exception thrown whenever grid transactions has been automatically rolled back.
|
class |
TransactionSerializationException
Exception thrown whenever transaction can't be serialized due to write conflict.
|
class |
TransactionTimeoutException
Exception thrown whenever transactions time out.
|
class |
TransactionUnsupportedConcurrencyException
Exception thrown whenever transaction concurrency level is not supported.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Transaction.close()
Ends the transaction.
|
void |
Transaction.commit()
Commits this transaction by initiating
two-phase-commit process. |
IgniteFuture<Void> |
Transaction.commitAsync()
Asynchronously commits this transaction by initiating
two-phase-commit process. |
void |
Transaction.resume()
Resume a transaction if it was previously suspended.
|
void |
Transaction.rollback()
Rolls back this transaction.
|
IgniteFuture<Void> |
Transaction.rollbackAsync()
Asynchronously rolls back this transaction.
|
void |
Transaction.suspend()
Suspends a transaction.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.10.0 Release Date : March 10 2021