Uses of Interface
org.gridgain.grid.lang.GridClosure

Packages that use GridClosure

Package	Description
org.gridgain.grid	Contains entry-point GridGain & HPC APIs.
org.gridgain.grid.cache	Contains main Data Grid APIs.
org.gridgain.grid.cache.query	Contains APIs for creating and executing cache queries.
org.gridgain.grid.compute	Contains Compute Grid functionality.
org.gridgain.grid.kernal	Contains main implementation.
org.gridgain.grid.kernal.processors.cache
org.gridgain.grid.kernal.processors.cache.datastructures
org.gridgain.grid.kernal.processors.cache.distributed.dht.atomic
org.gridgain.grid.kernal.processors.cache.distributed.near
org.gridgain.grid.kernal.processors.cache.local.atomic
org.gridgain.grid.kernal.processors.cache.query
org.gridgain.grid.kernal.processors.closure	TODO.
org.gridgain.grid.kernal.processors.streamer	TODO.
org.gridgain.grid.kernal.processors.streamer.task
org.gridgain.grid.streamer	Contains main Streaming APIs.
org.gridgain.grid.streamer.index	Contains APIs for indexing of streamer windows.
org.gridgain.grid.util	System-wide utility routine and helper classes.
org.gridgain.grid.util.future	Future related classes.
org.gridgain.grid.util.lang
org.gridgain.grid.util.typedef	Contains typedefs definitions for frequently used classes.

Uses of GridClosure in org.gridgain.grid

Methods in org.gridgain.grid with parameters of type GridClosure

Modifier and Type	Method and Description
<T> GridFuture<T>	GridFuture.chain(GridClosure<? super GridFuture<R>,T> doneCb) Make a chained future to convert result of this future (when complete) into a new format.

Uses of GridClosure in org.gridgain.grid.cache

Methods in org.gridgain.grid.cache with parameters of type GridClosure

