quickstart

Class MyArrayListResultCollector

java.lang.Object

quickstart.MyArrayListResultCollector

All Implemented Interfaces:

com.gemstone.gemfire.cache.execute.ResultCollector<Object,Object>

public class MyArrayListResultCollector
extends Object
implements com.gemstone.gemfire.cache.execute.ResultCollector<Object,Object>

MyArrayListResultCollector gathers result from all the function execution nodes.

Using a custom ResultCollector a user can sort/aggregate the result. This implementation stores the result in a List. The size of the list will be same as the no of nodes on which a function got executed

Since:

6.0

Constructor Summary

Constructors

Constructor and Description
MyArrayListResultCollector()

Method Summary

Methods

Modifier and Type	Method and Description
void	addResult(com.gemstone.gemfire.distributed.DistributedMember memberID, Object resultOfSingleExecution) Adds a single function execution result from a remote node to the ResultCollector
void	clearResults() GemFire will invoke this method before re-executing function (in case of Function Execution HA) This is to clear the previous execution results from the result collector
void	endResults() Call back provided to caller, which is called after function execution is complete and caller can retrieve results using ResultCollector.getResult()
Object	getResult() Waits if necessary for the computation to complete, and then retrieves its result.
Object	getResult(long timeout, TimeUnit unit) Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.

Methods inherited from class java.lang.Object

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

Constructor Detail

MyArrayListResultCollector

public MyArrayListResultCollector()

Method Detail

addResult

public void addResult(com.gemstone.gemfire.distributed.DistributedMember memberID,
             Object resultOfSingleExecution)

Adds a single function execution result from a remote node to the ResultCollector

Specified by:

addResult in interface com.gemstone.gemfire.cache.execute.ResultCollector<Object,Object>

getResult

public Object getResult()
                 throws com.gemstone.gemfire.cache.execute.FunctionException

Waits if necessary for the computation to complete, and then retrieves its result.

If Function.hasResult() is false, upon calling ResultCollector.getResult() throws FunctionException.

Specified by:

getResult in interface com.gemstone.gemfire.cache.execute.ResultCollector<Object,Object>

Returns:

the computed result

Throws:

com.gemstone.gemfire.cache.execute.FunctionException - if something goes wrong while retrieving the result

getResult

public Object getResult(long timeout,
               TimeUnit unit)
                 throws com.gemstone.gemfire.cache.execute.FunctionException,
                        InterruptedException

Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.

If Function.hasResult() is false, upon calling ResultCollector.getResult() throws FunctionException.

Specified by:

getResult in interface com.gemstone.gemfire.cache.execute.ResultCollector<Object,Object>

Parameters:

timeout - the maximum time to wait

unit - the time unit of the timeout argument

Returns:

computed result

Throws:

com.gemstone.gemfire.cache.execute.FunctionException - if something goes wrong while retrieving the result

InterruptedException

clearResults

public void clearResults()

GemFire will invoke this method before re-executing function (in case of Function Execution HA) This is to clear the previous execution results from the result collector

Specified by:

clearResults in interface com.gemstone.gemfire.cache.execute.ResultCollector<Object,Object>

Since:

6.3

endResults

public void endResults()

Call back provided to caller, which is called after function execution is complete and caller can retrieve results using ResultCollector.getResult()

Specified by:

endResults in interface com.gemstone.gemfire.cache.execute.ResultCollector<Object,Object>