View Javadoc
1   package de.dlr.shepard.data.timeseries.migration.services;
2   
3   import de.dlr.shepard.data.timeseries.migration.influxtimeseries.InfluxTimeseries;
4   import de.dlr.shepard.data.timeseries.migration.influxtimeseries.InfluxTimeseriesDataType;
5   import de.dlr.shepard.data.timeseries.model.TimeseriesContainer;
6   
7   class PayloadReadTask {
8   
9     public static final PayloadReadTask poisonPill = new PayloadReadTask(0, 0, 0, null, null, null, null, true);
10  
11    long startTimestamp;
12    long endTimestamp;
13    InfluxTimeseries influxTimeseries;
14    TimeseriesContainer container;
15    String databaseName;
16    InfluxTimeseriesDataType influxTimeseriesDataType;
17    int runningNumber; // running number starting with 1 for each container
18    boolean isLastTask = false;
19  
20    public PayloadReadTask(
21      int runningNumber,
22      long startTimestamp,
23      long endTimestamp,
24      InfluxTimeseries influxTimeseries,
25      TimeseriesContainer container,
26      String databaseName,
27      InfluxTimeseriesDataType influxTimeseriesDataType,
28      boolean isLastTask
29    ) {
30      this.runningNumber = runningNumber;
31      this.startTimestamp = startTimestamp;
32      this.endTimestamp = endTimestamp;
33      this.influxTimeseries = influxTimeseries;
34      this.container = container;
35      this.databaseName = databaseName;
36      this.influxTimeseriesDataType = influxTimeseriesDataType;
37      this.isLastTask = isLastTask;
38    }
39  }