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.context;
19
20 import org.apache.shardingsphere.data.pipeline.core.job.progress.TransmissionJobItemProgress;
21 import org.apache.shardingsphere.data.pipeline.core.job.progress.listener.PipelineJobProgressListener;
22 import org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader;
23 import org.apache.shardingsphere.data.pipeline.core.importer.sink.PipelineSink;
24 import org.apache.shardingsphere.data.pipeline.core.task.PipelineTask;
25
26 import java.util.Collection;
27
28
29
30
31 public interface TransmissionJobItemContext extends PipelineJobItemContext, PipelineJobProgressListener {
32
33 @Override
34 TransmissionProcessContext getJobProcessContext();
35
36
37
38
39
40
41 Collection<PipelineTask> getInventoryTasks();
42
43
44
45
46
47
48 Collection<PipelineTask> getIncrementalTasks();
49
50
51
52
53
54
55 TransmissionJobItemProgress getInitProgress();
56
57
58
59
60
61
62 PipelineTableMetaDataLoader getSourceMetaDataLoader();
63
64
65
66
67
68
69 PipelineSink getSink();
70
71
72
73
74
75
76 long getProcessedRecordsCount();
77
78
79
80
81
82
83 void updateInventoryRecordsCount(long recordsCount);
84
85
86
87
88
89
90 long getInventoryRecordsCount();
91
92 @Override
93 default TransmissionJobItemProgress toProgress() {
94 return new TransmissionJobItemProgress(this);
95 }
96 }