| Modifier and Type | Method and 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> R |
IgniteCompute.apply(IgniteClosure<T,R> job,
T arg)
Executes provided closure job on a node within the underlying cluster group.
|
<R1,R2,T> R2 |
IgniteCompute.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.
|
| Modifier and Type | Method and Description |
|---|---|
javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,T>> |
ContinuousQueryWithTransformer.getRemoteTransformerFactory()
Gets remote transformer factory
|
| Modifier and Type | Method and 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.
|
| Modifier and Type | Method and 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> R |
IgniteComputeImpl.apply(IgniteClosure<T,R> job,
T arg)
Executes provided closure job on a node within the underlying cluster group.
|
<R1,R2,T> R2 |
IgniteComputeImpl.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>> |
IgniteComputeImpl.applyAsync(IgniteClosure<T,R> job,
Collection<? extends T> args)
Executes provided closure job asynchronously 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> IgniteFuture<R> |
IgniteComputeImpl.applyAsync(IgniteClosure<T,R> job,
T arg)
Executes provided closure job asynchronously on a node within the underlying cluster group.
|
<R,T> IgniteInternalFuture<R> |
IgniteComputeHandler.applyAsync(IgniteClosure<T,R> job,
T arg)
Apply implementation.
|
<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.
|
<R1,R2,T> IgniteInternalFuture<R2> |
IgniteComputeHandler.applyAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc)
Apply with reducer implementation.
|
<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> 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.
|
<R,T> IgniteInternalFuture<Collection<R>> |
IgniteComputeHandler.broadcastAsync(IgniteClosure<T,R> job,
T arg)
Broadcast implementation.
|
<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 when
doneCb is executed. |
<T> IgniteInternalFuture<T> |
IgniteInternalFuture.chainCompose(IgniteClosure<? super IgniteInternalFuture<R>,IgniteInternalFuture<T>> doneCb,
Executor exec)
Make a chained future that is completed when
doneCb is executed. |
static IgniteDiagnosticMessage |
IgniteDiagnosticMessage.createRequest(Marshaller marsh,
IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c,
long futId) |
| Modifier and Type | Field and Description |
|---|---|
protected static IgniteClosure |
GridCacheAdapter.RET2NULL
GridCacheReturn-to-null conversion. |
| Modifier and Type | Method and 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() |
| Modifier and Type | Method and 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.
|
| Constructor and 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) |
| Modifier and Type | Method and Description |
|---|---|
@Nullable IgniteClosure<?,?> |
GridCacheQueryBean.transform() |
<K,V> @Nullable IgniteClosure<Map.Entry<K,V>,Object> |
GridCacheQueryAdapter.transform() |
IgniteClosure |
GridCacheQueryManager.ScanQueryIterator.transformer() |
IgniteClosure<?,?> |
GridCacheQueryRequest.transformer() |
| Modifier and Type | Method and 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)
Creates user's predicate based scan query.
|
| Constructor and Description |
|---|
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
@Nullable IgniteBiPredicate<Object,Object> filter,
@Nullable IgniteClosure<Map.Entry,Object> transform,
@Nullable Integer part,
boolean keepBinary,
boolean forceLocal,
Boolean dataPageScanEnabled)
Cache query adapter for SCAN query.
|
GridCacheQueryBean(GridCacheQueryAdapter<?> qry,
@Nullable IgniteReducer<Object,Object> rdc,
@Nullable IgniteClosure<?,?> trans,
@Nullable Object[] args) |
| Modifier and Type | Method and 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>,?> |
CacheContinuousQueryHandlerV3.getTransformer0() |
IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?> |
CacheContinuousQueryHandler.getTransformer0() |
| Constructor and Description |
|---|
CacheContinuousQueryHandlerV3(String cacheName,
Object topic,
ContinuousQueryWithTransformer.EventListener<?> locTransLsnr,
@Nullable javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter<K,V>> rmtFilterFactory,
javax.cache.configuration.Factory<? extends IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?>> rmtTransFactory,
boolean oldValRequired,
boolean sync,
boolean ignoreExpired,
boolean ignoreClsNotFound) |
SecurityAwareTransformerFactory(UUID subjectId,
javax.cache.configuration.Factory<IgniteClosure<E,R>> original) |
| Modifier and Type | Field and Description |
|---|---|
protected IgniteClosure<T,R> |
GridClosureProcessor.C1.job |
| Modifier and Type | Method and Description |
|---|---|
IgniteClosure |
GridClosureProcessor.C1.userObject()
Get user object where resources must be injected.
|
| Modifier and Type | Method and 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) |
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture<String> |
ClusterProcessor.requestDiagnosticInfo(UUID nodeId,
IgniteClosure<GridKernalContext,IgniteDiagnosticInfo> c,
String baseMsg)
Sends diagnostic message closure to remote node.
|
| Constructor and Description |
|---|
DistributedEnumProperty(String name,
IgniteClosure<Integer,T> fromOrdinalFunc,
IgniteClosure<T,Integer> toOrdinalFunc,
Class<T> enumCls)
Property constructor.
|
DistributedEnumProperty(String name,
IgniteClosure<Integer,T> fromOrdinalFunc,
IgniteClosure<T,Integer> toOrdinalFunc,
Class<T> enumCls)
Property constructor.
|
| Modifier and Type | Method and Description |
|---|---|
static byte |
DataStreamProcessor.ioPolicy(@Nullable IgniteClosure<ClusterNode,Byte> rslvr,
ClusterNode node)
Get IO policy for particular node with provided resolver.
|
void |
DataStreamerImpl.ioPolicyResolver(IgniteClosure<ClusterNode,Byte> ioPlcRslvr) |
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformAbstractConfigurationClosure
Abstract interop configuration closure.
|
| Modifier and Type | Method and Description |
|---|---|
protected abstract IgniteClosure<IgniteConfiguration,IgniteConfiguration> |
PlatformAbstractBootstrap.closure(long envPtr)
Get configuration transformer closure.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteInternalFuture |
PlatformCompute.ComputeConvertingFuture.chain(IgniteClosure doneCb)
Make a chained future to convert result of this future (when complete) into a new format.
|
IgniteInternalFuture |
PlatformCompute.ComputeConvertingFuture.chain(IgniteClosure doneCb,
Executor exec)
Make a chained future to convert result of this future (when complete) into a new format.
|
IgniteInternalFuture |
PlatformCompute.ComputeConvertingFuture.chainCompose(IgniteClosure doneCb)
Make a chained future that is completed when
doneCb is executed. |
IgniteInternalFuture |
PlatformCompute.ComputeConvertingFuture.chainCompose(IgniteClosure doneCb,
@Nullable Executor exec)
Make a chained future that is completed when
doneCb is executed. |
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformCppConfigurationClosure
Interop CPP configuration closure.
|
| Modifier and Type | Class and Description |
|---|---|
class |
PlatformDotNetConfigurationClosure
Closure to apply dot net configuration.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteClosure<UUID,ClusterNode> |
IgniteUtils.id2Node(GridKernalContext ctx) |
| Modifier and Type | Method and Description |
|---|---|
<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> 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.
|
<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> 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.
|
<T> IgniteInternalFuture<T> |
GridFutureAdapter.chainCompose(IgniteClosure<? super IgniteInternalFuture<R>,IgniteInternalFuture<T>> doneCb)
Make a chained future that is completed when
doneCb is executed. |
<T> IgniteInternalFuture<T> |
GridFutureAdapter.chainCompose(IgniteClosure<? super IgniteInternalFuture<R>,IgniteInternalFuture<T>> doneCb,
@Nullable Executor exec)
Make a chained future that is completed when
doneCb is executed. |
<R> IgniteInternalFuture<R> |
GridFinishedFuture.chainCompose(IgniteClosure<? super IgniteInternalFuture<T>,IgniteInternalFuture<R>> doneCb)
Make a chained future that is completed when
doneCb is executed. |
<R> IgniteInternalFuture<R> |
GridFinishedFuture.chainCompose(IgniteClosure<? super IgniteInternalFuture<T>,IgniteInternalFuture<R>> doneCb,
@Nullable Executor exec)
Make a chained future that is completed when
doneCb is executed. |
protected <T> IgniteInternalFuture<T> |
IgniteFutureImpl.chainInternal(IgniteClosure<? super IgniteFuture<V>,T> doneCb,
@Nullable Executor exec) |
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteClosureX<E,R>
Convenient closure subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and 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.
|
| Modifier and Type | Method and Description |
|---|---|
static <T1,T2> GridIterator<T2> |
GridFunc.iterator(Iterable<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
boolean readOnly,
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,
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,
IgnitePredicate<? super T1>... p)
Deprecated.
|
static <K0,K extends K0,V0,V extends V0> |
GridFunc.viewAsMap(@Nullable Set<K> c,
IgniteClosure<? super K,V> mapClo,
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,
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> |
GridFunc.viewReadOnly(@Nullable Map<K,V> m,
IgniteClosure<V,V1> trans,
IgnitePredicate<? super K>... p)
Read-only view on map that supports transformation of values and key filtering.
|
| Modifier and Type | Class and Description |
|---|---|
class |
CacheEntryGetValueClosure
Cache entry to get-value transformer closure.
|
class |
ClusterNodeGetIdClosure
Grid node to node ID transformer closure.
|
class |
IdentityClosure
Identity closure.
|
class |
ToStringClosure<T>
Closure that return
toString() value for its free variable. |
| Constructor and 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) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
C1<E1,R>
Defines
alias for IgniteClosure by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
CX1<E1,R>
Defines
alias for IgniteClosureX by extending it. |
| Modifier and Type | Method and 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.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.15.0 Release Date : April 25 2023