Package | Description |
---|---|
org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
org.apache.ignite.lang |
Contains general language constructs and functional APIs for distributed computations.
|
org.apache.ignite.logger.log4j |
Contains default Log4j implementation for logging.
|
org.apache.ignite.streamer |
Contains main Streaming APIs.
|
org.apache.ignite.streamer.index |
Contains APIs for indexing of streamer windows.
|
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 this grid projection.
|
<R,T> R |
IgniteCompute.apply(IgniteClosure<T,R> job,
T arg)
Executes provided closure job on a node in this grid projection.
|
<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.
|
<R,T> Collection<R> |
IgniteCompute.broadcast(IgniteClosure<T,R> job,
T arg)
Broadcasts given closure job with passed in argument to all nodes in grid projection.
|
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.
|
Modifier and Type | Method and Description |
---|---|
void |
Log4JExternallyRolledFileAppender.updateFilePath(IgniteClosure<String,String> filePathClos)
Sets closure that later evaluate file path.
|
void |
Log4jRollingFileAppender.updateFilePath(IgniteClosure<String,String> filePathClos)
Sets closure that later evaluate file path.
|
void |
Log4JFileAppender.updateFilePath(IgniteClosure<String,String> filePathClos)
Sets closure that later evaluate file path.
|
void |
Log4JDailyRollingFileAppender.updateFilePath(IgniteClosure<String,String> filePathClos)
Sets closure that later evaluate file path.
|
void |
Log4JLogger.updateFilePath(IgniteClosure<String,String> filePathClos)
Sets closure that later evaluate file path.
|
Modifier and Type | Method and Description |
---|---|
<R> Collection<R> |
StreamerContext.query(IgniteClosure<StreamerContext,R> clo)
Queries all streamer nodes deployed within grid.
|
<R> Collection<R> |
StreamerContext.query(IgniteClosure<StreamerContext,R> clo,
Collection<ClusterNode> nodes)
Queries streamer nodes deployed within grid.
|
<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.
|
Modifier and Type | Field and Description |
---|---|
protected IgniteClosure<StreamerIndexEntry<E,K,V>,K> |
StreamerIndexProviderAdapter.entryToKey |
protected IgniteClosure<StreamerIndexEntry<E,K,V>,V> |
StreamerIndexProviderAdapter.entryToVal |
Follow @ApacheIgnite
Apache Ignite Fabric : ver. 1.0.0-RC1 Release Date : February 16 2015