Package nz.org.riskscape.engine.pipeline

Class DefaultCollection<T>

java.lang.Object
nz.org.riskscape.engine.pipeline.DefaultCollection<T>
All Implemented Interfaces:
com.codahale.metrics.Gauge<String>, com.codahale.metrics.Metric
public class DefaultCollection<T> extends Object implements com.codahale.metrics.Gauge<String>

Implements a simple single-threaded collection of results from a Collector

  • Constructor Details

    • DefaultCollection

      public DefaultCollection(Collector<T> collector)

  • Method Details

    • lazilyCollected

      public TupleIterator lazilyCollected(TupleIterator collect)

    • collect

      public TupleIterator collect(TupleIterator toCollect)

    • addMetrics

      public void addMetrics(com.codahale.metrics.MetricRegistry registry, String prefix)

    • getValue

      public String getValue()
      Specified by:
      getValue in interface com.codahale.metrics.Gauge<T>