| Package | Description |
|---|---|
| org.gridgain.grid |
Contains entry-point GridGain & HPC APIs.
|
| org.gridgain.grid.cache |
Contains main Data Grid APIs.
|
| org.gridgain.grid.kernal.managers.swapspace |
TODO.
|
| org.gridgain.grid.kernal.processors.cache | |
| org.gridgain.grid.kernal.processors.streamer |
TODO. |
| org.gridgain.grid.kernal.processors.streamer.task | |
| org.gridgain.grid.spi.swapspace |
Contains APIs for swap space SPI.
|
| org.gridgain.grid.spi.swapspace.file |
Contains file-based swap space SPI.
|
| org.gridgain.grid.spi.swapspace.noop |
Contains default no-op swap space SPI implementation.
|
| org.gridgain.grid.streamer |
Contains main Streaming APIs.
|
| org.gridgain.grid.util |
System-wide utility routine and helper classes.
|
| org.gridgain.grid.util.future |
Future related classes.
|
| org.gridgain.grid.util.lang | |
| org.gridgain.grid.util.nio |
NIO server interfaces and common utility classes for NIO.
|
| org.gridgain.grid.util.typedef |
Contains typedefs definitions for frequently used classes.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridFuture.listenAsync(GridInClosure<? super GridFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFuture.stopListenAsync(GridInClosure<? super GridFuture<R>>... lsnr)
Removes given listeners from the future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheProjection.forEach(GridInClosure<GridCacheEntry<K,V>> vis)
Executes visitor closure on each cache element.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridSwapSpaceManager.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
void |
GridSwapSpaceManager.remove(String spaceName,
Object key,
GridInClosure<byte[]> c,
ClassLoader ldr)
Removes value from swap.
|
| Modifier and Type | Method and Description |
|---|---|
static GridInClosure<GridFuture<?>> |
GridCacheUtils.errorLogger(GridLogger log,
Class<? extends Exception>... excl) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridCacheProjectionImpl.forEach(GridInClosure<GridCacheEntry<K,V>> vis)
Executes visitor closure on each cache element.
|
void |
GridCacheAdapter.forEach(GridInClosure<GridCacheEntry<K,V>> vis)
Executes visitor closure on each cache element.
|
void |
GridCacheProxyImpl.forEach(GridInClosure<GridCacheEntry<K,V>> vis)
Executes visitor closure on each cache element.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerContextDelegate.broadcast(GridInClosure<GridStreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
GridStreamerContextImpl.broadcast(GridInClosure<GridStreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
GridStreamerContextDelegate.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
void |
GridStreamerContextImpl.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
| Constructor and Description |
|---|
GridStreamerBroadcastTask(GridInClosure<GridStreamerContext> clo,
String streamer) |
| Modifier and Type | Method and Description |
|---|---|
void |
GridSwapSpaceSpi.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
GridSwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridFileSwapSpaceSpi.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
GridSwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNoopSwapSpaceSpi.remove(String spaceName,
GridSwapKey key,
GridInClosure<byte[]> c,
GridSwapContext ctx)
Removes value stored in data space with given name corresponding to specified key.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridStreamerContext.broadcast(GridInClosure<GridStreamerContext> clo)
Queries all streamer nodes deployed within grid.
|
void |
GridStreamerContext.broadcast(GridInClosure<GridStreamerContext> clo,
Collection<GridNode> nodes)
Queries streamer nodes deployed within grid.
|
| Modifier and Type | Method and Description |
|---|---|
static GridJavaProcess |
GridJavaProcess.exec(Class cls,
String params,
GridLogger log,
GridInClosure<String> printC,
GridAbsClosure procKilledC)
Executes main() method of the given class in a separate system process.
|
static GridJavaProcess |
GridJavaProcess.exec(Class cls,
String params,
GridLogger log,
GridInClosure<String> printC,
GridAbsClosure procKilledC,
Collection<String> jvmArgs,
String cp)
Executes main() method of the given class in a separate system process.
|
void |
GridCircularBuffer.forEach(GridInClosure<T> c)
Executes given closure for every item in circular buffer.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridFutureChainListener<T,R>
Future listener to fill chained future with converted result of the source future.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridFutureAdapter.listenAsync(GridInClosure<? super GridFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFutureAdapterEx.listenAsync(GridInClosure<? super GridFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFinishedFutureEx.listenAsync(GridInClosure<? super GridFuture<T>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFinishedFuture.listenAsync(GridInClosure<? super GridFuture<T>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridFutureAdapter.stopListenAsync(GridInClosure<? super GridFuture<R>>... lsnr)
Removes given listeners from the future.
|
void |
GridFutureAdapterEx.stopListenAsync(GridInClosure<? super GridFuture<R>>... lsnr)
Removes given listeners from the future.
|
void |
GridFinishedFutureEx.stopListenAsync(GridInClosure<? super GridFuture<T>>... lsnr)
Removes given listeners from the future.
|
void |
GridFinishedFuture.stopListenAsync(GridInClosure<? super GridFuture<T>>... lsnr)
Removes given listeners from the future.
|
| Modifier and Type | Class and Description |
|---|---|
class |
GridInClosureX<T>
Convenient in-closure subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> GridInClosure<T> |
GridFunc.ciInvoke(String mtdName,
Object... args)
Creates in closure that will reflectively call a method with the given name on
closure's argument.
|
static <T> GridInClosure<T> |
GridFunc.print()
Gets closure that prints out its bound variable
|
static <T> GridInClosure<T> |
GridFunc.print(String pre,
String post)
Gets closure that prints out its bound variable.
|
static <T> GridInClosure<T> |
GridFunc.printf(String fmt)
Gets closure that prints out its bound variable.
|
static <T> GridInClosure<T> |
GridFunc.println()
Gets closure that calls
System.out.println() on its bound variable. |
static <T> GridInClosure<T> |
GridFunc.println(String pre,
String post)
Gets closure that prints out its bound variable.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> Collection<GridAbsClosure> |
GridFunc.curry(GridInClosure<? super T> c,
Collection<? extends T> args)
Curries collection of closures with given collection of arguments.
|
static <T> GridAbsClosure |
GridFunc.curry(GridInClosure<? super T> f,
T e)
Curries given closure.
|
static <T> Collection<GridAbsClosure> |
GridFunc.curry(int cnt,
GridInClosure<? super T> c,
GridOutClosure<T> pdc)
Curries collection of closures with given collection of arguments.
|
static <X> void |
GridFunc.forEach(Iterable<? extends X> c,
GridInClosure<? super X> f,
GridPredicate<? super X>... p)
Calls given
side-effect only closure over the each element of the provided
collection. |
static <K,V> void |
GridFunc.forEach(Map<? extends K,? extends V> m,
GridInClosure<? super GridBiTuple<K,V>> f,
GridPredicate<? super GridBiTuple<K,V>>... p)
Calls given
side-effect only closure (if provided) over the each element of the
provided map. |
static <X> void |
GridFunc.forEach(X[] c,
GridInClosure<? super X> f,
GridPredicate<? super X>... p)
Calls given
side-effect only closure over the each element of the provided array. |
static <T> Collection<GridAbsClosure> |
GridFunc.yield(Collection<? extends T> c,
GridInClosure<? super T> f)
Given collection of items and a closure this method returns read-only collection of
closures where each closure is closed on an element of the initial collection.
|
static <T> Collection<GridAbsClosure> |
GridFunc.yield(T[] c,
GridInClosure<? super T> f)
Given collection of items and a closure this method returns collection
of closures where each closure is closed on an element of the initial collection.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> Collection<GridAbsClosure> |
GridFunc.curry0(Collection<? extends GridInClosure<? super T>> in,
Collection<? extends T> args)
Curries collection of in closures with given collection of arguments.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GridNioFuture.listenAsync(GridInClosure<? super GridNioFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridNioFinishedFuture.listenAsync(GridInClosure<? super GridNioFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
void |
GridNioFutureImpl.listenAsync(GridInClosure<? super GridNioFuture<R>> lsnr)
Registers listener closure to be asynchronously notified whenever future completes.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CI1<T>
Defines
alias for GridInClosure by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
CIX1<T>
Defines
alias for GridInClosureX by extending it. |
Copyright © 2014. All rights reserved.