org.apache.ignite.internal.processors.closure

Class GridClosureProcessor

java.lang.Object

org.apache.ignite.internal.processors.GridProcessorAdapter

org.apache.ignite.internal.processors.closure.GridClosureProcessor

All Implemented Interfaces:

GridComponent, GridProcessor

public class GridClosureProcessor
extends GridProcessorAdapter

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	GridClosureProcessor.C1MLAV2<T,R>
static class	GridClosureProcessor.C1V2<T,R>
static class	GridClosureProcessor.C2MLAV2<R>
static class	GridClosureProcessor.C2V2<R>
static class	GridClosureProcessor.C4MLAV2
static class	GridClosureProcessor.C4V2

Nested classes/interfaces inherited from interface org.apache.ignite.internal.GridComponent

GridComponent.DiscoveryDataExchangeType

Field Summary

Fields

Modifier and Type	Field and Description
static IgniteProductVersion	BINARYLIZABLE_CLOSURES_SINCE Ignite version in which binarylizable versions of closures were introduced.

Fields inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

ctx, log

Constructor Summary

Constructors

Constructor and Description
GridClosureProcessor(GridKernalContext ctx)

Method Summary

Methods

Modifier and Type	Method and Description
<R> ComputeTaskInternalFuture<R>	affinityCall(Collection<String> cacheNames, int partId, Object affKey, Callable<R> job, Collection<ClusterNode> nodes)
ComputeTaskInternalFuture<?>	affinityRun(Collection<String> cacheNames, int partId, Object affKey, Runnable job, Collection<ClusterNode> nodes)
<T,R> IgniteInternalFuture<Collection<R>>	broadcast(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)
<T,R> IgniteInternalFuture<Collection<R>>	broadcastNoFailover(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)
<R> ComputeTaskInternalFuture<R>	callAsync(GridClosureCallMode mode, Callable<R> job, Collection<ClusterNode> nodes)
<R> ComputeTaskInternalFuture<R>	callAsync(GridClosureCallMode mode, Callable<R> job, Collection<ClusterNode> nodes, boolean sys)
<R> ComputeTaskInternalFuture<Collection<R>>	callAsync(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<ClusterNode> nodes)
<R> ComputeTaskInternalFuture<Collection<R>>	callAsync(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<ClusterNode> nodes, boolean sys)
<T,R> ComputeTaskInternalFuture<Collection<R>>	callAsync(IgniteClosure<T,R> job, Collection<? extends T> args, Collection<ClusterNode> nodes)
<T,R> ComputeTaskInternalFuture<R>	callAsync(IgniteClosure<T,R> job, T arg, Collection<ClusterNode> nodes)
<T,R1,R2> ComputeTaskInternalFuture<R2>	callAsync(IgniteClosure<T,R1> job, Collection<? extends T> args, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)
<R> IgniteInternalFuture<R>	callAsyncNoFailover(GridClosureCallMode mode, Callable<R> job, Collection<ClusterNode> nodes, boolean sys, long timeout)
<R> IgniteInternalFuture<Collection<R>>	callAsyncNoFailover(GridClosureCallMode mode, Collection<? extends Callable<R>> jobs, Collection<ClusterNode> nodes, boolean sys, long timeout)
<R> IgniteInternalFuture<R>	callLocal(Callable<R> c, byte plc)
<R> IgniteInternalFuture<R>	callLocalSafe(Callable<R> c) Executes closure on system pool.
<R> IgniteInternalFuture<R>	callLocalSafe(Callable<R> c, boolean sys) Executes closure on system pool.
<R1,R2> ComputeTaskInternalFuture<R2>	forkjoinAsync(GridClosureCallMode mode, Collection<? extends Callable<R1>> jobs, IgniteReducer<R1,R2> rdc, Collection<ClusterNode> nodes)
void	onKernalStop(boolean cancel) Callback to notify that kernal is about to stop.
ComputeTaskInternalFuture<?>	runAsync(GridClosureCallMode mode, Collection<? extends Runnable> jobs, Collection<ClusterNode> nodes)
ComputeTaskInternalFuture<?>	runAsync(GridClosureCallMode mode, Collection<? extends Runnable> jobs, Collection<ClusterNode> nodes, boolean sys)
ComputeTaskInternalFuture<?>	runAsync(GridClosureCallMode mode, Runnable job, Collection<ClusterNode> nodes)
ComputeTaskInternalFuture<?>	runAsync(GridClosureCallMode mode, Runnable job, Collection<ClusterNode> nodes, boolean sys)
IgniteInternalFuture<?>	runLocal(Runnable c, byte plc)
IgniteInternalFuture<?>	runLocalSafe(Runnable c) Executes closure on system pool.
IgniteInternalFuture<?>	runLocalSafe(Runnable c, boolean sys) Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).
IgniteInternalFuture<?>	runLocalSafe(Runnable c, byte plc) Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).
void	start() Starts grid component.

