View Javadoc
1   package de.dlr.shepard.data.timeseries;
2   
3   import de.dlr.shepard.data.timeseries.io.TimeseriesWithDataPoints;
4   import de.dlr.shepard.data.timeseries.model.Timeseries;
5   import de.dlr.shepard.data.timeseries.model.TimeseriesDataPoint;
6   import java.time.Instant;
7   import java.util.List;
8   
9   public final class TimeseriesTestDataGenerator {
10  
11    public static Timeseries generateTimeseries(String measurement) {
12      return new Timeseries(measurement, "device", "location", "symbolicName", "field");
13    }
14  
15    public static TimeseriesWithDataPoints generateTimeseriesWithDataPoints(
16      String measurement,
17      List<TimeseriesDataPoint> timeseriesDataPoints
18    ) {
19      return new TimeseriesWithDataPoints(generateTimeseries(measurement), timeseriesDataPoints);
20    }
21  
22    public static TimeseriesDataPoint generateDataPointDouble(long timestamp, Double value) {
23      return new TimeseriesDataPoint(timestamp, value);
24    }
25  
26    public static TimeseriesDataPoint generateDataPointDouble(Double value) {
27      return generateDataPointDouble(Instant.now().toEpochMilli() * 1_000_000, value);
28    }
29  
30    public static TimeseriesDataPoint generateDataPointInteger(long timestamp, Integer value) {
31      return generateDataPointInteger(timestamp, Long.valueOf(value));
32    }
33  
34    public static TimeseriesDataPoint generateDataPointInteger(Integer value) {
35      return generateDataPointInteger(Instant.now().toEpochMilli() * 1_000_000, value);
36    }
37  
38    public static TimeseriesDataPoint generateDataPointInteger(long timestamp, Long value) {
39      return new TimeseriesDataPoint(timestamp, value);
40    }
41  
42    public static TimeseriesDataPoint generateDataPointInteger(Long value) {
43      return new TimeseriesDataPoint(Instant.now().toEpochMilli() * 1_000_000, value);
44    }
45  
46    public static TimeseriesDataPoint generateDataPointString(String value) {
47      return new TimeseriesDataPoint(Instant.now().toEpochMilli() * 1_000_000, value);
48    }
49  
50    public static TimeseriesDataPoint generateDataPointString(long timestamp, String value) {
51      return new TimeseriesDataPoint(timestamp, value);
52    }
53  
54    public static TimeseriesDataPoint generateDataPointBoolean(Boolean value) {
55      return new TimeseriesDataPoint(Instant.now().toEpochMilli() * 1_000_000, value);
56    }
57  
58    public static TimeseriesDataPoint generateDataPointBoolean(long timestamp, Boolean value) {
59      return new TimeseriesDataPoint(timestamp, value);
60    }
61  }