| Package | Description |
|---|---|
| org.apache.ignite.configuration |
Contains configuration-related classes.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.managers.communication |
TODO.
|
| org.apache.ignite.internal.managers.swapspace |
TODO.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.util |
System-wide utility routine and helper classes.
|
| org.apache.ignite.internal.util.future |
Future related classes.
|
| org.apache.ignite.internal.util.lang | |
| org.apache.ignite.internal.util.nio |
NIO server interfaces and common utility classes for NIO.
|
| org.apache.ignite.internal.util.typedef |
Contains typedefs definitions for frequently used classes.
|
| org.apache.ignite.lang |
Contains general language constructs and functional APIs for distributed computations.
|
| org.apache.ignite.spi.communication.tcp |
Contains default TCP/IP-based implementation for communication SPI.
|
| org.apache.ignite.spi.discovery.tcp |
Contains default TCP/IP implementation for discovery SPI.
|
| org.apache.ignite.spi.swapspace |
Contains APIs for swap space SPI.
|
| org.apache.ignite.spi.swapspace.file |
Contains file-based swap space SPI.
|
| org.apache.ignite.spi.swapspace.noop |
Contains default no-op swap space SPI implementation.
|
| org.apache.ignite.startup |
Contains Ignite runtime startup classes.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInClosure<IgniteConfiguration> |
IgniteConfiguration.getWarmupClosure()
Gets grid warmup closure.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteConfiguration |
IgniteConfiguration.setWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos)
Sets warmup closure to execute before grid startup.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteInternalFuture.listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridIoManager.send(ClusterNode node,
GridTopic topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackClosure) |
void |
GridIoManager.send(ClusterNode node,
Object topic,
Message msg,
byte plc,
IgniteInClosure<IgniteException> ackClosure) |
void |
GridIoManager.sendOrderedMessage(ClusterNode node,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackClosure) |
void |
GridIoManager.sendOrderedMessage(UUID nodeId,
Object topic,
Message msg,
byte plc,
long timeout,
boolean skipOnTimeout,
IgniteInClosure<IgniteException> ackClosure) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridSwapSpaceManager.remove(String spaceName,
Object key,
IgniteInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
void |
GridSwapSpaceManager.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
| Modifier and Type | Class and Description |
|---|---|
protected static class |
GridCacheAdapter.UpdateGetTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdatePutAndGetTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdatePutTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdateRemoveTimeStatClosure<T> |
protected static class |
GridCacheAdapter.UpdateTimeStatClosure<T> |
| Modifier and Type | Method and Description |
|---|---|
static IgniteInClosure<IgniteInternalFuture<?>> |
GridCacheUtils.errorLogger(IgniteLogger log,
Class<? extends Exception>... excl) |
| Modifier and Type | Method and Description |
|---|---|
static GridJavaProcess |
GridJavaProcess.exec(Class cls,
String params,
IgniteLogger log,
IgniteInClosure<String> printC,
GridAbsClosure procKilledC)
Executes main() method of the given class in a separate system process.
|
static GridJavaProcess |
GridJavaProcess.exec(Class cls,
String params,
IgniteLogger log,
IgniteInClosure<String> printC,
GridAbsClosure procKilledC,
Collection<String> jvmArgs,
String cp)
Executes main() method of the given class in a separate system process.
|
static GridJavaProcess |
GridJavaProcess.exec(String clsName,
String params,
IgniteLogger log,
IgniteInClosure<String> printC,
GridAbsClosure procKilledC,
Collection<String> jvmArgs,
String cp)
Executes main() method of the given class in a separate system process.
|
void |
GridCircularBuffer.forEach(IgniteInClosure<T> c)
Executes given closure for every item in circular buffer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridFutureChainListener<T,R>
Future listener to fill chained future with converted result of the source future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteFutureImpl.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFutureAdapter.listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr0)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFinishedFuture.listen(IgniteInClosure<? super IgniteInternalFuture<T>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteInClosureX<T>
Convenient in-closure subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> GridAbsClosure |
GridFunc.curry(IgniteInClosure<? super T> f,
T e)
Curries given closure.
|
static <X> void |
GridFunc.forEach(Iterable<? extends X> c,
IgniteInClosure<? super X> f,
IgnitePredicate<? super X>... p)
Calls given
side-effect only closure over the each element of the provided
collection. |
static <X> void |
GridFunc.forEach(X[] c,
IgniteInClosure<? super X> f,
IgnitePredicate<? super X>... p)
Calls given
side-effect only closure over the each element of the provided array. |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteInClosure<IgniteException> |
GridNioFutureImpl.ackClosure |
| Modifier and Type | Method and Description |
|---|---|
IgniteInClosure<IgniteException> |
GridNioFutureImpl.ackClosure() |
IgniteInClosure<IgniteException> |
GridNioFinishedFuture.ackClosure() |
IgniteInClosure<IgniteException> |
GridNioFuture.ackClosure() |
| Modifier and Type | Method and Description |
|---|---|
void |
GridNioFutureImpl.ackClosure(IgniteInClosure<IgniteException> closure)
Sets ack closure which will be applied when ack recevied.
|
void |
GridNioFinishedFuture.ackClosure(IgniteInClosure<IgniteException> closure)
Sets ack closure which will be applied when ack recevied.
|
void |
GridNioFuture.ackClosure(IgniteInClosure<IgniteException> closure)
Sets ack closure which will be applied when ack recevied.
|
boolean |
GridShmemCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> closure) |
boolean |
GridTcpNioCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> closure) |
boolean |
GridCommunicationClient.sendMessage(UUID nodeId,
Message msg,
IgniteInClosure<IgniteException> closure) |
GridNioFuture<?> |
GridNioServer.sendSystem(GridNioSession ses,
Message msg,
IgniteInClosure<? super IgniteInternalFuture<?>> lsnr)
Adds message at the front of the queue without acquiring back pressure semaphore.
|
boolean |
GridNioRecoveryDescriptor.tryReserve(long id,
IgniteInClosure<Boolean> c) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
CI1<T>
Defines
alias for IgniteInClosure by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
CIX1<T>
Defines
alias for IgniteInClosureX by extending it. |
| Modifier and Type | Method and Description |
|---|---|
void |
IgniteFuture.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
TcpCommunicationSpi.sendMessage(ClusterNode node,
Message msg,
IgniteInClosure<IgniteException> ackClosure)
Sends given message to destination node.
|
| Modifier and Type | Field and Description |
|---|---|
protected CopyOnWriteArrayList<IgniteInClosure<Socket>> |
TcpDiscoverySpi.incomeConnLsnrs |
protected CopyOnWriteArrayList<IgniteInClosure<TcpDiscoveryAbstractMessage>> |
TcpDiscoverySpi.sendMsgLsnrs |
| Modifier and Type | Method and Description |
|---|---|
void |
TcpDiscoverySpi.addIncomeConnectionListener(IgniteInClosure<Socket> lsnr)
FOR TEST ONLY!!!
|
void |
TcpDiscoverySpi.addSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)
FOR TEST ONLY!!!
|
void |
TcpDiscoverySpi.removeIncomeConnectionListener(IgniteInClosure<Socket> lsnr)
FOR TEST ONLY!!!
|
void |
TcpDiscoverySpi.removeSendMessageListener(IgniteInClosure<TcpDiscoveryAbstractMessage> lsnr)
FOR TEST ONLY!!!
|
| Modifier and Type | Method and Description |
|---|---|
void |
SwapSpaceSpi.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
SwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
FileSwapSpaceSpi.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
SwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
NoopSwapSpaceSpi.remove(String spaceName,
SwapKey key,
IgniteInClosure<byte[]> c,
SwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
| Modifier and Type | Class and Description |
|---|---|
class |
BasicWarmupClosure
Basic warm-up closure which warm-ups cache operations.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.4.0 Release Date : September 24 2015