Class TimeseriesFetchStrategy

    • Field Detail

      • PARALLELISM

        public static final int PARALLELISM
    • Constructor Detail

      • TimeseriesFetchStrategy

        public TimeseriesFetchStrategy()
    • Method Detail

      • fetch

        public FetchResults fetch​(long start,
                                  long end,
                                  long step,
                                  int maxrows,
                                  java.lang.Long interval,
                                  java.lang.Long heartbeat,
                                  java.util.List<Source> sources,
                                  boolean relaxed)
        Description copied from interface: MeasurementFetchStrategy
        Fetches the measurements for the given sources.
        Specified by:
        fetch in interface MeasurementFetchStrategy
        Parameters:
        start - timestamp in milliseconds
        end - timestamp in milliseconds
        step - desired resolution in milliseconds - actual resolution might differ
        maxrows - maximum number of rows - no limit when <= 0
        interval - duration in milliseconds, used by strategies that implement late aggregation
        heartbeat - duration in milliseconds, used by strategies that implement late aggregation
        sources - array of sources - these should have unique labels
        relaxed - if false a missing source results in a return of null. true on the other hand ignores that source.
        Returns:
        null when a resource id or attribute cannot be found
      • setResourceDao

        @Inject
        protected void setResourceDao​(ResourceDao resourceDao)
      • setTimeseriesStorageManager

        @Inject
        protected void setTimeseriesStorageManager​(TimeseriesStorageManager timeseriesStorage)
      • setMetricRegistry

        @Inject
        protected void setMetricRegistry​(@Named("timeseriesMetricRegistry")
                                         com.codahale.metrics.MetricRegistry registry)