org.apache.ignite.compute.gridify.aop

Class GridifySetToValueAbstractAspect

java.lang.Object

org.apache.ignite.compute.gridify.aop.GridifySetToValueAbstractAspect

Direct Known Subclasses:

GridifySetToValueAspectJAspect, GridifySetToValueSpringAspect

public class GridifySetToValueAbstractAspect
extends Object

Convenience adapter with common methods for different aspect implementations (AspectJ, JBoss AOP, Spring AOP). This adapter used in grid task for GridifySetToValue annotation.

Constructor Summary

Constructors

Constructor and Description
GridifySetToValueAbstractAspect()

Method Summary

Modifier and Type	Method and Description
protected void	checkIsSplitToJobsAllowed(org.apache.ignite.internal.util.gridify.GridifyRangeArgument arg, GridifySetToValue ann) Check if split allowed for input argument.
protected void	checkMethodSignature(Method mtd) Check method signature.
protected Object	execute(Method mtd, IgniteCompute compute, Class<?> cls, org.apache.ignite.internal.util.gridify.GridifyRangeArgument arg, GridifyNodeFilter nodeFilter, int threshold, int splitSize, long timeout) Execute method on grid.

Methods inherited from class java.lang.Object

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

Constructor Detail

GridifySetToValueAbstractAspect

public GridifySetToValueAbstractAspect()

Method Detail

checkMethodSignature

protected void checkMethodSignature(Method mtd)
                             throws IgniteCheckedException

Check method signature.

Parameters:

mtd - Grid-enabled method.

Throws:

IgniteCheckedException - If method signature invalid.

checkIsSplitToJobsAllowed

protected void checkIsSplitToJobsAllowed(org.apache.ignite.internal.util.gridify.GridifyRangeArgument arg,
                                         GridifySetToValue ann)
                                  throws IgniteCheckedException

Check if split allowed for input argument. Note, that for argument with unknown elements size with default GridifySetToValue.splitSize() value (default value 0) there is no ability to calculate how much jobs should be used in task execution.

Parameters:

arg - Gridify argument.

ann - Annotation

Throws:

IgniteCheckedException - If split is not allowed with current parameters.

execute

protected Object execute(Method mtd,
                         IgniteCompute compute,
                         Class<?> cls,
                         org.apache.ignite.internal.util.gridify.GridifyRangeArgument arg,
                         GridifyNodeFilter nodeFilter,
                         int threshold,
                         int splitSize,
                         long timeout)
                  throws IgniteCheckedException

Execute method on grid.

Parameters:

mtd - Method.

compute - IgniteCompute instance.

cls - Joint point signature class.

arg - GridifyArgument with all method signature parameters.

nodeFilter - Node filter.

threshold - Parameter that defines the minimal value below which the execution will NOT be grid-enabled.

splitSize - Size of elements to send in job argument.

timeout - Execution timeout.

Returns:

Result.

Throws:

IgniteCheckedException - If execution failed.