Uses of Interface
org.apache.ignite.lang.IgniteClosure
-
Packages that use IgniteClosure Package Description org.apache.ignite Contains entry-point Ignite & HPC APIs.org.apache.ignite.cache.query Contains APIs for creating and executing cache queries.org.apache.ignite.lang Contains general language constructs and functional APIs for distributed computations. -
-
Uses of IgniteClosure in org.apache.ignite
Methods in org.apache.ignite with parameters of type IgniteClosure Modifier and Type Method Description <T,R>
Collection<R>IgniteCompute. apply(IgniteClosure<T,R> job, Collection<? extends T> args)
Executes provided closure job on nodes within the underlying cluster group.<R,T>
RIgniteCompute. apply(IgniteClosure<T,R> job, T arg)
Executes provided closure job on a node within the underlying cluster group.<R1,R2,T>
R2IgniteCompute. apply(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)
Executes provided closure job on nodes within the underlying cluster group.<T,R>
IgniteFuture<Collection<R>>IgniteCompute. applyAsync(IgniteClosure<T,R> job, Collection<? extends T> args)
Executes provided closure job asynchronously on nodes within the underlying cluster group.<R,T>
IgniteFuture<R>IgniteCompute. applyAsync(IgniteClosure<T,R> job, T arg)
Executes provided closure job asynchronously on a node within the underlying cluster group.<R1,R2,T>
IgniteFuture<R2>IgniteCompute. applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)
Executes provided closure job asynchronously on nodes within the underlying cluster group.<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.<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.<T,R>
QueryCursor<R>IgniteCache. query(Query<T> qry, IgniteClosure<T,R> transformer)
Queries the cache transforming the entries on the server nodes. -
Uses of IgniteClosure in org.apache.ignite.cache.query
Methods in org.apache.ignite.cache.query that return types with arguments of type IgniteClosure Modifier and Type Method Description javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,T>>
ContinuousQueryWithTransformer. getRemoteTransformerFactory()
Gets remote transformer factoryMethod parameters in org.apache.ignite.cache.query with type arguments of type IgniteClosure Modifier and Type Method Description ContinuousQueryWithTransformer<K,V,T>
ContinuousQueryWithTransformer. setRemoteTransformerFactory(javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,T>> factory)
Sets transformer factory. -
Uses of IgniteClosure in org.apache.ignite.lang
Methods in org.apache.ignite.lang with parameters of type IgniteClosure Modifier and Type Method Description <T> IgniteFuture<T>
IgniteFuture. chain(IgniteClosure<? super IgniteFuture<V>,T> doneCb)
Make a chained future to convert result of this future (when complete) into a new format.<T> IgniteFuture<T>
IgniteFuture. chainAsync(IgniteClosure<? super IgniteFuture<V>,T> doneCb, Executor exec)
Make a chained future to convert result of this future (when complete) into a new format.
-