org.springframework.data.gemfire.function.execution

Class GemfireOnRegionFunctionTemplate

java.lang.Object

org.springframework.data.gemfire.function.execution.GemfireOnRegionFunctionTemplate

All Implemented Interfaces:

InitializingBean, GemfireFunctionOperations, GemfireOnRegionOperations

public class GemfireOnRegionFunctionTemplate
extends Object
implements GemfireOnRegionOperations

Author:

David Turanski, John Blum

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.geode.cache.execute.ResultCollector<?,?>	resultCollector
protected long	timeout

Constructor Summary

Constructors

Constructor and Description
GemfireOnRegionFunctionTemplate(org.apache.geode.cache.Region<?,?> region) Constructs a new instance of the GemfireOnRegionFunctionTemplate initialized with the given Region.

Method Summary

Modifier and Type	Method and Description
void	afterPropertiesSet()
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(org.apache.geode.cache.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.
<T> Iterable<T>	execute(String functionId, Set<?> keys, Object... args)
protected <T> T	executeAndExtract(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution)
<T> T	executeAndExtract(org.apache.geode.cache.execute.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
<T> T	executeAndExtract(String functionId, Set<?> keys, Object... args)
void	executeWithNoResult(String functionId, Object... args) Execute a GemFire Function registered with the given ID having no return value.
void	executeWithNoResult(String functionId, Set<?> keys, Object... args)
protected org.springframework.data.gemfire.function.execution.RegionFunctionExecution	getFunctionExecution()
org.apache.geode.cache.execute.ResultCollector<?,?>	getResultCollector()
void	setResultCollector(org.apache.geode.cache.execute.ResultCollector<?,?> resultCollector)
void	setTimeout(long timeout)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.data.gemfire.function.execution.GemfireOnRegionOperations

execute, executeAndExtract, executeWithNoResult

Methods inherited from interface org.springframework.data.gemfire.function.execution.GemfireFunctionOperations

execute, execute, execute, executeAndExtract, executeAndExtract, executeWithNoResult

Field Detail

timeout

protected long timeout

resultCollector

protected volatile org.apache.geode.cache.execute.ResultCollector<?,?> resultCollector

Constructor Detail

GemfireOnRegionFunctionTemplate

public GemfireOnRegionFunctionTemplate(org.apache.geode.cache.Region<?,?> region)

Constructs a new instance of the GemfireOnRegionFunctionTemplate initialized with the given Region.

Parameters:

region - the Region upon which the Function will be executed.

Throws:

IllegalArgumentException - if Region is null.

See Also:

Region

Method Detail

getFunctionExecution

protected org.springframework.data.gemfire.function.execution.RegionFunctionExecution getFunctionExecution()

execute

public <T> Iterable<T> execute(String functionId,
                               Set<?> keys,
                               Object... args)

Specified by:

execute in interface GemfireOnRegionOperations

executeAndExtract

public <T> T executeAndExtract(String functionId,
                               Set<?> keys,
                               Object... args)

Specified by:

executeAndExtract in interface GemfireOnRegionOperations

executeWithNoResult

public void executeWithNoResult(String functionId,
                                Set<?> keys,
                                Object... args)

Specified by:

executeWithNoResult in interface GemfireOnRegionOperations

afterPropertiesSet

public void afterPropertiesSet()
                        throws Exception

Specified by:

afterPropertiesSet in interface InitializingBean

Throws:

Exception

execute

public <T> Iterable<T> execute(org.apache.geode.cache.execute.Function function,
                               Object... args)

Description copied from interface: GemfireFunctionOperations

Execute an unregistered GemFire Function with the given arguments.

Specified by:

execute in interface GemfireFunctionOperations

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

public <T> T executeAndExtract(org.apache.geode.cache.execute.Function function,
                               Object... args)

Description copied from interface: GemfireFunctionOperations

Execute an unregistered GemFire Function with the expected singleton result.

Specified by:

executeAndExtract in interface GemfireFunctionOperations

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:

Function

execute

public <T> Iterable<T> execute(String functionId,
                               Object... args)

Description copied from interface: GemfireFunctionOperations

Execute a GemFire Function registered with the given ID.

Specified by:

execute in interface GemfireFunctionOperations

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

public <T> T executeAndExtract(String functionId,
                               Object... args)

Description copied from interface: GemfireFunctionOperations

Execute a GemFire Function registered with an ID and with an expected singleton result

Specified by:

executeAndExtract in interface GemfireFunctionOperations

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

public void executeWithNoResult(String functionId,
                                Object... args)

Description copied from interface: GemfireFunctionOperations

Execute a GemFire Function registered with the given ID having no return value.

Specified by:

executeWithNoResult in interface GemfireFunctionOperations

Parameters:

functionId - the ID under which the GemFire function is registered.

args - an array of Object arguments to the Function call.

execute

public <T> T execute(GemfireFunctionCallback<T> callback)

Description copied from interface: GemfireFunctionOperations

Execute a GemFire Function using a native GemFire Execution instance.

Specified by:

execute in interface GemfireFunctionOperations

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:

GemfireFunctionCallback

execute

protected <T> Iterable<T> execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution)

execute

protected <T> Iterable<T> execute(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution,
                                  boolean returnResult)

executeAndExtract

protected <T> T executeAndExtract(org.springframework.data.gemfire.function.execution.AbstractFunctionExecution execution)

setResultCollector

public void setResultCollector(org.apache.geode.cache.execute.ResultCollector<?,?> resultCollector)

getResultCollector

public org.apache.geode.cache.execute.ResultCollector<?,?> getResultCollector()

setTimeout

public void setTimeout(long timeout)