| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.cache.query |
Contains APIs for creating and executing cache queries.
|
| 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.
|
| 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> 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.
|
| Modifier and Type | Method and Description |
|---|---|
void |
Log4JLogger.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 |
Log4JExternallyRolledFileAppender.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.
|
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.7.2 Release Date : February 6 2019