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 java.lang.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 and Description
protected static java.util.concurrent.TimeUnit	DEFAULT_TIME_UNIT
protected static java.lang.String	NOT_IMPLEMENTED

Constructor Summary

Constructors

Constructor and Description
AbstractResultCollector()

Method Summary

Modifier and Type	Method and Description
void	clearResults()
void	endResults()
S	getResult()
S	getResult(long duration, java.util.concurrent.TimeUnit unit)
protected boolean	hasResultsEnded()
protected boolean	hasResultsNotEnded()
protected java.util.concurrent.TimeUnit	resolveTimeUnit(java.util.concurrent.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 Detail

NOT_IMPLEMENTED

protected static final java.lang.String NOT_IMPLEMENTED

See Also:

Constant Field Values

DEFAULT_TIME_UNIT

protected static final java.util.concurrent.TimeUnit DEFAULT_TIME_UNIT

Constructor Detail

AbstractResultCollector

public AbstractResultCollector()

Method Detail

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,
                   java.util.concurrent.TimeUnit unit)
            throws org.apache.geode.cache.execute.FunctionException,
                   java.lang.InterruptedException

Specified by:

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

Throws:

org.apache.geode.cache.execute.FunctionException

java.lang.InterruptedException

setResult

protected void setResult(S result)

resolveTimeUnit

protected java.util.concurrent.TimeUnit resolveTimeUnit(java.util.concurrent.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()