Package org.springframework.geode.function.support

Class AbstractResultCollector<T,S>

java.lang.Object

org.springframework.geode.function.support.AbstractResultCollector<T,S>

All Implemented Interfaces:

org.apache.geode.cache.execute.ResultCollector<T,S>

Direct Known Subclasses:

SingleResultReturningCollector

public abstract class AbstractResultCollector<T,S>
extends Object
implements org.apache.geode.cache.execute.ResultCollector<T,S>

The AbstractResultCollector class is an abstract base implementation of the ResultCollector interface encapsulating common functionality for collecting results from a Function execution.

Since:

1.0.0

See Also:

• ResultCollector

Field Summary

Fields

Modifier and Type	Field	Description
protected static final TimeUnit	DEFAULT_TIME_UNIT
protected static final String	NOT_IMPLEMENTED

Constructor Summary

Constructors

Constructor	Description
AbstractResultCollector()

Method Summary

Modifier and Type	Method	Description
void	clearResults()
void	endResults()
S	getResult()
S	getResult(long duration, TimeUnit unit)
protected boolean	hasResultsEnded()
protected boolean	hasResultsNotEnded()
protected TimeUnit	resolveTimeUnit(TimeUnit unit)
protected void	setResult(S result)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.geode.cache.execute.ResultCollector

addResult

Field Details

NOT_IMPLEMENTED

protected static final String NOT_IMPLEMENTED

See Also:

• Constant Field Values

DEFAULT_TIME_UNIT

protected static final TimeUnit DEFAULT_TIME_UNIT

Constructor Details

AbstractResultCollector

public AbstractResultCollector()

Method Details

getResult

public S getResult()
            throws org.apache.geode.cache.execute.FunctionException

Specified by:

getResult in interface org.apache.geode.cache.execute.ResultCollector<T,S>

Throws:

org.apache.geode.cache.execute.FunctionException

getResult

public S getResult(long duration,
 TimeUnit unit)
            throws org.apache.geode.cache.execute.FunctionException,
InterruptedException

Specified by:

getResult in interface org.apache.geode.cache.execute.ResultCollector<T,S>

Throws:

org.apache.geode.cache.execute.FunctionException

InterruptedException

setResult

protected void setResult(S result)

resolveTimeUnit

protected TimeUnit resolveTimeUnit(TimeUnit unit)

clearResults

public void clearResults()

Specified by:

clearResults in interface org.apache.geode.cache.execute.ResultCollector<T,S>

endResults

public void endResults()

Specified by:

endResults in interface org.apache.geode.cache.execute.ResultCollector<T,S>

hasResultsEnded

protected boolean hasResultsEnded()

hasResultsNotEnded

protected boolean hasResultsNotEnded()