| Package | Description |
|---|---|
| org.apache.ignite |
Contains entry-point Ignite & HPC APIs.
|
| org.apache.ignite.internal |
Contains main implementation.
|
| org.apache.ignite.internal.processors.cache |
This package contain cache-related processors & persistence implementation.
|
| org.apache.ignite.internal.processors.cache.distributed.near | |
| org.apache.ignite.internal.processors.cache.mvcc | |
| org.apache.ignite.internal.processors.cache.query | |
| org.apache.ignite.internal.processors.closure |
TODO.
|
| org.apache.ignite.internal.util.future |
Future related classes.
|
| org.apache.ignite.internal.util.lang | |
| org.apache.ignite.internal.util.lang.gridfunc |
Contains utilities classes for
GridFunc. |
| org.apache.ignite.internal.util.typedef |
Contains typedefs definitions for frequently used classes.
|
| Modifier and Type | Method and Description |
|---|---|
<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.
|
<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.
|
<R1,R2> R2 |
IgniteCompute.call(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs on nodes within the underlying cluster group.
|
<R1,R2> IgniteFuture<R2> |
IgniteCompute.callAsync(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs asynchronously on nodes within the underlying cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
<R1,R2,T> R2 |
IgniteComputeImpl.apply(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc)
Executes provided closure job on nodes within the underlying cluster group.
|
<R1,R2,T> IgniteFuture<R2> |
IgniteComputeImpl.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.
|
<R1,R2> R2 |
IgniteComputeImpl.call(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs on nodes within the underlying cluster group.
|
<R1,R2> IgniteFuture<R2> |
IgniteComputeImpl.callAsync(Collection<? extends IgniteCallable<R1>> jobs,
IgniteReducer<R1,R2> rdc)
Executes collection of jobs asynchronously on nodes within the underlying cluster group.
|
| Modifier and Type | Method and Description |
|---|---|
static IgniteReducer<Boolean,Boolean> |
GridCacheUtils.boolReducer() |
static <T> IgniteReducer<Collection<T>,Collection<T>> |
GridCacheUtils.collectionsReducer(int size)
Gets reducer that aggregates collections.
|
static IgniteReducer<Long,Long> |
GridCacheUtils.longReducer() |
static <K,V> IgniteReducer<Map<K,V>,Map<K,V>> |
GridCacheUtils.mapsReducer(int size)
Gets reducer that aggregates maps into one.
|
static <T> IgniteReducer<T,Collection<T>> |
GridCacheUtils.objectsReducer()
Gets reducer that aggregates items into collection.
|
| Constructor and Description |
|---|
CacheObjectsReleaseFuture(String type,
AffinityTopologyVersion topVer,
@Nullable IgniteReducer<T,R> rdc) |
GridCacheCompoundFuture(@Nullable IgniteReducer<T,R> rdc) |
GridCacheCompoundIdentityFuture(@Nullable IgniteReducer<T,T> rdc) |
| Constructor and Description |
|---|
GridNearTxAbstractEnlistFuture(GridCacheContext<?,?> cctx,
GridNearTxLocal tx,
long timeout,
@Nullable IgniteReducer<T,T> rdc) |
| Modifier and Type | Class and Description |
|---|---|
class |
VacuumMetricsReducer
Vacuum metrics reducer.
|
| Modifier and Type | Method and Description |
|---|---|
IgniteReducer<Object,Object> |
GridCacheQueryRequest.reducer() |
@Nullable IgniteReducer<Object,Object> |
GridCacheQueryBean.reducer() |
| Modifier and Type | Method and Description |
|---|---|
<R> CacheQueryFuture<R> |
GridCacheQueryAdapter.execute(IgniteReducer<T,R> rmtReducer,
Object... args)
Executes the query the same way as
CacheQuery.execute(Object...) method but reduces result remotely. |
<R> CacheQueryFuture<R> |
CacheQuery.execute(IgniteReducer<T,R> rmtReducer,
Object... args)
Executes the query the same way as
CacheQuery.execute(Object...) method but reduces result remotely. |
| Constructor and Description |
|---|
GridCacheQueryBean(GridCacheQueryAdapter<?> qry,
@Nullable IgniteReducer<Object,Object> rdc,
@Nullable IgniteClosure<?,?> trans,
@Nullable Object[] args) |
GridCacheQueryRequest(int cacheId,
long id,
String cacheName,
GridCacheQueryType type,
boolean fields,
String clause,
int limit,
String clsName,
IgniteBiPredicate<Object,Object> keyValFilter,
@Nullable Integer part,
IgniteReducer<Object,Object> rdc,
IgniteClosure<?,?> trans,
int pageSize,
boolean incBackups,
Object[] args,
boolean incMeta,
boolean keepBinary,
UUID subjId,
int taskHash,
AffinityTopologyVersion topVer,
MvccSnapshot mvccSnapshot,
boolean addDepInfo,
Boolean dataPageScanEnabled) |
| Modifier and Type | Method and Description |
|---|---|
<T,R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.callAsync(IgniteClosure<T,R1> job,
Collection<? extends T> args,
IgniteReducer<R1,R2> rdc,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
<R1,R2> ComputeTaskInternalFuture<R2> |
GridClosureProcessor.forkjoinAsync(GridClosureCallMode mode,
Collection<? extends Callable<R1>> jobs,
IgniteReducer<R1,R2> rdc,
@Nullable Collection<ClusterNode> nodes,
@Nullable String execName) |
| Constructor and Description |
|---|
GridCompoundFuture(@Nullable IgniteReducer<T,R> rdc) |
GridCompoundIdentityFuture(@Nullable IgniteReducer<T,T> rdc) |
| Modifier and Type | Class and Description |
|---|---|
class |
IgniteReducerX<E1,R>
Convenient reducer subclass that allows for thrown grid exception.
|
| Modifier and Type | Method and Description |
|---|---|
static <T> IgniteReducer<T,T> |
GridFunc.identityReducer(T elem)
Gets reducer which always returns
true from collect(Object)
method and passed in element from reduce() method. |
static IgniteReducer<Integer,Integer> |
GridFunc.sumIntReducer()
Deprecated.
|
static IgniteReducer<Long,Long> |
GridFunc.sumLongReducer()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
static <T,R> R |
GridFunc.awaitAll(long timeout,
@Nullable IgniteReducer<T,R> rdc,
@Nullable Collection<IgniteInternalFuture<T>> futs)
Deprecated.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AlwaysTrueReducer<T>
Reducer which always returns
true from collect(Object) |
class |
IntSumReducer
Reducer that calculates sum of integer elements.
|
class |
LongSumReducer
Reducer that calculates sum of long integer elements.
|
class |
StringConcatReducer
Reducer that concatenates strings using provided delimiter.
|
| Modifier and Type | Interface and Description |
|---|---|
interface |
R1<E1,R>
Defines
alias for IgniteReducer by extending it. |
| Modifier and Type | Class and Description |
|---|---|
class |
RX1<E1,R>
Defines
alias for IgniteReducerX by extending it. |
Follow @ApacheIgnite
Ignite Database and Caching Platform : ver. 2.9.0 Release Date : October 15 2020