com.gemstone.gemfire.cache.execute
Interface Execution

public interface Execution

Provides methods to build the context for the execution of a Function . A Context describes the environment in which the Execution will take place.

Since:

6.0

See Also:

FunctionService, Function

Method Summary

ResultCollector<? extends Serializable,? extends Serializable>	execute(Function function) Executes the function instance provided.
ResultCollector<? extends Serializable,? extends Serializable>	execute(String functionId) Executes the function using its id Function.execute(FunctionContext) is called on the instance retrieved using FunctionService.getFunction(String) on the executing member.
ResultCollector<? extends Serializable,? extends Serializable>	execute(String functionId, boolean hasResult) Executes the function instance provided.
ResultCollector<? extends Serializable,? extends Serializable>	execute(String functionId, boolean hasResult, boolean isHA) Executes the function instance provided.
ResultCollector<? extends Serializable,? extends Serializable>	execute(String functionId, boolean hasResult, boolean isHA, boolean optimizeForWrite) Executes the function instance provided.
Execution	withArgs(Serializable args) Specifies the user data passed to the function when it is executed.
Execution	withCollector(ResultCollector<? extends Serializable,? extends Serializable> rc) Specifies the ResultCollector that will receive the results after the function has been executed.
Execution	withFilter(Set<?> filter) Specifies a data filter of routing objects for selecting the GemFire members to execute the function on.

Method Detail

withFilter

Execution withFilter(Set<?> filter)

Specifies a data filter of routing objects for selecting the GemFire members to execute the function on.

If the filter set is empty the function is executed on all members that have the region defined.

In case of the DataPolicy.PARTITION it will execute on a set of members which has all the data.

Parameters:

filter - Set defining the data filter to be used for executing the function

Returns:

an Execution with the filter

Throws:

IllegalArgumentException - if filter passed is null.

UnsupportedOperationException - if not called after FunctionService.onRegion(com.gemstone.gemfire.cache.Region)

Since:

6.0

withArgs

Execution withArgs(Serializable args)

Specifies the user data passed to the function when it is executed. The function can retrieve these arguments using FunctionContext.getArguments()

Parameters:

args - user data passed to the function execution

Returns:

an Execution with args

Throws:

IllegalArgumentException - if the input parameter is null

Since:

6.0

withCollector

Execution withCollector(ResultCollector<? extends Serializable,? extends Serializable> rc)

Specifies the ResultCollector that will receive the results after the function has been executed. Collector will receive results as they are sent from the Function.execute(FunctionContext) using ResultSender.

Returns:

an Execution with a collector

Throws:

IllegalArgumentException - if ResultCollector is null

Since:

6.0

See Also:

ResultCollector

execute

ResultCollector<? extends Serializable,? extends Serializable> execute(String functionId)
                                                                       throws FunctionException

Executes the function using its id

Function.execute(FunctionContext) is called on the instance retrieved using FunctionService.getFunction(String) on the executing member.

Parameters:

functionId - the Function.getId() of the function

Returns:

ResultCollector to retrieve the results received. This is different object than the ResultCollector provided in withCollector(ResultCollector). User has to use this reference to retrieve results.

Throws:

LowMemoryException - if the Function.optimizeForWrite() returns true and there is a low memory condition

FunctionException

Since:

6.0

execute

ResultCollector<? extends Serializable,? extends Serializable> execute(Function function)
                                                                       throws FunctionException

Executes the function instance provided.

Function.execute(FunctionContext) is called on the de-serialized instance on the executing member.

Parameters:

function - instance to execute

Returns:

ResultCollector to retrieve the results received. This is different object than the ResultCollector provided in withCollector(ResultCollector). User has to use this reference to retrieve results.

Throws:

LowMemoryException - if the Function.optimizeForWrite() returns true and there is a low memory condition

FunctionException

Since:

6.0

execute

ResultCollector<? extends Serializable,? extends Serializable> execute(String functionId,
                                                                       boolean hasResult)
                                                                       throws FunctionException

Executes the function instance provided.

Function.execute(FunctionContext) is called on the de-serialized instance on the executing member.

Parameters:

functionId - the Function.getId() of the function

hasResult - Whether the function returns any result

Returns:

ResultCollector to retrieve the results received. This is different object than the ResultCollector provided in withCollector(ResultCollector). User has to use this reference to retrieve results.

Throws:

LowMemoryException - if the Function.optimizeForWrite() returns true and there is a low memory condition

FunctionException

Since:

6.5

execute

ResultCollector<? extends Serializable,? extends Serializable> execute(String functionId,
                                                                       boolean hasResult,
                                                                       boolean isHA)
                                                                       throws FunctionException

Executes the function instance provided.

Function.execute(FunctionContext) is called on the de-serialized instance on the executing member.

Parameters:

functionId - the Function.getId() of the function

hasResult - Whether the function returns any result

isHA - Whether the given function is HA

Returns:

ResultCollector to retrieve the results received. This is different object than the ResultCollector provided in withCollector(ResultCollector). User has to use this reference to retrieve results.

Throws:

LowMemoryException - if the Function.optimizeForWrite() returns true and there is a low memory condition

FunctionException

Since:

6.5

execute

ResultCollector<? extends Serializable,? extends Serializable> execute(String functionId,
                                                                       boolean hasResult,
                                                                       boolean isHA,
                                                                       boolean optimizeForWrite)
                                                                       throws FunctionException

Executes the function instance provided.

Function.execute(FunctionContext) is called on the de-serialized instance on the executing member.

Parameters:

functionId - the Function.getId() of the function

hasResult - Whether the function returns any result

isHA - Whether the given function is HA

optimizeForWrite - Whether the function should be optmized for write operations

Returns:

ResultCollector to retrieve the results received. This is different object than the ResultCollector provided in withCollector(ResultCollector). User has to use this reference to retrieve results.

Throws:

LowMemoryException - if the Function.optimizeForWrite() returns true and there is a low memory condition

FunctionException

Since:

6.5