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.migration.influxtimeseries.InfluxTimeseriesPayload;
6 import de.dlr.shepard.data.timeseries.model.TimeseriesContainer;
7
8 public class PayloadWriteTask {
9
10 private static int taskIdCounter = 0;
11
12 public static final PayloadWriteTask poisonPill = new PayloadWriteTask(
13 taskIdCounter,
14 0,
15 0,
16 null,
17 null,
18 null,
19 null,
20 true
21 );
22
23 InfluxTimeseriesPayload payload;
24 InfluxTimeseriesDataType dataType;
25 InfluxTimeseries influxTimeseries;
26 TimeseriesContainer container;
27 int taskId;
28 int runningNumber;
29 boolean isLastTask;
30
31 public long startTimestamp;
32 public long endTimestamp;
33
34 public PayloadWriteTask(
35 int runningNumber,
36 long startTimestamp,
37 long endTimestamp,
38 InfluxTimeseriesPayload payload,
39 InfluxTimeseriesDataType dataType,
40 InfluxTimeseries influxTimeseries,
41 TimeseriesContainer container,
42 boolean isLastTask
43 ) {
44 this.runningNumber = runningNumber;
45 this.startTimestamp = startTimestamp;
46 this.endTimestamp = endTimestamp;
47 this.payload = payload;
48 this.dataType = dataType;
49 this.influxTimeseries = influxTimeseries;
50 this.container = container;
51 this.isLastTask = isLastTask;
52 taskId = taskIdCounter++;
53 }
54 }