| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.compute |
Contains Compute Grid functionality.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.cluster | |
| org.apache.ignite.internal.processors.cache | |
| org.apache.ignite.internal.processors.cache.transactions | |
| org.apache.ignite.internal.processors.datastreamer |
Data streamer processor.
|
| org.apache.ignite.internal.processors.igfs |
Contains high performance file system processer.
|
| org.apache.ignite.internal.util.future |
Future related classes.
|
| org.apache.ignite.internal.util.typedef |
Contains typedefs definitions for frequently used classes.
|
| org.apache.ignite.lang |
Contains general language constructs and functional APIs for distributed computations.
|
| org.apache.ignite.scheduler |
Contains Job Scheduling functionality.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
IgniteDataStreamer.addData(Collection<? extends Map.Entry<K,V>> entries)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
IgniteDataStreamer.addData(K key,
V val)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
IgniteDataStreamer.addData(Map.Entry<K,V> entry)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
IgniteDataStreamer.addData(Map<K,V> entries)
Adds data for streaming on remote node.
|
<R> IgniteFuture<R> |
IgniteScheduler.callLocal(Callable<R> c)
Executes given callable on internal system thread pool asynchronously.
|
IgniteFuture<?> |
IgniteDataStreamer.future()
Gets future for this streaming process.
|
IgniteFuture<?> |
IgniteCache.rebalance()
This cache node to re-balance its partitions.
|
IgniteFuture<?> |
IgniteDataStreamer.removeData(K key)
Adds key for removal on remote node.
|
IgniteFuture<?> |
IgniteScheduler.runLocal(Runnable r)
Executes given closure on internal system thread pool asynchronously.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
ComputeTaskFuture<R>
This class defines a handler for asynchronous task execution.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
ComputeTaskSession.mapFuture()
Gets future that will be completed when task "map" step has completed
(which means that
ComputeTask.map(List, Object) method has finished). |
| Modifier and Type | Field and Description |
|---|---|
protected ThreadLocal<IgniteFuture<?>> |
AsyncSupportAdapter.curFut
Future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
IgniteSchedulerImpl.callLocal(Callable<R> c)
Executes given callable on internal system thread pool asynchronously.
|
protected <R> IgniteFuture<R> |
AsyncSupportAdapter.createFuture(IgniteInternalFuture<R> fut) |
protected <R> IgniteFuture<R> |
IgniteComputeImpl.createFuture(IgniteInternalFuture<R> fut) |
<R> IgniteFuture<R> |
AsyncSupportAdapter.future()
Gets and resets future for previous asynchronous operation.
|
<R> IgniteFuture<R> |
AsyncSupportAdapter.future(boolean reset)
Gets and optionally resets future for previous asynchronous operation.
|
IgniteFuture<?> |
GridTaskSessionImpl.mapFuture()
Gets future that will be completed when task "map" step has completed
(which means that
ComputeTask.map(List, Object) method has finished). |
IgniteFuture<?> |
GridJobSessionImpl.mapFuture()
Gets future that will be completed when task "map" step has completed
(which means that
ComputeTask.map(List, Object) method has finished). |
IgniteFuture<?> |
IgniteSchedulerImpl.runLocal(Runnable r)
Executes given closure on internal system thread pool asynchronously.
|
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
IgniteClusterImpl.future()
Gets and resets future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
IgniteCacheProxy.rebalance()
This cache node to re-balance its partitions.
|
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
TransactionProxyImpl.future()
Gets and resets future for previous asynchronous operation.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteFuture<?> |
DataStreamerImpl.addData(Collection<? extends Map.Entry<K,V>> entries)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addData(K key,
V val)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addData(Map.Entry<K,V> entry)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addData(Map<K,V> entries)
Adds data for streaming on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.addDataInternal(Collection<? extends DataStreamerEntry> entries) |
IgniteFuture<?> |
DataStreamerImpl.addDataInternal(KeyCacheObject key,
CacheObject val) |
IgniteFuture<?> |
DataStreamerImpl.future()
Gets future for this streaming process.
|
IgniteFuture<?> |
DataStreamerImpl.removeData(K key)
Adds key for removal on remote node.
|
IgniteFuture<?> |
DataStreamerImpl.removeDataInternal(KeyCacheObject key) |
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
IgfsImpl.future()
Gets and resets future for previous asynchronous operation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteFinishedFutureImpl<V> |
class |
IgniteFutureImpl<V>
Implementation of public API future.
|
| 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.
|
| 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.
|
void |
IgniteFutureImpl.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
X.waitAll(Iterable<IgniteFuture<?>> futs)
Synchronously waits for all futures in the collection.
|
| 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.
|
<R> IgniteFuture<R> |
IgniteAsyncSupport.future()
Gets and resets future for previous asynchronous operation.
|
| 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.
|
void |
IgniteFuture.listen(IgniteInClosure<? super IgniteFuture<V>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
SchedulerFuture<R>
Future for cron-based scheduled execution.
|
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0-RC3 Release Date : March 24 2015