Methods inherited from class org.apache.ignite.internal.processors.GridProcessorAdapter

assertParameter, collectDiscoveryData, discoveryDataType, onDisconnected, onDiscoveryDataReceived, onKernalStart, onReconnected, printMemoryStats, stop, toString, validateNode

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

BINARYLIZABLE_CLOSURES_SINCE

public static final IgniteProductVersion BINARYLIZABLE_CLOSURES_SINCE

Ignite version in which binarylizable versions of closures were introduced.

Constructor Detail

GridClosureProcessor

public GridClosureProcessor(GridKernalContext ctx)

Parameters:

ctx - Kernal context.

Method Detail

start

public void start()
           throws IgniteCheckedException

Starts grid component.

Specified by:

start in interface GridComponent

Overrides:

start in class GridProcessorAdapter

Throws:

IgniteCheckedException - Throws in case of any errors.

onKernalStop

public void onKernalStop(boolean cancel)

Callback to notify that kernal is about to stop.

Specified by:

onKernalStop in interface GridComponent

Overrides:

onKernalStop in class GridProcessorAdapter

Parameters:

cancel - Flag indicating whether jobs should be canceled.

runAsync

public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode,
                                    @Nullable
                                    Collection<? extends Runnable> jobs,
                                    @Nullable
                                    Collection<ClusterNode> nodes)

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

Returns:

Task execution future.

runAsync

public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode,
                                    Collection<? extends Runnable> jobs,
                                    @Nullable
                                    Collection<ClusterNode> nodes,
                                    boolean sys)

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Task execution future.

runAsync

public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode,
                                    Runnable job,
                                    @Nullable
                                    Collection<ClusterNode> nodes)

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

Returns:

Task execution future.

runAsync

public ComputeTaskInternalFuture<?> runAsync(GridClosureCallMode mode,
                                    Runnable job,
                                    @Nullable
                                    Collection<ClusterNode> nodes,
                                    boolean sys)

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Task execution future.

forkjoinAsync

public <R1,R2> ComputeTaskInternalFuture<R2> forkjoinAsync(GridClosureCallMode mode,
                                                  Collection<? extends Callable<R1>> jobs,
                                                  IgniteReducer<R1,R2> rdc,
                                                  @Nullable
                                                  Collection<ClusterNode> nodes)

Type Parameters:

R1 - Type.

R2 - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

rdc - Reducer.

nodes - Grid nodes.

Returns:

Reduced result.

callAsync

public <R> ComputeTaskInternalFuture<Collection<R>> callAsync(GridClosureCallMode mode,
                                                     @Nullable
                                                     Collection<? extends Callable<R>> jobs,
                                                     @Nullable
                                                     Collection<ClusterNode> nodes)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

Returns:

Grid future for collection of closure results.

callAsync

public <R> ComputeTaskInternalFuture<Collection<R>> callAsync(GridClosureCallMode mode,
                                                     Collection<? extends Callable<R>> jobs,
                                                     @Nullable
                                                     Collection<ClusterNode> nodes,
                                                     boolean sys)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Grid future for collection of closure results.

callAsync

public <R> ComputeTaskInternalFuture<R> callAsync(GridClosureCallMode mode,
                                         @Nullable
                                         Callable<R> job,
                                         @Nullable
                                         Collection<ClusterNode> nodes)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

Returns:

Grid future for collection of closure results.

affinityCall

public <R> ComputeTaskInternalFuture<R> affinityCall(@NotNull
                                            Collection<String> cacheNames,
                                            int partId,
                                            @Nullable
                                            Object affKey,
                                            Callable<R> job,
                                            @Nullable
                                            Collection<ClusterNode> nodes)
                                          throws IgniteCheckedException

Parameters:

cacheNames - Cache names.

partId - Partition.

affKey - Affinity key.

job - Closure to execute.

nodes - Grid nodes.

Returns:

Grid future for collection of closure results.

Throws:

IgniteCheckedException - If failed.

affinityRun

public ComputeTaskInternalFuture<?> affinityRun(@NotNull
                                       Collection<String> cacheNames,
                                       int partId,
                                       @Nullable
                                       Object affKey,
                                       Runnable job,
                                       @Nullable
                                       Collection<ClusterNode> nodes)
                                         throws IgniteCheckedException

Parameters:

cacheNames - Cache names.

partId - Partition.

affKey - Affinity key.

job - Job.

nodes - Grid nodes.

Returns:

Job future.

Throws:

IgniteCheckedException - If failed.

callAsyncNoFailover

public <R> IgniteInternalFuture<R> callAsyncNoFailover(GridClosureCallMode mode,
                                              @Nullable
                                              Callable<R> job,
                                              @Nullable
                                              Collection<ClusterNode> nodes,
                                              boolean sys,
                                              long timeout)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Grid future for collection of closure results.

