Uses of Interface
org.apache.ignite.lang.IgniteInClosure

Packages that use IgniteInClosure

Package	Description
org.apache.ignite.configuration
org.apache.ignite.internal	Contains main implementation.
org.apache.ignite.internal.managers.swapspace	TODO.
org.apache.ignite.internal.processors.cache
org.apache.ignite.internal.processors.cache.distributed.dht
org.apache.ignite.internal.processors.cache.distributed.near
org.apache.ignite.internal.processors.cache.transactions
org.apache.ignite.internal.processors.streamer	TODO.
org.apache.ignite.internal.processors.streamer.task
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.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.
org.apache.ignite.streamer	Contains main Streaming APIs.

Uses of IgniteInClosure in org.apache.ignite.configuration

Methods in org.apache.ignite.configuration that return IgniteInClosure

Modifier and Type	Method and Description
IgniteInClosure<IgniteConfiguration>	IgniteConfiguration.getWarmupClosure() Gets grid warmup closure.

Methods in org.apache.ignite.configuration with parameters of type IgniteInClosure

Modifier and Type	Method and Description
void	IgniteConfiguration.setWarmupClosure(IgniteInClosure<IgniteConfiguration> warmupClos) Sets warmup closure to execute before grid startup.

Uses of IgniteInClosure in org.apache.ignite.internal

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

Modifier and Type	Method and Description
void	IgniteInternalFuture.listen(IgniteInClosure<? super IgniteInternalFuture<R>> lsnr) Registers listener closure to be asynchronously notified whenever future completes.

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

Methods in org.apache.ignite.internal.managers.swapspace with parameters of type IgniteInClosure

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.

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

Classes in org.apache.ignite.internal.processors.cache that implement IgniteInClosure

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>

Methods in org.apache.ignite.internal.processors.cache that return IgniteInClosure

Modifier and Type	Method and Description
static IgniteInClosure<IgniteInternalFuture<?>>	GridCacheUtils.errorLogger(IgniteLogger log, Class<? extends Exception>... excl)

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

Methods in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type IgniteInClosure

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridDhtTxLocal.prepareAsync(Iterable<IgniteTxEntry> reads, Iterable<IgniteTxEntry> writes, Map<IgniteTxKey,GridCacheVersion> verMap, long msgId, IgniteUuid nearMiniId, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse> completeCb) Prepares next batch of entries in dht transaction.

Constructors in org.apache.ignite.internal.processors.cache.distributed.dht with parameters of type IgniteInClosure

Constructor and Description
GridDhtTxPrepareFuture(GridCacheSharedContext cctx, GridDhtTxLocalAdapter tx, IgniteUuid nearMiniId, Map<IgniteTxKey,GridCacheVersion> dhtVerMap, boolean last, boolean retVal, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse> completeCb)

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

Methods in org.apache.ignite.internal.processors.cache.distributed.near with parameters of type IgniteInClosure

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	GridNearTxLocal.prepareAsyncLocal(Collection<IgniteTxEntry> reads, Collection<IgniteTxEntry> writes, Map<UUID,Collection<UUID>> txNodes, boolean last, Collection<UUID> lastBackups, IgniteInClosure<GridNearTxPrepareResponse> completeCb) Prepares next batch of entries in dht transaction.

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

Methods in org.apache.ignite.internal.processors.cache.transactions with parameters of type IgniteInClosure

Modifier and Type	Method and Description
IgniteInternalFuture<IgniteInternalTx>	IgniteTxHandler.prepareTx(UUID nearNodeId, GridNearTxLocal locTx, GridNearTxPrepareRequest req, IgniteInClosure<GridNearTxPrepareResponse> completeCb)

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

Methods in org.apache.ignite.internal.processors.streamer with parameters of type IgniteInClosure

Modifier and Type	Method and Description
void	GridStreamerContextImpl.broadcast(IgniteInClosure<StreamerContext> clo) Queries all streamer nodes deployed within grid.
void	GridStreamerContextDelegate.broadcast(IgniteInClosure<StreamerContext> clo) Queries all streamer nodes deployed within grid.
void	GridStreamerContextImpl.broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.
void	GridStreamerContextDelegate.broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.

Uses of IgniteInClosure in org.apache.ignite.internal.processors.streamer.task

Constructors in org.apache.ignite.internal.processors.streamer.task with parameters of type IgniteInClosure

Constructor and Description
GridStreamerBroadcastTask(IgniteInClosure<StreamerContext> clo, String streamer)

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

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

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.
void	GridCircularBuffer.forEach(IgniteInClosure<T> c) Executes given closure for every item in circular buffer.

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

Classes in org.apache.ignite.internal.util.future that implement IgniteInClosure

