Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.streamer |
Contains main Streaming APIs.
|
Modifier and Type | Method and Description |
---|---|
<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 this grid projection.
|
<R1,R2> R2 |
IgniteCompute.call(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs on nodes within this grid projection.
|
Modifier and Type | Method and Description |
---|---|
<R1,R2> R2 |
StreamerContext.reduce(IgniteClosure<StreamerContext,R1> clo,
IgniteReducer<R1,R2> rdc)
Queries all streamer nodes deployed within grid.
|
<R1,R2> R2 |
StreamerContext.reduce(IgniteClosure<StreamerContext,R1> clo,
IgniteReducer<R1,R2> rdc,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015