Skip to content

Commit 25a88f6

Browse files
authored
Collector: Refactoring the three phases of data collection tasks using disruptor (#48)
1 parent a812c4c commit 25a88f6

File tree

60 files changed

+2153
-1279
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

60 files changed

+2153
-1279
lines changed

.gitignore

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,4 +4,7 @@ target/
44

55
# IntelliJ relaged
66
.idea/
7-
*.iml
7+
*.iml
8+
9+
# log
10+
logs/

iotdb-collector/collector-core/pom.xml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -99,6 +99,10 @@
9999
<groupId>org.glassfish.jersey.inject</groupId>
100100
<artifactId>jersey-hk2</artifactId>
101101
</dependency>
102+
<dependency>
103+
<groupId>com.lmax</groupId>
104+
<artifactId>disruptor</artifactId>
105+
</dependency>
102106
</dependencies>
103107
<build>
104108
<plugins>

iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/Application.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@
2222
import org.apache.iotdb.collector.config.Configuration;
2323
import org.apache.iotdb.collector.service.ApiService;
2424
import org.apache.iotdb.collector.service.IService;
25+
import org.apache.iotdb.collector.service.RuntimeService;
2526

2627
import org.slf4j.Logger;
2728
import org.slf4j.LoggerFactory;
@@ -36,6 +37,7 @@ public class Application {
3637
private final LinkedList<IService> services = new LinkedList<>();
3738

3839
private Application() {
40+
services.add(new RuntimeService());
3941
services.add(new ApiService());
4042
}
4143

iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/CollectorAgent.java

Lines changed: 0 additions & 50 deletions
This file was deleted.

iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorProcessorTaskExecutor.java

Lines changed: 0 additions & 68 deletions
This file was deleted.

iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorSinkTaskExecutor.java

Lines changed: 0 additions & 67 deletions
This file was deleted.

iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorSourceTaskExecutor.java

Lines changed: 0 additions & 67 deletions
This file was deleted.

iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorTaskExecutor.java

Lines changed: 0 additions & 64 deletions
This file was deleted.

0 commit comments

Comments
 (0)