| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.query | |
| org.apache.ignite.internal.processors.closure |
TODO.
|
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processer.
|
| org.apache.ignite.internal.util |
System-wide utility routine and helper classes.
|
| org.apache.ignite.internal.util.future |
Future related classes.
|
| org.apache.ignite.internal.util.lang | |
| org.apache.ignite.internal.util.typedef |
Contains typedefs definitions for frequently used classes.
|
| org.apache.ignite.internal.visor.util | |
| org.apache.ignite.lang |
Contains general language constructs and functional APIs for distributed computations.
|
| 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.
|
<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.
|
| 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.
|
<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.
|
<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.
|
| 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<GridDhtLocalPartition,GridDhtPartitionState> |
GridCacheUtils.part2state() |
static <K,V> IgniteClosure<IgniteInternalTx,GridCacheVersion> |
GridCacheUtils.tx2xidVersion() |
static IgniteClosure<Integer,GridCacheVersion[]> |
GridCacheUtils.versionArrayFactory() |
| 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.
|
| 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<Object,Object> |
GridCacheQueryBean.transform() |
IgniteClosure<Object,Object> |
GridCacheQueryRequest.transformer() |
| Modifier and Type | Method and Description |
|---|---|
<R> CacheQueryFuture<R> |
GridCacheQueryAdapter.execute(IgniteClosure<T,R> rmtTransform,
Object... args)
Executes the query the same way as
CacheQuery.execute(Object...) method but transforms result remotely. |
<R> CacheQueryFuture<R> |
CacheQuery.execute(IgniteClosure<T,R> rmtTransform,
Object... args)
Executes the query the same way as
CacheQuery.execute(Object...) method but transforms result remotely. |
| Constructor and Description |
|---|
GridCacheQueryBean(GridCacheQueryAdapter<?> qry,
IgniteReducer<Object,Object> rdc,
IgniteClosure<Object,Object> 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<Object,Object> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepPortable,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer) |
| Modifier and Type | Method and Description |
|---|---|
<T,R> IgniteInternalFuture<Collection<R>> |
GridClosureProcessor.broadcast(IgniteClosure<T,R> job,
T arg,
Collection<ClusterNode> nodes) |
<T,R> IgniteInternalFuture<Collection<R>> |
GridClosureProcessor.broadcastNoFailover(IgniteClosure<T,R> job,
T arg,
Collection<ClusterNode> nodes) |
<T,R> ComputeTaskInternalFuture<Collection<R>> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
Collection<? extends T> args,
Collection<ClusterNode> nodes) |
<T,R> ComputeTaskInternalFuture<R> |
GridClosureProcessor.callAsync(IgniteClosure<T,R> job,
T arg,
Collection<ClusterNode> nodes) |
<T,R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.callAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc,
Collection<ClusterNode> nodes) |
| Modifier and Type | Method and Description |
|---|---|
IgfsFileInfo |
IgfsMetaManager.updateInfo(IgniteUuid fileId,
IgniteClosure<IgfsFileInfo,IgfsFileInfo> c)
Update file info in cache.
|
| 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.
|
<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.
|
protected <T> IgniteInternalFuture<T> |
IgniteFutureImpl.chainInternal(IgniteClosure<? super IgniteFuture<V>,T> doneCb) |
| Constructor and Description |
|---|
GridFutureChainListener(GridFutureAdapter<R> fut,
IgniteClosure<? super IgniteInternalFuture<T>,R> doneCb)
Constructs chain listener.
|
| 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 <K,V> IgniteClosure<javax.cache.Cache.Entry<K,V>,K> |
GridFunc.cacheEntry2Key()
Gets closure that returns key for cache 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()
Gets closure that return
toString() value for its free variable. |
| Modifier and Type | Method and Description |
|---|---|
static <T,R> IgniteOutClosure<R> |
GridFunc.curry(IgniteClosure<? super T,R> f,
T e)
Curries given closure.
|
static <V,Y> Y |
GridFunc.find(Iterable<? extends V> c,
Y dfltVal,
IgniteClosure<? super V,Y> f,
IgnitePredicate<? super V>... p)
Finds, transforms and returns first element in given collection for which any of
the provided predicates evaluates to
true. |
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)
Transforms an array to read only collection using provided closure.
|
static <T1,T2> List<T2> |
GridFunc.transformList(Collection<? extends T1> c,
IgniteClosure<? super T1,T2> trans,
IgnitePredicate<? super T1>... p)
Creates a view on given list with provided transformer and predicates.
|
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> List<T2> |
GridFunc.viewListReadOnly(List<? extends T1> c,
IgniteClosure<? 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,
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 | 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,
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.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.4.0 Release Date : September 24 2015