1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.shardingsphere.data.pipeline.core.task.progress;
19
20 import org.apache.shardingsphere.data.pipeline.core.ingest.position.IngestPosition;
21
22 import java.util.concurrent.atomic.AtomicReference;
23
24
25
26
27 public final class IncrementalTaskProgress implements TaskProgress {
28
29 private final AtomicReference<IngestPosition> position = new AtomicReference<>();
30
31 private final AtomicReference<IncrementalTaskDelay> incrementalTaskDelay = new AtomicReference<>();
32
33 public IncrementalTaskProgress(final IngestPosition position) {
34 this.position.set(position);
35 incrementalTaskDelay.set(new IncrementalTaskDelay());
36 }
37
38 @Override
39 public IngestPosition getPosition() {
40 return position.get();
41 }
42
43
44
45
46
47
48 public void setPosition(final IngestPosition position) {
49 this.position.set(position);
50 }
51
52
53
54
55
56
57 public IncrementalTaskDelay getIncrementalTaskDelay() {
58 return incrementalTaskDelay.get();
59 }
60
61
62
63
64
65
66 public void setIncrementalTaskDelay(final IncrementalTaskDelay incrementalTaskDelay) {
67 this.incrementalTaskDelay.set(incrementalTaskDelay);
68 }
69 }