Modifier and Type	Method and Description
void	GridCacheEntry.transform(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transform(Object, GridClosure) method.
void	GridCacheProjection.transform(K key, GridClosure<V,V> transformer) Stores result of applying valTransform closure to the previous value associated with given key in cache.
void	GridCacheProjection.transformAll(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
GridFuture<?>	GridCacheProjection.transformAllAsync(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
<R> R	GridCacheProjection.transformAndCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer) Applies transformer closure to the previous value associated with given key in cache, closure should return GridBiTuple instance where first value is new value stored in cache and second value is returned as result of this method.
GridFuture<?>	GridCacheEntry.transformAsync(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transformAsync(Object, GridClosure) method.
GridFuture<?>	GridCacheProjection.transformAsync(K key, GridClosure<V,V> transformer) Stores result of applying transformer closure to the previous value associated with given key in cache.

Method parameters in org.gridgain.grid.cache with type arguments of type GridClosure

Modifier and Type	Method and Description
void	GridCacheProjection.transformAll(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
GridFuture<?>	GridCacheProjection.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.

Uses of GridClosure in org.gridgain.grid.cache.query

Methods in org.gridgain.grid.cache.query with parameters of type GridClosure

Modifier and Type	Method and Description
<R> GridCacheQueryFuture<R>	GridCacheQuery.execute(GridClosure<T,R> rmtTransform, Object... args) Executes the query the same way as GridCacheQuery.execute(Object...) method but transforms result remotely.

Uses of GridClosure in org.gridgain.grid.compute

Methods in org.gridgain.grid.compute with parameters of type GridClosure

Modifier and Type	Method and Description
<T,R> GridFuture<Collection<R>>	GridCompute.apply(GridClosure<T,R> job, Collection<? extends T> args) Executes provided closure job on nodes within this grid projection.
<R,T> GridFuture<R>	GridCompute.apply(GridClosure<T,R> job, T arg) Executes provided closure job on a node in this grid projection.
<R1,R2,T> GridFuture<R2>	GridCompute.apply(GridClosure<T,R1> job, Collection<? extends T> args, GridReducer<R1,R2> rdc) Executes provided closure job on nodes within this grid projection.
<R,T> GridFuture<Collection<R>>	GridCompute.broadcast(GridClosure<T,R> job, T arg) Broadcasts given closure job with passed in argument to all nodes in grid projection.

Uses of GridClosure in org.gridgain.grid.kernal

Methods in org.gridgain.grid.kernal with parameters of type GridClosure

Modifier and Type	Method and Description
<T,R> GridFuture<Collection<R>>	GridComputeImpl.apply(GridClosure<T,R> job, Collection<? extends T> args) Executes provided closure job on nodes within this grid projection.
<R,T> GridFuture<R>	GridComputeImpl.apply(GridClosure<T,R> job, T arg) Executes provided closure job on a node in this grid projection.
<R1,R2,T> GridFuture<R2>	GridComputeImpl.apply(GridClosure<T,R1> job, Collection<? extends T> args, GridReducer<R1,R2> rdc) Executes provided closure job on nodes within this grid projection.
<R,T> GridFuture<Collection<R>>	GridComputeImpl.broadcast(GridClosure<T,R> job, T arg) Broadcasts given closure job with passed in argument to all nodes in grid projection.

Uses of GridClosure in org.gridgain.grid.kernal.processors.cache

Classes in org.gridgain.grid.kernal.processors.cache that implement GridClosure

Modifier and Type	Class and Description
class	GridCacheTransformComputeClosure<V,R>

Methods in org.gridgain.grid.kernal.processors.cache that return GridClosure

Modifier and Type	Method and Description
static <K,V> GridClosure<K,GridCacheEntry<K,V>>	GridCacheUtils.cacheKey2Entry(GridCacheContext<K,V> ctx) Gets closure which returns GridCacheEntry given cache key.
static <K,V> GridClosure<GridCacheEntryEx<K,V>,K>	GridCacheUtils.entry2Key()
static <K,V> GridClosure<Integer,GridPredicate<GridCacheEntry<K,V>>[]>	GridCacheUtils.factory() Entry predicate factory mostly used for deserialization.
static <K,V> GridClosure<GridCacheEntryInfo<K,V>,K>	GridCacheUtils.info2Key()
static <K,V> GridClosure<GridDhtLocalPartition<K,V>,GridDhtPartitionState>	GridCacheUtils.part2state()
static <K,V> GridClosure<GridCacheTxEntry<K,V>,GridCacheEntryEx<K,V>>	GridCacheUtils.tx2entry()
static <K,V> GridClosure<GridCacheTxEntry<K,V>,K>	GridCacheUtils.tx2key()
static <K,V> GridClosure<GridCacheTxEntry<K,V>,byte[]>	GridCacheUtils.tx2keyBytes()
static GridClosure<GridCacheTx,GridUuid>	GridCacheUtils.tx2xid()
static <K,V> GridClosure<GridCacheTxEx<K,V>,GridCacheVersion>	GridCacheUtils.tx2xidVersion()
static <K,V> GridClosure<Collection<GridCacheTxEntry<K,V>>,Collection<K>>	GridCacheUtils.txCol2Key()
static GridClosure<Integer,GridCacheVersion[]>	GridCacheUtils.versionArrayFactory()

Methods in org.gridgain.grid.kernal.processors.cache that return types with arguments of type GridClosure

Modifier and Type	Method and Description
Collection<GridClosure<V,V>>	GridCacheTxEntry.transformClosures()

Methods in org.gridgain.grid.kernal.processors.cache with parameters of type GridClosure

Modifier and Type	Method and Description
protected GridCacheTxEntry<K,V>	GridCacheTxLocalAdapter.addEntry(GridCacheOperation op, V val, GridClosure<V,V> transformClos, GridCacheEntryEx<K,V> entry, long ttl, GridPredicate<GridCacheEntry<K,V>>[] filter, boolean filtersSet, long drTtl, long drExpireTime, GridCacheVersion drVer)
void	GridCacheTxEntry.addTransformClosure(GridClosure<V,V> transformClos)
void	GridCacheEvictionEntry.transform(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transform(Object, GridClosure) method.
void	GridCacheEntryImpl.transform(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transform(Object, GridClosure) method.
void	GridCacheFilterEvaluationEntry.transform(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transform(Object, GridClosure) method.
void	GridCacheProjectionImpl.transform(K key, GridClosure<V,V> transformer) Stores result of applying valTransform closure to the previous value associated with given key in cache.
void	GridCacheAdapter.transform(K key, GridClosure<V,V> transformer) Stores result of applying valTransform closure to the previous value associated with given key in cache.
void	GridCacheProxyImpl.transform(K key, GridClosure<V,V> transformer) Stores result of applying valTransform closure to the previous value associated with given key in cache.
boolean	GridCacheTxLocalAdapter.transform(K key, GridClosure<V,V> transformer)
boolean	GridCacheTxLocalEx.transform(K key, GridClosure<V,V> valTransform)
void	GridCacheProjectionImpl.transformAll(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
void	GridCacheAdapter.transformAll(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
void	GridCacheProxyImpl.transformAll(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
GridFuture<?>	GridCacheProjectionImpl.transformAllAsync(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
GridFuture<?>	GridCacheAdapter.transformAllAsync(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
GridFuture<?>	GridCacheProxyImpl.transformAllAsync(Set<? extends K> keys, GridClosure<V,V> transformer) Stores result of applying the specified transform closure to previous values associated with the specified keys in cache.
<R> R	GridCacheProjectionImpl.transformAndCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer) Applies transformer closure to the previous value associated with given key in cache, closure should return GridBiTuple instance where first value is new value stored in cache and second value is returned as result of this method.
<R> R	GridCacheAdapter.transformAndCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer) Applies transformer closure to the previous value associated with given key in cache, closure should return GridBiTuple instance where first value is new value stored in cache and second value is returned as result of this method.
<R> R	GridCacheProxyImpl.transformAndCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer) Applies transformer closure to the previous value associated with given key in cache, closure should return GridBiTuple instance where first value is new value stored in cache and second value is returned as result of this method.
GridFuture<?>	GridCacheEvictionEntry.transformAsync(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transformAsync(Object, GridClosure) method.
GridFuture<?>	GridCacheEntryImpl.transformAsync(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transformAsync(Object, GridClosure) method.
GridFuture<?>	GridCacheFilterEvaluationEntry.transformAsync(GridClosure<V,V> transformer) This method has the same semantic as GridCacheProjection.transformAsync(Object, GridClosure) method.
GridFuture<?>	GridCacheProjectionImpl.transformAsync(K key, GridClosure<V,V> transformer) Stores result of applying transformer closure to the previous value associated with given key in cache.
GridFuture<?>	GridCacheAdapter.transformAsync(K key, GridClosure<V,V> transformer) Stores result of applying transformer closure to the previous value associated with given key in cache.
GridFuture<?>	GridCacheProxyImpl.transformAsync(K key, GridClosure<V,V> transformer) Stores result of applying transformer closure to the previous value associated with given key in cache.
GridFuture<?>	GridCacheProjectionEx.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> entry, long ttl) Internal method that is called from GridCacheEntryImpl.
GridFuture<?>	GridCacheProjectionImpl.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> entry, long ttl) Internal method that is called from GridCacheEntryImpl.
GridFuture<?>	GridCacheAdapter.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> entry, long ttl) Internal method that is called from GridCacheEntryImpl.
GridFuture<?>	GridCacheProxyImpl.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> entry, long ttl) Internal method that is called from GridCacheEntryImpl.
GridFuture<Boolean>	GridCacheTxLocalAdapter.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> cached, long ttl)
GridFuture<Boolean>	GridCacheTxLocalEx.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> cached, long ttl)
<R> R	GridCacheTxLocalAdapter.transformCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer)
<R> R	GridCacheTxLocalEx.transformCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer)

Method parameters in org.gridgain.grid.kernal.processors.cache with type arguments of type GridClosure

Modifier and Type	Method and Description
protected GridFuture<Set<K>>	GridCacheTxLocalAdapter.enlistWrite(Collection<? extends K> keys, GridCacheEntryEx<K,V> cached, long ttl, boolean implicit, Map<? extends K,? extends V> lookup, Map<? extends K,? extends GridClosure<V,V>> transformMap, boolean retval, boolean lockOnly, GridPredicate<GridCacheEntry<K,V>>[] filter, GridCacheReturn<V> ret, Collection<K> enlisted, Map<? extends K,GridCacheDrInfo<V>> drPutMap, Map<? extends K,GridCacheVersion> drRmvMap) Internal routine for putAll(..)
protected Set<K>	GridCacheTxLocalAdapter.postLockWrite(Iterable<? extends K> keys, Set<K> failed, Map<K,V> transformed, Map<? extends K,? extends GridClosure<V,V>> transformMap, GridCacheReturn<V> ret, boolean rmv, boolean retval, GridPredicate<GridCacheEntry<K,V>>[] filter) Post lock processing for put or remove.
void	GridCacheProjectionImpl.transformAll(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
void	GridCacheAdapter.transformAll(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
void	GridCacheProxyImpl.transformAll(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
void	GridCacheTxLocalAdapter.transformAll(Map<? extends K,? extends GridClosure<V,V>> map)
void	GridCacheTxLocalEx.transformAll(Map<? extends K,? extends GridClosure<V,V>> map)
GridFuture<?>	GridCacheProjectionImpl.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
GridFuture<?>	GridCacheAdapter.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
GridFuture<?>	GridCacheProxyImpl.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
GridFuture<?>	GridCacheTxLocalAdapter.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> map)
GridFuture<?>	GridCacheTxLocalEx.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> map)
void	GridCacheTxEntry.transformClosures(Collection<GridClosure<V,V>> transformClosCol)

Constructors in org.gridgain.grid.kernal.processors.cache with parameters of type GridClosure

Constructor and Description
GridCacheIterator(Iterable<? extends GridCacheEntry<K,V>> c, GridClosure<GridCacheEntry<K,V>,T> trans, GridPredicate<GridCacheEntry<K,V>>[] filter)
GridCacheTransformComputeClosure(GridClosure<V,GridBiTuple<V,R>> transformer)
GridCacheTxEntry(GridCacheContext<K,V> ctx, GridCacheTxEx<K,V> tx, GridCacheOperation op, V val, GridClosure<V,V> transformClos, long ttl, GridCacheEntryEx<K,V> entry, GridPredicate<GridCacheEntry<K,V>>[] filters, GridCacheVersion drVer) This constructor is meant for local transactions.

Uses of GridClosure in org.gridgain.grid.kernal.processors.cache.datastructures

Classes in org.gridgain.grid.kernal.processors.cache.datastructures that implement GridClosure

Modifier and Type	Class and Description
protected static class	GridCacheQueueAdapter.AddClosure
protected static class	GridCacheQueueAdapter.ClearClosure
protected static class	GridCacheQueueAdapter.PollClosure
protected static class	GridCacheQueueAdapter.RemoveClosure

Uses of GridClosure in org.gridgain.grid.kernal.processors.cache.distributed.dht.atomic

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht.atomic that return GridClosure

Modifier and Type	Method and Description
GridClosure<V,V>	GridDhtAtomicUpdateRequest.nearTransformClosure(int idx)
GridClosure<V,V>	GridDhtAtomicUpdateRequest.transformClosure(int idx)
GridClosure<V,V>	GridNearAtomicUpdateRequest.transformClosure(int idx)

Methods in org.gridgain.grid.kernal.processors.cache.distributed.dht.atomic with parameters of type GridClosure

Modifier and Type	Method and Description
void	GridDhtAtomicUpdateFuture.addNearWriteEntries(Iterable<UUID> readers, GridDhtCacheEntry<K,V> entry, V val, byte[] valBytes, GridClosure<V,V> transformC, long ttl)
void	GridDhtAtomicUpdateRequest.addNearWriteValue(K key, byte[] keyBytes, V val, byte[] valBytes, GridClosure<V,V> transformC)
void	GridDhtAtomicUpdateFuture.addWriteEntry(GridDhtCacheEntry<K,V> entry, V val, byte[] valBytes, GridClosure<V,V> transformC, long drTtl, long drExpireTime, GridCacheVersion drVer, long ttl)
void	GridDhtAtomicUpdateRequest.addWriteValue(K key, byte[] keyBytes, V val, byte[] valBytes, GridClosure<V,V> transformC, long drTtl, long drExpireTime, GridCacheVersion drVer)
void	GridDhtAtomicCache.transform(K key, GridClosure<V,V> transformer) Stores result of applying valTransform closure to the previous value associated with given key in cache.
<R> R	GridDhtAtomicCache.transformAndCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer) Applies transformer closure to the previous value associated with given key in cache, closure should return GridBiTuple instance where first value is new value stored in cache and second value is returned as result of this method.
GridFuture<?>	GridDhtAtomicCache.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> entry, long ttl) Internal method that is called from GridCacheEntryImpl.

Method parameters in org.gridgain.grid.kernal.processors.cache.distributed.dht.atomic with type arguments of type GridClosure

Modifier and Type	Method and Description
void	GridDhtAtomicCache.transformAll(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
GridFuture<?>	GridDhtAtomicCache.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.

Uses of GridClosure in org.gridgain.grid.kernal.processors.cache.distributed.near

Methods in org.gridgain.grid.kernal.processors.cache.distributed.near with parameters of type GridClosure

Modifier and Type	Method and Description
void	GridNearAtomicCache.transform(K key, GridClosure<V,V> transformer) Stores result of applying valTransform closure to the previous value associated with given key in cache.
<R> R	GridNearAtomicCache.transformAndCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer) Applies transformer closure to the previous value associated with given key in cache, closure should return GridBiTuple instance where first value is new value stored in cache and second value is returned as result of this method.
GridFuture<?>	GridNearAtomicCache.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> entry, long ttl) Internal method that is called from GridCacheEntryImpl.

Method parameters in org.gridgain.grid.kernal.processors.cache.distributed.near with type arguments of type GridClosure

Modifier and Type	Method and Description
void	GridNearAtomicCache.transformAll(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
GridFuture<?>	GridNearAtomicCache.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.

Uses of GridClosure in org.gridgain.grid.kernal.processors.cache.local.atomic

Methods in org.gridgain.grid.kernal.processors.cache.local.atomic with parameters of type GridClosure

Modifier and Type	Method and Description
void	GridLocalAtomicCache.transform(K key, GridClosure<V,V> transformer) Stores result of applying valTransform closure to the previous value associated with given key in cache.
<R> R	GridLocalAtomicCache.transformAndCompute(K key, GridClosure<V,GridBiTuple<V,R>> transformer) Applies transformer closure to the previous value associated with given key in cache, closure should return GridBiTuple instance where first value is new value stored in cache and second value is returned as result of this method.
GridFuture<?>	GridLocalAtomicCache.transformAsync(K key, GridClosure<V,V> transformer, GridCacheEntryEx<K,V> entry, long ttl) Internal method that is called from GridCacheEntryImpl.

Method parameters in org.gridgain.grid.kernal.processors.cache.local.atomic with type arguments of type GridClosure

Modifier and Type	Method and Description
void	GridLocalAtomicCache.transformAll(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.
GridFuture<?>	GridLocalAtomicCache.transformAllAsync(Map<? extends K,? extends GridClosure<V,V>> m) Stores result of applying transform closures from the given map to previous values associated with corresponding keys in cache.

Uses of GridClosure in org.gridgain.grid.kernal.processors.cache.query

Methods in org.gridgain.grid.kernal.processors.cache.query that return GridClosure

Modifier and Type	Method and Description
GridClosure<Object,Object>	GridCacheQueryBean.transform()
GridClosure<Object,Object>	GridCacheQueryRequest.transformer()

Methods in org.gridgain.grid.kernal.processors.cache.query with parameters of type GridClosure

Modifier and Type	Method and Description
<R> GridCacheQueryFuture<R>	GridCacheQueryAdapter.execute(GridClosure<T,R> rmtTransform, Object... args) Executes the query the same way as GridCacheQuery.execute(Object...) method but transforms result remotely.

Constructors in org.gridgain.grid.kernal.processors.cache.query with parameters of type GridClosure

Constructor and Description
GridCacheQueryBean(GridCacheQueryAdapter<?> qry, GridReducer<Object,Object> rdc, GridClosure<Object,Object> trans, Object[] args)
GridCacheQueryRequest(long id, String cacheName, GridCacheQueryType type, boolean fields, String clause, String clsName, GridBiPredicate<Object,Object> keyValFilter, GridPredicate<GridCacheEntry<Object,Object>> prjFilter, GridReducer<Object,Object> rdc, GridClosure<Object,Object> trans, int pageSize, boolean incBackups, Object[] args, boolean incMeta)

Uses of GridClosure in org.gridgain.grid.kernal.processors.closure

Methods in org.gridgain.grid.kernal.processors.closure with parameters of type GridClosure

Modifier and Type	Method and Description
<T,R> GridFuture<Collection<R>>	GridClosureProcessor.broadcast(GridClosure<T,R> job, T arg, Collection<GridNode> nodes)
<T,R> GridFuture<Collection<R>>	GridClosureProcessor.callAsync(GridClosure<T,R> job, Collection<? extends T> args, Collection<GridNode> nodes)
<T,R> GridFuture<R>	GridClosureProcessor.callAsync(GridClosure<T,R> job, T arg, Collection<GridNode> nodes)
<T,R1,R2> GridFuture<R2>	GridClosureProcessor.callAsync(GridClosure<T,R1> job, Collection<? extends T> args, GridReducer<R1,R2> rdc, Collection<GridNode> nodes)

Uses of GridClosure in org.gridgain.grid.kernal.processors.streamer

Methods in org.gridgain.grid.kernal.processors.streamer with parameters of type GridClosure

Modifier and Type	Method and Description
<R> Collection<R>	GridStreamerContextDelegate.query(GridClosure<GridStreamerContext,R> clo) Queries all streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextImpl.query(GridClosure<GridStreamerContext,R> clo) Queries all streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextDelegate.query(GridClosure<GridStreamerContext,R> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContextImpl.query(GridClosure<GridStreamerContext,R> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextDelegate.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContextImpl.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.

Uses of GridClosure in org.gridgain.grid.kernal.processors.streamer.task

Constructors in org.gridgain.grid.kernal.processors.streamer.task with parameters of type GridClosure

Constructor and Description
GridStreamerQueryTask(GridClosure<GridStreamerContext,R> qryClos, String streamer)
GridStreamerReduceTask(GridClosure<GridStreamerContext,R1> clos, GridReducer<R1,R2> rdc, String streamer)

Uses of GridClosure in org.gridgain.grid.streamer

Methods in org.gridgain.grid.streamer with parameters of type GridClosure

Modifier and Type	Method and Description
<R> Collection<R>	GridStreamerContext.query(GridClosure<GridStreamerContext,R> clo) Queries all streamer nodes deployed within grid.
<R> Collection<R>	GridStreamerContext.query(GridClosure<GridStreamerContext,R> clo, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc) Queries all streamer nodes deployed within grid.
<R1,R2> R2	GridStreamerContext.reduce(GridClosure<GridStreamerContext,R1> clo, GridReducer<R1,R2> rdc, Collection<GridNode> nodes) Queries streamer nodes deployed within grid.

Uses of GridClosure in org.gridgain.grid.streamer.index

Fields in org.gridgain.grid.streamer.index declared as GridClosure

Modifier and Type	Field and Description
protected GridClosure<GridStreamerIndexEntry<E,K,V>,K>	GridStreamerIndexProviderAdapter.entryToKey
protected GridClosure<GridStreamerIndexEntry<E,K,V>,V>	GridStreamerIndexProviderAdapter.entryToVal

Uses of GridClosure in org.gridgain.grid.util

Methods in org.gridgain.grid.util that return GridClosure

Modifier and Type	Method and Description
static GridClosure<UUID,GridNode>	GridUtils.id2Node(GridKernalContext ctx)

Uses of GridClosure in org.gridgain.grid.util.future

Methods in org.gridgain.grid.util.future with parameters of type GridClosure

Modifier and Type	Method and Description
<T> GridFuture<T>	GridFutureAdapter.chain(GridClosure<? super GridFuture<R>,T> doneCb) Make a chained future to convert result of this future (when complete) into a new format.
<T> GridFuture<T>	GridFutureAdapterEx.chain(GridClosure<? super GridFuture<R>,T> doneCb) Make a chained future to convert result of this future (when complete) into a new format.
<R> GridFuture<R>	GridFinishedFutureEx.chain(GridClosure<? super GridFuture<T>,R> doneCb) Make a chained future to convert result of this future (when complete) into a new format.
<R> GridFuture<R>	GridFinishedFuture.chain(GridClosure<? super GridFuture<T>,R> doneCb) Make a chained future to convert result of this future (when complete) into a new format.

Constructors in org.gridgain.grid.util.future with parameters of type GridClosure

Constructor and Description
GridFutureChainListener(GridKernalContext ctx, GridFutureAdapter<R> fut, GridClosure<? super GridFuture<T>,R> doneCb) Constructs chain listener.

Uses of GridClosure in org.gridgain.grid.util.lang

Classes in org.gridgain.grid.util.lang that implement GridClosure

Modifier and Type	Class and Description
class	GridClosureX<E,R> Convenient closure subclass that allows for thrown grid exception.

Methods in org.gridgain.grid.util.lang that return GridClosure

Modifier and Type	Method and Description
static <X> GridClosure<X,Boolean>	GridFunc.as(GridPredicate<? super X> p) Converts given predicate to closure.
static <T> GridClosure<Callable<T>,GridOutClosure<T>>	GridFunc.c2c() Returns closure that converts Callable to GridOutClosure.
static <K,V> GridClosure<GridCacheEntry<K,V>,V>	GridFunc.cacheEntry2Get() Gets closure that returns value for an entry.
static <K,V> GridClosure<GridCacheEntry<K,V>,K>	GridFunc.cacheEntry2Key() Gets closure that returns key for cache entry.
static <K,V> GridClosure<GridCacheEntry<K,V>,V>	GridFunc.cacheEntry2Peek() Gets closure that returns result of GridCacheEntry.peek() method.
static <T,R> GridClosure<T,R>	GridFunc.cInvoke(String mtdName, Object... args) Creates closure that will reflectively call a method with the given name on closure's argument and return result of that call.
static GridClosure<Object,Class<?>>	GridFunc.clazz() Gets closure that converts object to its runtime class.
static <D,B,C> GridClosure<D,C>	GridFunc.compose(GridClosure<? super D,? extends B> f, GridClosure<? super B,C> g) Composes two closures into one.
static <T1,R> GridClosure<T1,R>	GridFunc.constant1(R val) Gets closure that returns constant value.
static <T1,T2,R> GridClosure<T2,R>	GridFunc.curry(GridBiClosure<? super T1,? super T2,R> f, T1 e) Curries given closure.
static <K,V> GridClosure<K,V>	GridFunc.forMap(Map<? extends K,? extends V> m) Gets closure that wraps given map access, i.e.
static <K,V> GridClosure<K,V>	GridFunc.forMap(Map<? extends K,? extends V> m, Callable<V> c) Gets closure that wraps given map's access, i.e.
static <T> GridClosure<GridFuture<T>,Future<T>>	GridFunc.future() Gets closure that converts GridFuture to Future.
static GridClosure<UUID,String>	GridFunc.id2id8() Gets closure which converts node ID to node ID8 representation (shorter and good enough).
static <T> GridClosure<T,T>	GridFunc.identity() Gets identity closure, i.e.
static <K> GridClosure<Map.Entry<K,?>,K>	GridFunc.mapEntry2Key() Gets closure that returns key for an entry.
static <V> GridClosure<Map.Entry<?,V>,V>	GridFunc.mapEntry2Value() Gets closure that returns value for an entry.
static GridClosure<GridNode,UUID>	GridFunc.node2id() Gets closure which converts node to node ID.
static GridClosure<GridNode,String>	GridFunc.node2id8() Gets closure which converts node to node ID8 representation (shorter and good enough).
static GridClosure<GridProjection,GridPredicate<GridNode>>	GridFunc.predicate() Gets closure that transform a grid projection into its predicate.
static GridClosure<Runnable,GridAbsClosure>	GridFunc.r2c() Returns closure that converts Runnable to GridAbsClosure.
static <T> GridClosure<T,String>	GridFunc.string() Gets closure that return toString() value for its free variable.

Methods in org.gridgain.grid.util.lang that return types with arguments of type GridClosure

Modifier and Type	Method and Description
static <T1,T2,R> Collection<GridClosure<T2,R>>	GridFunc.curry2(Collection<? extends GridBiClosure<? super T1,T2,R>> iter, T1 arg) Curries collection of closures with given argument.

Methods in org.gridgain.grid.util.lang with parameters of type GridClosure

Modifier and Type	Method and Description
static <T> GridPredicate<T>	GridFunc.as(GridClosure<? super T,Boolean> c) Converts given closure to predicate.
static <D,B,C> GridClosure<D,C>	GridFunc.compose(GridClosure<? super D,? extends B> f, GridClosure<? super B,C> g) Composes two closures into one.
static <D,B,C> GridClosure<D,C>	GridFunc.compose(GridClosure<? super D,? extends B> f, GridClosure<? super B,C> g) Composes two closures into one.
static <X,Y> GridPredicate<X>	GridFunc.compose(GridPredicate<? super Y> p, GridClosure<? super X,? extends Y> f) Gets a predicate that is composed of given predicate and closure.
static <T,R> Collection<GridOutClosure<R>>	GridFunc.curry(GridClosure<? super T,R> c, Collection<? extends T> args) Curries collection of closures with given collection of arguments.
static <T,R> GridOutClosure<R>	GridFunc.curry(GridClosure<? super T,R> f, T e) Curries given closure.
static <T,R> Collection<GridOutClosure<R>>	GridFunc.curry(int cnt, GridClosure<? super T,R> c, GridOutClosure<T> pdc) Curries collection of closures with given collection of arguments.
static <V,Y> Y	GridFunc.find(Iterable<? extends V> c, Y dfltVal, GridClosure<? super V,Y> f, GridPredicate<? super V>... p) Finds, transforms and returns first element in given collection for which any of the provided predicates evaluates to true.
static <V,Y> Y	GridFunc.find(V[] c, Y dfltVal, GridClosure<? super V,Y> f, GridPredicate<? super V>... p) Finds, transforms and returns first element in given array for which any of the provided predicates evaluates to true.
static <T1,T2> GridIterator<T2>	GridFunc.iterator(Iterable<? extends T1> c, GridClosure<? super T1,T2> trans, boolean readOnly, GridPredicate<? super T1>... p) Creates and returns transforming iterator from given collection and optional filtering predicates.
static <X,Y> Collection<Y>	GridFunc.transform(Collection<? extends X> c, GridClosure<? super X,Y> f) Transforms one collection to another using provided closure.
static <X,Y> Collection<Y>	GridFunc.transform(Collection<? extends X> c, GridClosure<? super X,Y> f, GridPredicate<? super X>... p) Transforms one collection to another using provided closure and optional set of predicates.
static <X,Y> Collection<Y>	GridFunc.transform(Collection<Y> to, Iterable<? extends X> from, GridClosure<? super X,Y> f, GridPredicate<? super X>... p) Transforms one collection to another using provided closure and predicate.
static <X,Y> Collection<Y>	GridFunc.transform(X[] c, GridClosure<? super X,Y> f) Transforms an array to read only collection using provided closure.
static <T1,T2> List<T2>	GridFunc.transformList(Collection<? extends T1> c, GridClosure<? super T1,T2> trans, GridPredicate<? super T1>... p) Creates a view on given list with provided transformer and predicates.
static <T1,T2> Set<T2>	GridFunc.transformSet(Collection<? extends T1> c, GridClosure<? super T1,T2> trans, GridPredicate<? super T1>... p) Creates a view on given set with provided transformer and predicates.
static <X,Y extends X> Collection<Y>	GridFunc.upcast(Collection<? extends X> c, GridClosure<? super X,Y> f) Special version of transform method that works on two types that are in child-parent relationship.
static <K0,K extends K0,V0,V extends V0> Map<K,V>	GridFunc.viewAsMap(Set<K> c, GridClosure<? super K,V> mapClo, GridPredicate<? super K>... p) Read-only map view of a collection.
static <T1,T2> List<T2>	GridFunc.viewListReadOnly(List<? extends T1> c, GridClosure<? super T1,T2> trans) Creates read-only light-weight view on given list with provided transformation.
static <T1,T2> Collection<T2>	GridFunc.viewReadOnly(Collection<? extends T1> c, GridClosure<? super T1,T2> trans, GridPredicate<? super T1>... p) Creates read-only light-weight view on given collection with transformation and provided predicates.
static <K0,K extends K0,V0,V extends V0,V1> Map<K,V1>	GridFunc.viewReadOnly(Map<K,V> m, GridClosure<V,V1> trans, GridPredicate<? super K>... p) Read-only view on map that supports transformation of values and key filtering.
static <T,R> Collection<GridOutClosure<R>>	GridFunc.yield(Collection<? extends T> c, GridClosure<? super T,R> 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,R> Collection<GridOutClosure<R>>	GridFunc.yield(T[] c, GridClosure<? super T,R> f) Given array of items and a closure this method returns collection of closures where each closure is closed on a element of the array.

Method parameters in org.gridgain.grid.util.lang with type arguments of type GridClosure

Modifier and Type	Method and Description
static <T,R> Collection<GridOutClosure<R>>	GridFunc.curry(Collection<? extends GridClosure<? super T,R>> closures, Collection<? extends T> args) Curries collection of closures with given collection of arguments.
static <T,R> Collection<GridOutClosure<R>>	GridFunc.curry(Collection<? extends GridClosure<? super T,R>> iter, T arg) Curries collection of closures with given argument.

Uses of GridClosure in org.gridgain.grid.util.typedef

Subinterfaces of GridClosure in org.gridgain.grid.util.typedef

Modifier and Type	Interface and Description
interface	C1<E1,R> Defines alias for GridClosure by extending it.

Classes in org.gridgain.grid.util.typedef that implement GridClosure

Modifier and Type	Class and Description
class	CX1<E1,R> Defines alias for GridClosureX by extending it.