| 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,
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.
|
<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> 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.
|
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> |
IgniteCacheProxyImpl.query(Query<T> qry,
IgniteClosure<T,R> transformer)
Queries the cache transforming the entries on the server nodes.
|
<T,R> QueryCursor<R> |
GatewayProtectedCacheProxy.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 |
|---|---|
IgniteClosure<?,?> |
GridCacheQueryBean.transform() |
<K,V> IgniteClosure<Map.Entry<K,V>,Object> |
GridCacheQueryAdapter.transform() |
IgniteClosure<?,?> |
GridCacheQueryRequest.transformer() |
| Modifier and Type | Method and Description |
|---|---|
<T,R> CacheQuery<R> |
GridCacheQueryManager.createScanQuery(IgniteBiPredicate<K,V> filter,
IgniteClosure<T,R> trans,
Integer part,
boolean keepBinary)
Creates user's predicate based scan query.
|
| Constructor and Description |
|---|
GridCacheQueryAdapter(GridCacheContext<?,?> cctx,
GridCacheQueryType type,
IgniteBiPredicate<Object,Object> filter,
IgniteClosure<Map.Entry,Object> transform,
Integer part,
boolean keepBinary) |
GridCacheQueryBean(GridCacheQueryAdapter<?> qry,
IgniteReducer<Object,Object> rdc,
IgniteClosure<?,?> trans,
Object[] args) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
Integer part,
IgniteReducer<Object,Object> rdc,
IgniteClosure<?,?> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer,
boolean addDepInfo) |
| Modifier and Type | Method and Description |
|---|---|
protected IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?> |
CacheContinuousQueryHandler.getTransformer() |
protected IgniteClosure<javax.cache.event.CacheEntryEvent<? extends K,? extends V>,?> |
CacheContinuousQueryHandlerV3.getTransformer() |
| Modifier and Type | Method and Description |
|---|---|
UUID |
CacheContinuousQueryManager.executeQuery(javax.cache.event.CacheEntryUpdatedListener locLsnr,
ContinuousQueryWithTransformer.EventListener locTransLsnr,
CacheEntryEventSerializableFilter rmtFilter,
javax.cache.configuration.Factory<? extends javax.cache.event.CacheEntryEventFilter> rmtFilterFactory,
javax.cache.configuration.Factory<? extends IgniteClosure> rmtTransFactory,
int bufSize,
long timeInterval,
boolean autoUnsubscribe,
boolean loc,
boolean keepBinary,
boolean includeExpired) |
| Constructor and Description |
|---|
CacheContinuousQueryHandlerV3(String cacheName,
Object topic,
ContinuousQueryWithTransformer.EventListener<?> locTransLsnr,
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) |
| 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,
Collection<ClusterNode> nodes,
String execName) |
<T,R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
Collection<? extends T> args,
Collection<ClusterNode> nodes,
String execName) |
<T,R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
T arg,
Collection<ClusterNode> nodes,
String execName) |
<T,R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.callAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc,
Collection<ClusterNode> nodes,
String execName) |
| 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.
|
| Modifier and Type | Method and Description |
|---|---|
static byte |
DataStreamProcessor.ioPolicy(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.
|
| 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.
|
protected <T> IgniteInternalFuture<T> |
IgniteFutureImpl.chainInternal(IgniteClosure<? super IgniteFuture<V>,T> doneCb,
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<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 <V,Y> Y |
GridFunc.find(Iterable<? extends V> c,
Y dfltVal,
IgniteClosure<? super V,Y> f,
IgnitePredicate<? super V>... p)
Deprecated.
|
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(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(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(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 | Class and Description |
|---|---|
class |
VisorEventMapper
Mapper from grid event to Visor data transfer object.
|
| Modifier and Type | Method and Description |
|---|---|
static Collection<VisorGridEvent> |
VisorTaskUtils.collectEvents(Ignite ignite,
String evtOrderKey,
String evtThrottleCntrKey,
boolean all,
IgniteClosure<Event,VisorGridEvent> evtMapper)
Grabs local events and detects if events was lost since last poll.
|
static List<VisorGridEvent> |
VisorTaskUtils.collectEvents(Ignite ignite,
String evtOrderKey,
String evtThrottleCntrKey,
int[] evtTypes,
IgniteClosure<Event,VisorGridEvent> evtMapper)
Grabs local events and detects if events was lost since last poll.
|
| 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 Fabric : ver. 2.6.0 Release Date : July 10 2018