Uses of Interface
org.apache.ignite.lang.IgniteClosure
-
-
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.internal
Methods in org.apache.ignite.internal with parameters of type IgniteClosure Modifier and Type Method Description <T,R>
Collection<R>IgniteComputeImpl. apply(IgniteClosure<T,R> job, @Nullable Collection<? extends T> args)Executes provided closure job on nodes within the underlying cluster group.<R,T>
RIgniteComputeImpl. apply(IgniteClosure<T,R> job, T arg)Executes provided closure job on a node within the underlying cluster group.<R1,R2,T>
R2IgniteComputeImpl. 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>
IgniteInternalFuture<Collection<R>>IgniteComputeHandler. applyAsync(IgniteClosure<T,R> job, @Nullable Collection<? extends T> args)Apply implementation.<R,T>
IgniteInternalFuture<R>IgniteComputeHandler. applyAsync(IgniteClosure<T,R> job, T arg)Apply implementation.<R1,R2,T>
IgniteInternalFuture<R2>IgniteComputeHandler. applyAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc)Apply with reducer implementation.<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.<R,T>
Collection<R>IgniteComputeImpl. broadcast(IgniteClosure<T,R> job, T arg)Broadcasts given closure job with passed in argument to all nodes in the cluster group.<R,T>
IgniteInternalFuture<Collection<R>>IgniteComputeHandler. broadcastAsync(IgniteClosure<T,R> job, T arg)Broadcast implementation.<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.<T> IgniteInternalFuture<T>IgniteInternalFuture. chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)Make a chained future to convert result of this future (when complete) into a new format.<T> IgniteInternalFuture<T>IgniteInternalFuture. chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.<T> IgniteInternalFuture<T>IgniteInternalFuture. chainCompose(IgniteClosure<? super IgniteInternalFuture<R>,IgniteInternalFuture<T>> doneCb)Make a chained future that is completed whendoneCbis executed.<T> IgniteInternalFuture<T>IgniteInternalFuture. chainCompose(IgniteClosure<? super IgniteInternalFuture<R>,IgniteInternalFuture<T>> doneCb, Executor exec)Make a chained future that is completed whendoneCbis executed.static IgniteDiagnosticMessageIgniteDiagnosticMessage. createRequest(Marshaller marsh, IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c, long futId) -
Uses of IgniteClosure in org.apache.ignite.internal.cdc
Methods in org.apache.ignite.internal.cdc with parameters of type IgniteClosure Modifier and Type Method Description booleanWalRecordsConsumer. onRecords(Iterator<DataEntry> entries, IgniteClosure<DataEntry,CdcEvent> transform, @Nullable IgnitePredicate<? super DataEntry> filter)Handles data entries. -
Uses of IgniteClosure in org.apache.ignite.internal.processors.cache
Fields in org.apache.ignite.internal.processors.cache declared as IgniteClosure Modifier and Type Field Description protected static IgniteClosureGridCacheAdapter. RET2NULLGridCacheReturn-to-null conversion.Methods in org.apache.ignite.internal.processors.cache that return IgniteClosure Modifier and Type Method Description static IgniteClosure<GridCacheEntryEx,KeyCacheObject>GridCacheUtils. entry2Key()static <K,V>
IgniteClosure<Integer,IgnitePredicate<javax.cache.Cache.Entry<K,V>>[]>GridCacheUtils. factory()Entry predicate factory mostly used for deserialization.static <K,V>
IgniteClosure<GridCacheEntryInfo,K>GridCacheUtils. info2Key()static IgniteClosure<IgniteInternalTx,GridCacheVersion>GridCacheUtils. tx2xidVersion()Methods in org.apache.ignite.internal.processors.cache with parameters of type IgniteClosure Modifier and Type Method Description <T> IgniteFuture<T>IgniteCacheFutureImpl. 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>IgniteCacheFutureImpl. 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.<T,R>
QueryCursor<R>GatewayProtectedCacheProxy. query(Query<T> qry, IgniteClosure<T,R> transformer)Queries the cache transforming the entries on the server nodes.<T,R>
QueryCursor<R>IgniteCacheProxyImpl. query(Query<T> qry, IgniteClosure<T,R> transformer)Queries the cache transforming the entries on the server nodes.Constructors in org.apache.ignite.internal.processors.cache with parameters of type IgniteClosure Constructor Description GridCacheIterator(GridCacheContext<K,V> cctx, Iterable<? extends javax.cache.Cache.Entry<K,V>> c, IgniteClosure<javax.cache.Cache.Entry<K,V>,T> trans, IgnitePredicate<javax.cache.Cache.Entry<K,V>>[] filter) -
Uses of IgniteClosure in org.apache.ignite.internal.processors.cache.query
Methods in org.apache.ignite.internal.processors.cache.query that return IgniteClosure Modifier and Type Method Description <K,V>
@Nullable IgniteClosure<Map.Entry<K,V>,Object>CacheQuery. transform()@Nullable IgniteClosure<?,?>GridCacheQueryBean. transform()IgniteClosure<javax.cache.Cache.Entry<K,V>,R>AbstractScanQueryIterator. transformer()IgniteClosure<?,?>GridCacheQueryRequest. transformer()Methods in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteClosure Modifier and Type Method Description <T,R>
CacheQuery<R>GridCacheQueryManager. createScanQuery(@Nullable IgniteBiPredicate<K,V> filter, @Nullable IgniteClosure<T,R> trans, @Nullable Integer part, boolean keepBinary, boolean forceLocal, Boolean dataPageScanEnabled, Set<KeyCacheObject> skipKeys)Creates user's predicate based scan query.Constructors in org.apache.ignite.internal.processors.cache.query with parameters of type IgniteClosure Constructor Description AbstractScanQueryIterator(GridCacheContext<K,V> cctx, CacheQuery<R> qry, IgniteClosure<javax.cache.Cache.Entry<K,V>,R> transform, boolean locNode)CacheQuery(GridCacheContext<?,?> cctx, GridCacheQueryType type, @Nullable IgniteBiPredicate<Object,Object> filter, @Nullable IgniteClosure<Map.Entry,Object> transform, @Nullable Integer part, boolean keepBinary, boolean forceLocal, Boolean dataPageScanEnabled, @Nullable Set<KeyCacheObject> skipKeys)Cache query adapter for SCAN query.GridCacheQueryBean(CacheQuery<?> qry, @Nullable IgniteReducer<Object,Object> rdc, @Nullable IgniteClosure<?,?> trans, @Nullable Object[] args) -
Uses of IgniteClosure in org.apache.ignite.internal.processors.cache.query.continuous
Methods in org.apache.ignite.internal.processors.cache.query.continuous that return IgniteClosure Modifier and Type Method Description IgniteClosure<E,R>SecurityAwareTransformerFactory. create()@Nullable IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>CacheContinuousQueryHandler. getTransformer()IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>CacheContinuousQueryHandler. getTransformer0()IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>CacheContinuousQueryHandlerV3. getTransformer0()Constructor parameters in org.apache.ignite.internal.processors.cache.query.continuous with type arguments of type IgniteClosure Constructor Description SecurityAwareTransformerFactory(UUID subjectId, javax.cache.configuration.Factory<IgniteClosure<E,R>> original) -
Uses of IgniteClosure in org.apache.ignite.internal.processors.closure
Fields in org.apache.ignite.internal.processors.closure declared as IgniteClosure Modifier and Type Field Description protected IgniteClosure<T,R>GridClosureProcessor.C1. jobMethods in org.apache.ignite.internal.processors.closure that return IgniteClosure Modifier and Type Method Description IgniteClosureGridClosureProcessor.C1. userObject()Get user object where resources must be injected.Methods in org.apache.ignite.internal.processors.closure with parameters of type IgniteClosure Modifier and Type Method Description <T,R>
IgniteInternalFuture<Collection<R>>GridClosureProcessor. broadcast(IgniteClosure<T,R> job, T arg, TaskExecutionOptions opts)<T,R>
ComputeTaskInternalFuture<Collection<R>>GridClosureProcessor. callAsync(IgniteClosure<T,R> job, @Nullable Collection<? extends T> args, TaskExecutionOptions opts)<T,R>
ComputeTaskInternalFuture<R>GridClosureProcessor. callAsync(IgniteClosure<T,R> job, T arg, TaskExecutionOptions opts)<T,R1,R2>
ComputeTaskInternalFuture<R2>GridClosureProcessor. callAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc, TaskExecutionOptions opts) -
Uses of IgniteClosure in org.apache.ignite.internal.processors.cluster
Methods in org.apache.ignite.internal.processors.cluster with parameters of type IgniteClosure Modifier and Type Method Description IgniteInternalFuture<String>ClusterProcessor. requestDiagnosticInfo(UUID nodeId, IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c, String baseMsg)Sends diagnostic message closure to remote node. -
Uses of IgniteClosure in org.apache.ignite.internal.processors.configuration.distributed
Constructors in org.apache.ignite.internal.processors.configuration.distributed with parameters of type IgniteClosure Constructor Description DistributedEnumProperty(String name, String desc, IgniteClosure<Integer,T> fromOrdinalFunc, IgniteClosure<T,Integer> toOrdinalFunc, Class<T> enumCls)Property constructor. -
Uses of IgniteClosure in org.apache.ignite.internal.processors.datastreamer
Methods in org.apache.ignite.internal.processors.datastreamer with parameters of type IgniteClosure Modifier and Type Method Description static byteDataStreamProcessor. ioPolicy(@Nullable IgniteClosure<ClusterNode,Byte> rslvr, ClusterNode node)Get IO policy for particular node with provided resolver.voidDataStreamerImpl. ioPolicyResolver(IgniteClosure<ClusterNode,Byte> ioPlcRslvr) -
Uses of IgniteClosure in org.apache.ignite.internal.processors.platform
Classes in org.apache.ignite.internal.processors.platform that implement IgniteClosure Modifier and Type Class Description classPlatformAbstractConfigurationClosureAbstract interop configuration closure.Methods in org.apache.ignite.internal.processors.platform that return IgniteClosure Modifier and Type Method Description protected abstract IgniteClosure<IgniteConfiguration,IgniteConfiguration>PlatformAbstractBootstrap. closure(long envPtr)Get configuration transformer closure. -
Uses of IgniteClosure in org.apache.ignite.internal.processors.platform.compute
Methods in org.apache.ignite.internal.processors.platform.compute with parameters of type IgniteClosure Modifier and Type Method Description IgniteInternalFuturePlatformCompute.ComputeConvertingFuture. chain(IgniteClosure doneCb)Make a chained future to convert result of this future (when complete) into a new format.IgniteInternalFuturePlatformCompute.ComputeConvertingFuture. chain(IgniteClosure doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.IgniteInternalFuturePlatformCompute.ComputeConvertingFuture. chainCompose(IgniteClosure doneCb)Make a chained future that is completed whendoneCbis executed.IgniteInternalFuturePlatformCompute.ComputeConvertingFuture. chainCompose(IgniteClosure doneCb, @Nullable Executor exec)Make a chained future that is completed whendoneCbis executed. -
Uses of IgniteClosure in org.apache.ignite.internal.processors.platform.cpp
Classes in org.apache.ignite.internal.processors.platform.cpp that implement IgniteClosure Modifier and Type Class Description classPlatformCppConfigurationClosureInterop CPP configuration closure. -
Uses of IgniteClosure in org.apache.ignite.internal.processors.platform.dotnet
Classes in org.apache.ignite.internal.processors.platform.dotnet that implement IgniteClosure Modifier and Type Class Description classPlatformDotNetConfigurationClosureClosure to apply dot net configuration. -
Uses of IgniteClosure in org.apache.ignite.internal.util
Methods in org.apache.ignite.internal.util that return IgniteClosure Modifier and Type Method Description static IgniteClosure<UUID,ClusterNode>IgniteUtils. id2Node(GridKernalContext ctx) -
Uses of IgniteClosure in org.apache.ignite.internal.util.future
Methods in org.apache.ignite.internal.util.future with parameters of type IgniteClosure Modifier and Type Method Description <R> IgniteInternalFuture<R>GridFinishedFuture. chain(IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)Make a chained future to convert result of this future (when complete) into a new format.<T1> IgniteInternalFuture<T1>GridFinishedFuture. chain(IgniteClosure<? super IgniteInternalFuture<T>,T1> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.<T> IgniteInternalFuture<T>GridFutureAdapter. chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb)Make a chained future to convert result of this future (when complete) into a new format.<T> IgniteInternalFuture<T>GridFutureAdapter. chain(IgniteClosure<? super IgniteInternalFuture<R>,T> doneCb, Executor exec)Make a chained future to convert result of this future (when complete) into a new format.<T> IgniteFuture<T>IgniteFutureImpl. 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>IgniteFutureImpl. 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.<R> IgniteInternalFuture<R>GridFinishedFuture. chainCompose(IgniteClosure<? super IgniteInternalFuture<T>,IgniteInternalFuture<R>> doneCb)Make a chained future that is completed whendoneCbis executed.<R> IgniteInternalFuture<R>GridFinishedFuture. chainCompose(IgniteClosure<? super IgniteInternalFuture<T>,IgniteInternalFuture<R>> doneCb, @Nullable Executor exec)Make a chained future that is completed whendoneCbis executed.<T> IgniteInternalFuture<T>GridFutureAdapter. chainCompose(IgniteClosure<? super IgniteInternalFuture<R>,IgniteInternalFuture<T>> doneCb)Make a chained future that is completed whendoneCbis executed.<T> IgniteInternalFuture<T>GridFutureAdapter. chainCompose(IgniteClosure<? super IgniteInternalFuture<R>,IgniteInternalFuture<T>> doneCb, @Nullable Executor exec)Make a chained future that is completed whendoneCbis executed.protected <T> IgniteInternalFuture<T>IgniteFutureImpl. chainInternal(IgniteClosure<? super IgniteFuture<V>,T> doneCb, @Nullable Executor exec) -
Uses of IgniteClosure in org.apache.ignite.internal.util.lang
Classes in org.apache.ignite.internal.util.lang that implement IgniteClosure Modifier and Type Class Description classIgniteClosureX<E,R>Convenient closure subclass that allows for thrown grid exception.Methods in org.apache.ignite.internal.util.lang that return IgniteClosure Modifier and Type Method Description static <K,V>
IgniteClosure<javax.cache.Cache.Entry<K,V>,V>GridFunc. cacheEntry2Get()Gets closure that returns value for an entry.static <T> IgniteClosure<T,T>GridFunc. identity()Gets identity closure, i.e. the closure that returns its variable value.static IgniteClosure<? super ClusterNode,UUID>GridFunc. node2id()Gets closure which converts node to node ID.static <T> IgniteClosure<T,String>GridFunc. string()Deprecated.Methods in org.apache.ignite.internal.util.lang with parameters of type IgniteClosure Modifier and Type Method Description static <T1,T2>
GridIterator<T2>GridFunc. iterator(Iterable<? extends T1> c, IgniteClosure<? super T1,T2> trans, boolean readOnly, @Nullable IgnitePredicate<? super T1>... p)Creates and returns transforming iterator from given collection and optional filtering predicates.static <T1,T2>
Iterator<T2>GridFunc. iterator(Iterator<? extends T1> c, IgniteClosure<? super T1,T2> trans, boolean readOnly, @Nullable IgnitePredicate<? super T1>... p)static <X,Y>
Collection<Y>GridFunc. transform(Collection<? extends X> c, IgniteClosure<? super X,Y> f)Transforms one collection to another using provided closure.static <X,Y>
Collection<Y>GridFunc. transform(X[] c, IgniteClosure<? super X,Y> f)Deprecated.static <T1,T2>
List<T2>GridFunc. transformList(Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, @Nullable IgnitePredicate<? super T1>... p)Deprecated.static <K0,K extends K0,V0,V extends V0>
Map<K,V>GridFunc. viewAsMap(@Nullable Set<K> c, IgniteClosure<? super K,V> mapClo, @Nullable IgnitePredicate<? super K>... p)Read-only map view of a collection.static <T1,T2>
Collection<T2>GridFunc. viewReadOnly(@Nullable Collection<? extends T1> c, IgniteClosure<? super T1,T2> trans, @Nullable IgnitePredicate<? 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(@Nullable Map<K,V> m, IgniteClosure<V,V1> trans, @Nullable IgnitePredicate<? super K>... p)Read-only view on map that supports transformation of values and key filtering. -
Uses of IgniteClosure in org.apache.ignite.internal.util.lang.gridfunc
Classes in org.apache.ignite.internal.util.lang.gridfunc that implement IgniteClosure Modifier and Type Class Description classCacheEntryGetValueClosureCache entry to get-value transformer closure.classClusterNodeGetIdClosureGrid node to node ID transformer closure.classIdentityClosureIdentity closure.classToStringClosure<T>Closure that returntoString()value for its free variable.Constructors in org.apache.ignite.internal.util.lang.gridfunc with parameters of type IgniteClosure Constructor Description PredicateSetView(Set<K> set, IgniteClosure<? super K,V> clo, IgnitePredicate<? super K>... preds)TransformCollectionView(Collection<? extends T2> col, IgniteClosure<? super T2,T1> clos, IgnitePredicate<? super T2>... preds)TransformFilteringIterator(Iterator<? extends T1> iter, IgniteClosure<? super T1,T2> clos, boolean readOnly, IgnitePredicate<? super T1>... preds)TransformMapView(Map<K,V> map, IgniteClosure<V,V1> clos, IgnitePredicate<? super K>... preds) -
Uses of IgniteClosure in org.apache.ignite.internal.util.typedef
Subinterfaces of IgniteClosure in org.apache.ignite.internal.util.typedef Modifier and Type Interface Description interfaceC1<E1,R>DefinesaliasforIgniteClosureby extending it.Classes in org.apache.ignite.internal.util.typedef that implement IgniteClosure Modifier and Type Class Description classCX1<E1,R>DefinesaliasforIgniteClosureXby extending it. -
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.
-