callAsyncNoFailover

public <R> IgniteInternalFuture<Collection<R>> callAsyncNoFailover(GridClosureCallMode mode,
                                                          @Nullable
                                                          Collection<? extends Callable<R>> jobs,
                                                          @Nullable
                                                          Collection<ClusterNode> nodes,
                                                          boolean sys,
                                                          long timeout)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

jobs - Closures to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

timeout - If greater than 0 limits task execution. Cannot be negative.

Returns:

Grid future for collection of closure results.

callAsync

public <R> ComputeTaskInternalFuture<R> callAsync(GridClosureCallMode mode,
                                         Callable<R> job,
                                         @Nullable
                                         Collection<ClusterNode> nodes,
                                         boolean sys)

Type Parameters:

R - Type.

Parameters:

mode - Distribution mode.

job - Closure to execute.

nodes - Grid nodes.

sys - If true, then system pool will be used.

Returns:

Grid future for collection of closure results.

callAsync

public <T,R> ComputeTaskInternalFuture<R> callAsync(IgniteClosure<T,R> job,
                                           @Nullable
                                           T arg,
                                           @Nullable
                                           Collection<ClusterNode> nodes)

Parameters:

job - Job closure.

arg - Optional job argument.

nodes - Grid nodes.

Returns:

Grid future for execution result.

broadcast

public <T,R> IgniteInternalFuture<Collection<R>> broadcast(IgniteClosure<T,R> job,
                                                  @Nullable
                                                  T arg,
                                                  @Nullable
                                                  Collection<ClusterNode> nodes)

Parameters:

job - Job closure.

arg - Optional job argument.

nodes - Grid nodes.

Returns:

Grid future for execution result.

broadcastNoFailover

public <T,R> IgniteInternalFuture<Collection<R>> broadcastNoFailover(IgniteClosure<T,R> job,
                                                            @Nullable
                                                            T arg,
                                                            @Nullable
                                                            Collection<ClusterNode> nodes)

Parameters:

job - Job closure.

arg - Optional job argument.

nodes - Grid nodes.

Returns:

Grid future for execution result.

callAsync

public <T,R> ComputeTaskInternalFuture<Collection<R>> callAsync(IgniteClosure<T,R> job,
                                                       @Nullable
                                                       Collection<? extends T> args,
                                                       @Nullable
                                                       Collection<ClusterNode> nodes)

Parameters:

job - Job closure.

args - Job arguments.

nodes - Grid nodes.

Returns:

Grid future for execution result.

callAsync

public <T,R1,R2> ComputeTaskInternalFuture<R2> callAsync(IgniteClosure<T,R1> job,
                                                Collection<? extends T> args,
                                                IgniteReducer<R1,R2> rdc,
                                                @Nullable
                                                Collection<ClusterNode> nodes)

Parameters:

job - Job closure.

args - Job arguments.

rdc - Reducer.

nodes - Grid nodes.

Returns:

Grid future for execution result.

runLocal

public IgniteInternalFuture<?> runLocal(@Nullable
                               Runnable c,
                               byte plc)
                                 throws IgniteCheckedException

Parameters:

c - Closure to execute.

plc - Whether to run on system or public pool.

Returns:

Future.

Throws:

IgniteCheckedException - Thrown in case of any errors.

runLocalSafe

public IgniteInternalFuture<?> runLocalSafe(Runnable c)

Executes closure on system pool. Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

Returns:

Future.

runLocalSafe

public IgniteInternalFuture<?> runLocalSafe(Runnable c,
                                   boolean sys)

Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

sys - If true, then system pool will be used, otherwise public pool will be used.

Returns:

Future.

runLocalSafe

public IgniteInternalFuture<?> runLocalSafe(Runnable c,
                                   byte plc)

Companion to runLocal(Runnable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

plc - Policy to choose executor pool.

Returns:

Future.

callLocal

public <R> IgniteInternalFuture<R> callLocal(@Nullable
                                    Callable<R> c,
                                    byte plc)
                                  throws IgniteCheckedException

Type Parameters:

R - Type of closure return value.

Parameters:

c - Closure to execute.

plc - Whether to run on system or public pool.

Returns:

Future.

Throws:

IgniteCheckedException - Thrown in case of any errors.

callLocalSafe

public <R> IgniteInternalFuture<R> callLocalSafe(Callable<R> c)

Executes closure on system pool. Companion to callLocal(Callable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

Returns:

Future.

callLocalSafe

public <R> IgniteInternalFuture<R> callLocalSafe(Callable<R> c,
                                        boolean sys)

Executes closure on system pool. Companion to callLocal(Callable, boolean) but in case of rejected execution re-runs the closure in the current thread (blocking).

Parameters:

c - Closure to execute.

sys - If true, then system pool will be used, otherwise public pool will be used.

Returns:

Future.