| Package | Description |
|---|---|
| org.apache.ignite.internal.managers.communication |
TODO.
|
| org.apache.ignite.internal.util |
System-wide utility routine and helper classes.
|
| org.apache.ignite.internal.util.lang | |
| org.apache.ignite.internal.util.typedef |
Contains typedefs definitions for frequently used classes.
|
| Modifier and Type | Method and Description |
|---|---|
static void |
GridIoMessageFactory.registerCustom(byte type,
IgniteOutClosure<Message> c)
Registers factory for custom message.
|
| Modifier and Type | Method and Description |
|---|---|
static <R> R |
IgniteUtils.wrapThreadLoader(ClassLoader ldr,
IgniteOutClosure<R> c)
Sets thread context class loader to the given loader, executes the closure, and then
resets thread context class loader to its initial value.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
IgniteReducer2<E1,E2,R>
Defines generic
for-all or reduce type of closure. |
interface |
IgniteReducer3<E1,E2,E3,R>
Defines generic
for-all or reduce type of closure. |
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteOutClosureX<T>
Convenient out-closure subclass that allows for thrown grid exception.
|
class |
IgniteReducer2X<E1,E2,R>
Convenient reducer subclass that allows for thrown grid exception.
|
class |
IgniteReducer3X<E1,E2,E3,R>
Convenient reducer subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> IgniteOutClosure |
GridFunc.as(Future<T> fut)
Converts given future into the closure.
|
static IgniteOutClosure<Boolean> |
GridFunc.as(GridAbsPredicate p)
Converts given predicate to closure.
|
static <R> IgniteOutClosure<R> |
GridFunc.as0(Callable<R> c)
Converts given callable to an out-closure.
|
static <R> IgniteOutClosure<R> |
GridFunc.coInvoke(Class<?> cls,
String mtdName,
Object... args)
Creates out closure that will reflectively call a static method with the given name
and return result of that call.
|
static <R> IgniteOutClosure<R> |
GridFunc.coInvoke(Object o,
String mtdName,
Object... args)
Creates out closure that will reflectively call a method with the given name on provided
object and return result of that call.
|
static <R> IgniteOutClosure<R> |
GridFunc.constant(R val)
Gets closure that returns constant value.
|
static <T,R> IgniteOutClosure<R> |
GridFunc.curry(IgniteClosure<? super T,R> f,
T e)
Curries given closure.
|
static <T> IgniteOutClosure<T> |
GridFunc.factory(Class<T> cls)
Creates and returns new factory closure for the given type.
|
static <T> IgniteOutClosure<T> |
GridFunc.nill()
Returns out closure that always returns
null. |
| Modifier and Type | Method and Description |
|---|---|
static <T> IgniteClosure<Callable<T>,IgniteOutClosure<T>> |
GridFunc.c2c()
Returns closure that converts
Callable to IgniteOutClosure. |
static <T,R> Collection<IgniteOutClosure<R>> |
GridFunc.curry(Collection<? extends IgniteClosure<? super T,R>> closures,
Collection<? extends T> args)
Curries collection of closures with given collection of arguments.
|
static <T,R> Collection<IgniteOutClosure<R>> |
GridFunc.curry(Collection<? extends IgniteClosure<? super T,R>> iter,
T arg)
Curries collection of closures with given argument.
|
static <T,R> Collection<IgniteOutClosure<R>> |
GridFunc.curry(IgniteClosure<? super T,R> c,
Collection<? extends T> args)
Curries collection of closures with given collection of arguments.
|
static <T,R> Collection<IgniteOutClosure<R>> |
GridFunc.curry(int cnt,
IgniteClosure<? super T,R> c,
IgniteOutClosure<T> pdc)
Curries collection of closures with given collection of arguments.
|
static <T,R> Collection<IgniteOutClosure<R>> |
GridFunc.yield(Collection<? extends T> c,
IgniteClosure<? super T,R> 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,R> Collection<IgniteOutClosure<R>> |
GridFunc.yield(T[] c,
IgniteClosure<? super T,R> f)
Given array of items and a closure this method returns collection
of closures where each closure is closed on a element of the array.
|
| Modifier and Type | Method and Description |
|---|---|
static <T,R> Collection<IgniteOutClosure<R>> |
GridFunc.curry(int cnt,
IgniteClosure<? super T,R> c,
IgniteOutClosure<T> pdc)
Curries collection of closures with given collection of arguments.
|
static <T> Collection<GridAbsClosure> |
GridFunc.curry(int cnt,
IgniteInClosure<? super T> c,
IgniteOutClosure<T> pdc)
Curries collection of closures with given collection of arguments.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
CO<T>
Defines
alias for IgniteOutClosure by extending it. |
interface |
R2<E1,E2,R>
Defines
alias for IgniteReducer2 by extending it. |
interface |
R3<E1,E2,E3,R>
Defines
alias for IgniteReducer3 by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
COX<T>
Defines
alias for IgniteOutClosureX by extending it. |
class |
RX2<E1,E2,R>
Defines
alias for IgniteReducer2X by extending it. |
class |
RX3<E1,E2,E3,R>
Defines
alias for IgniteReducer3X by extending it. |
Follow @ApacheIgnite
Ignite Fabric : ver. 1.0.0 Release Date : March 31 2015