Class GemfireOnMembersFunctionTemplate
java.lang.Object
org.springframework.data.gemfire.function.execution.GemfireOnMembersFunctionTemplate
- All Implemented Interfaces:
InitializingBean
,GemfireFunctionOperations
- Author:
- David Turanski, John Blum
- See Also:
-
DistributedMember
AbstractFunctionTemplate
-
Constructor Summary
ConstructorDescriptionGemfireOnMembersFunctionTemplate
(String[] groups) GemfireOnMembersFunctionTemplate
(Set<DistributedMember> distributedMembers) -
Method Summary
Modifier and TypeMethodDescriptionvoid
<T> Iterable<T>
Execute a GemFire Function registered with the given ID.<T> Iterable<T>
Execute an unregistered GemFire Function with the given arguments.protected <T> Iterable<T>
execute
(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution functionExecution) protected <T> Iterable<T>
execute
(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution functionExecution, boolean returnResult) <T> T
execute
(GemfireFunctionCallback<T> callback) Execute a GemFire Function using a native GemFireExecution
instance.<T> T
executeAndExtract
(String functionId, Object... args) Execute a GemFire Function registered with an ID and with an expected singleton result<T> T
executeAndExtract
(Function function, Object... args) Execute an unregistered GemFire Function with the expected singleton result.protected <T> T
executeAndExtract
(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution functionExecution) void
executeWithNoResult
(String functionId, Object... args) Execute a GemFire Function registered with the given ID having no return value.protected org.springframework.data.gemfire.function.execution.AbstractFunctionExecution
ResultCollector<?,
?> long
void
setResultCollector
(ResultCollector<?, ?> resultCollector) void
setTimeout
(long timeout)
-
Constructor Details
-
GemfireOnMembersFunctionTemplate
public GemfireOnMembersFunctionTemplate() -
GemfireOnMembersFunctionTemplate
-
GemfireOnMembersFunctionTemplate
-
-
Method Details
-
getFunctionExecution
protected org.springframework.data.gemfire.function.execution.AbstractFunctionExecution getFunctionExecution() -
afterPropertiesSet
- Specified by:
afterPropertiesSet
in interfaceInitializingBean
- Throws:
Exception
-
execute
Description copied from interface:GemfireFunctionOperations
Execute an unregistered GemFire Function with the given arguments.- Specified by:
execute
in interfaceGemfireFunctionOperations
- Type Parameters:
T
- type parameter specifying the result type of the Function execution.- Parameters:
function
- the GemFire Function object to execute.args
- an array of Object arguments to the Function call.- Returns:
- the contents of the ResultsCollector.
-
executeAndExtract
Description copied from interface:GemfireFunctionOperations
Execute an unregistered GemFire Function with the expected singleton result.- Specified by:
executeAndExtract
in interfaceGemfireFunctionOperations
- Type Parameters:
T
- type parameter specifying the result type of the Function execution.- Parameters:
function
- the GemFire Function object.args
- an array of Object arguments to the Function call.- Returns:
- the first item in the ResultsCollector.
- See Also:
-
execute
Description copied from interface:GemfireFunctionOperations
Execute a GemFire Function registered with the given ID.- Specified by:
execute
in interfaceGemfireFunctionOperations
- Type Parameters:
T
- type parameter specifying the result type of the Function execution.- Parameters:
functionId
- the ID under which the GemFire function is registered.args
- an array of Object arguments to the Function call.- Returns:
- the results
-
executeAndExtract
Description copied from interface:GemfireFunctionOperations
Execute a GemFire Function registered with an ID and with an expected singleton result- Specified by:
executeAndExtract
in interfaceGemfireFunctionOperations
- Type Parameters:
T
- type parameter specifying the result type of the Function execution.- Parameters:
functionId
- the ID under which the GemFire function is registered.args
- an array of Object arguments to the Function call.- Returns:
- the first item in the results collector
-
executeWithNoResult
Description copied from interface:GemfireFunctionOperations
Execute a GemFire Function registered with the given ID having no return value.- Specified by:
executeWithNoResult
in interfaceGemfireFunctionOperations
- Parameters:
functionId
- the ID under which the GemFire function is registered.args
- an array of Object arguments to the Function call.
-
execute
Description copied from interface:GemfireFunctionOperations
Execute a GemFire Function using a native GemFireExecution
instance.- Specified by:
execute
in interfaceGemfireFunctionOperations
- Type Parameters:
T
- type parameter specifying the result type of the Function execution.- Parameters:
callback
- a callback providing the execution instance.- Returns:
- the Function execution result.
- See Also:
-
execute
protected <T> Iterable<T> execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution functionExecution) -
execute
protected <T> Iterable<T> execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution functionExecution, boolean returnResult) -
executeAndExtract
protected <T> T executeAndExtract(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution functionExecution) -
setResultCollector
-
getResultCollector
-
setTimeout
public void setTimeout(long timeout) -
getTimeout
public long getTimeout()
-