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 Details

  • 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()