public class GemfireOnServerFunctionTemplate extends Object
Modifier and Type | Field and Description |
---|---|
protected org.apache.commons.logging.Log |
log |
protected ResultCollector<?,?> |
resultCollector |
protected long |
timeout |
Constructor and Description |
---|
GemfireOnServerFunctionTemplate(Pool pool) |
GemfireOnServerFunctionTemplate(RegionService cache) |
Modifier and Type | Method and Description |
---|---|
protected <T> Iterable<T> |
execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution) |
protected <T> Iterable<T> |
execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution,
boolean returnResult) |
<T> Iterable<T> |
execute(Function function,
Object... args)
Execute an unregistered GemFire Function with the given arguments.
|
<T> T |
execute(GemfireFunctionCallback<T> callback)
Execute a GemFire Function using a native GemFire
Execution instance. |
<T> Iterable<T> |
execute(String functionId,
Object... args)
Execute a GemFire Function registered with the given ID.
|
protected <T> T |
executeAndExtract(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution) |
<T> T |
executeAndExtract(Function function,
Object... args)
Execute an unregistered GemFire Function with the expected singleton result.
|
<T> T |
executeAndExtract(String functionId,
Object... args)
Execute a GemFire Function registered with an ID and with an expected singleton result
|
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 |
getFunctionExecution() |
ResultCollector<?,?> |
getResultCollector() |
void |
setResultCollector(ResultCollector<?,?> resultCollector) |
void |
setTimeout(long timeout) |
protected org.apache.commons.logging.Log log
protected long timeout
protected volatile ResultCollector<?,?> resultCollector
public GemfireOnServerFunctionTemplate(RegionService cache)
public GemfireOnServerFunctionTemplate(Pool pool)
protected org.springframework.data.gemfire.function.execution.AbstractFunctionExecution getFunctionExecution()
public <T> Iterable<T> execute(Function function, Object... args)
GemfireFunctionOperations
execute
in interface GemfireFunctionOperations
T
- type parameter specifying the result type of the Function execution.function
- the GemFire Function object to execute.args
- an array of Object arguments to the Function call.public <T> T executeAndExtract(Function function, Object... args)
GemfireFunctionOperations
executeAndExtract
in interface GemfireFunctionOperations
T
- type parameter specifying the result type of the Function execution.function
- the GemFire Function object.args
- an array of Object arguments to the Function call.Function
public <T> Iterable<T> execute(String functionId, Object... args)
GemfireFunctionOperations
execute
in interface GemfireFunctionOperations
T
- type parameter specifying the result type of the Function execution.functionId
- the ID under which the GemFire function is registered.args
- an array of Object arguments to the Function call.public void executeWithNoResult(String functionId, Object... args)
GemfireFunctionOperations
executeWithNoResult
in interface GemfireFunctionOperations
functionId
- the ID under which the GemFire function is registered.args
- an array of Object arguments to the Function call.public <T> T executeAndExtract(String functionId, Object... args)
GemfireFunctionOperations
executeAndExtract
in interface GemfireFunctionOperations
T
- type parameter specifying the result type of the Function execution.functionId
- the ID under which the GemFire function is registered.args
- an array of Object arguments to the Function call.public <T> T execute(GemfireFunctionCallback<T> callback)
GemfireFunctionOperations
Execution
instance.execute
in interface GemfireFunctionOperations
T
- type parameter specifying the result type of the Function execution.callback
- a callback providing the execution instance.GemfireFunctionCallback
protected <T> Iterable<T> execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution)
protected <T> Iterable<T> execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution, boolean returnResult)
protected <T> T executeAndExtract(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution)
public void setTimeout(long timeout)
public void setResultCollector(ResultCollector<?,?> resultCollector)
public ResultCollector<?,?> getResultCollector()