Modifier and Type	Class and Description
class	GridFutureChainListener<T,R> Future listener to fill chained future with converted result of the source future.

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

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.

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

Classes in org.apache.ignite.internal.util.lang that implement IgniteInClosure

Modifier and Type	Class and Description
class	IgniteInClosureX<T> Convenient in-closure subclass that allows for thrown grid exception.

Methods in org.apache.ignite.internal.util.lang that return IgniteInClosure

Modifier and Type	Method and Description
static <T> IgniteInClosure<T>	GridFunc.ciInvoke(String mtdName, Object... args) Creates in closure that will reflectively call a method with the given name on closure's argument.
static <T> IgniteInClosure<T>	GridFunc.print() Gets closure that prints out its bound variable
static <T> IgniteInClosure<T>	GridFunc.print(String pre, String post) Gets closure that prints out its bound variable.
static <T> IgniteInClosure<T>	GridFunc.printf(String fmt) Gets closure that prints out its bound variable.
static <T> IgniteInClosure<T>	GridFunc.println() Gets closure that calls System.out.println() on its bound variable.
static <T> IgniteInClosure<T>	GridFunc.println(String pre, String post) Gets closure that prints out its bound variable.

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

Modifier and Type	Method and Description
static <T> Collection<GridAbsClosure>	GridFunc.curry(IgniteInClosure<? super T> c, Collection<? extends T> args) Curries collection of closures with given collection of arguments.
static <T> GridAbsClosure	GridFunc.curry(IgniteInClosure<? super T> f, T e) Curries given closure.
static <T> Collection<GridAbsClosure>	GridFunc.curry(int cnt, IgniteInClosure<? super T> c, IgniteOutClosure<T> pdc) Curries collection of closures with given collection of arguments.
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 <K,V> void	GridFunc.forEach(Map<? extends K,? extends V> m, IgniteInClosure<? super IgniteBiTuple<K,V>> f, IgnitePredicate<? super IgniteBiTuple<K,V>>... p) Calls given side-effect only closure (if provided) over the each element of the provided map.
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.
static <T> Collection<GridAbsClosure>	GridFunc.yield(Collection<? extends T> c, IgniteInClosure<? super T> f) Given collection of items and a closure this method returns read-only collection of closures where each closure is closed on an element of the initial collection.
static <T> Collection<GridAbsClosure>	GridFunc.yield(T[] c, IgniteInClosure<? super T> f) Given collection of items and a closure this method returns collection of closures where each closure is closed on an element of the initial collection.

Method parameters in org.apache.ignite.internal.util.lang with type arguments of type IgniteInClosure

Modifier and Type	Method and Description
static <T> Collection<GridAbsClosure>	GridFunc.curry0(Collection<? extends IgniteInClosure<? super T>> in, Collection<? extends T> args) Curries collection of in closures with given collection of arguments.

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

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

Modifier and Type	Method and Description
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)

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

Subinterfaces of IgniteInClosure in org.apache.ignite.internal.util.typedef

Modifier and Type	Interface and Description
interface	CI1<T> Defines alias for IgniteInClosure by extending it.

Classes in org.apache.ignite.internal.util.typedef that implement IgniteInClosure

Modifier and Type	Class and Description
class	CIX1<T> Defines alias for IgniteInClosureX by extending it.

Uses of IgniteInClosure in org.apache.ignite.lang

Methods in org.apache.ignite.lang with parameters of type IgniteInClosure

Modifier and Type	Method and Description
void	IgniteFuture.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr) Registers listener closure to be asynchronously notified whenever future completes.

Uses of IgniteInClosure in org.apache.ignite.spi.swapspace

Methods in org.apache.ignite.spi.swapspace with parameters of type IgniteInClosure

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.

Uses of IgniteInClosure in org.apache.ignite.spi.swapspace.file

Methods in org.apache.ignite.spi.swapspace.file with parameters of type IgniteInClosure

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.

Uses of IgniteInClosure in org.apache.ignite.spi.swapspace.noop

Methods in org.apache.ignite.spi.swapspace.noop with parameters of type IgniteInClosure

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.

Uses of IgniteInClosure in org.apache.ignite.startup

Classes in org.apache.ignite.startup that implement IgniteInClosure

Modifier and Type	Class and Description
class	BasicWarmupClosure Basic warm-up closure which warm-ups cache operations.

Uses of IgniteInClosure in org.apache.ignite.streamer

Methods in org.apache.ignite.streamer with parameters of type IgniteInClosure

Modifier and Type	Method and Description
void	StreamerContext.broadcast(IgniteInClosure<StreamerContext> clo) Queries all streamer nodes deployed within grid.
void	StreamerContext.broadcast(IgniteInClosure<StreamerContext> clo, Collection<ClusterNode> nodes) Queries streamer nodes deployed within grid.