25a88f6aabf806d38ffa36c70c8e8b7b1599cd9f - iotdb-extras

commit: 25a88f6aabf806d38ffa36c70c8e8b7b1599cd9f
[log]
author: 0xB <76414902+YC27@users.noreply.github.com>
Tue Mar 04 11:12:32 2025 +0800
committer: GitHub <noreply@github.com>
Tue Mar 04 11:12:32 2025 +0800
tree: 2f6ae94a351dd62fc701cb6dc712d56541b22794
parent: a812c4c819a32a1f248515684da3717ce7b86b30 [diff]

Collector: Refactoring the three phases of data collection tasks using disruptor (#48)

.gitignore[diff]
iotdb-collector/collector-core/pom.xml[diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/Application.java[diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/CollectorAgent.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorProcessorTaskExecutor.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorSinkTaskExecutor.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorSourceTaskExecutor.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorTaskExecutor.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorTaskExecutorAgent.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/plugin/CollectorPluginAgent.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/plugin/CollectorPluginConstructor.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorProcessorTask.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorSinkTask.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorSourceTask.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTaskAgent.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/ping/impl/PingApiServiceImpl.java[Renamed from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/impl/PingApiServiceImpl.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/handler/RequestValidationHandler.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/impl/AdminApiServiceImpl.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/plugin/impl/PluginApiServiceImpl.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/plugin/impl/PluginApiServiceRequestValidationHandler.java[Copied from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/task/impl/TaskApiServiceImpl.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/api/v1/task/impl/TaskApiServiceRequestValidationHandler.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/ApiServiceOptions.java[diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/Options.java[diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/TaskRuntimeOptions.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/BuiltinPlugin.java[Renamed from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/BuiltinCollectorPlugin.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/CollectorPullSource.java[Copied from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/CollectorPushSource.java[Copied from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/SourceEvent.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/CollectorSource.java[Copied from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/RuntimeConfig.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/api/StoppablePlugin.java[Copied from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/HttpSource.java[Deleted - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/event/SourceEvent.java[Renamed from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/SourceEvent.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/processor/DoNothingProcessor.java[Renamed from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/processor/DoNothingProcessor.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/sink/SessionSink.java[Renamed from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/SessionSink.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/source/HttpPullSource.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/source/HttpPushSource.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/PluginFactory.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/plugin/PluginRuntime.java[Copied from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/TaskRuntime.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/datastructure/TaskEventCollector.java[Renamed from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/collect/CollectorEventCollector.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/datastructure/TaskEventConsumer.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/datastructure/TaskEventConsumerController.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/datastructure/TaskEventContainer.java[Renamed from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/ProcessorTask.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/PullSourceTask.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/PushSourceTask.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/SinkTask.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/SourceTask.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/Task.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/TaskComponent.java[Copied from iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/def/TaskRepository.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/runtime/task/exception/DisruptorTaskExceptionHandler.java[Added - diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/ApiService.java[diff]
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/service/RuntimeService.java[Added - diff]
iotdb-collector/collector-core/src/main/resources/application.properties[diff]
iotdb-collector/collector-core/src/main/resources/logback.xml[Added - diff]
iotdb-collector/collector-openapi/pom.xml[diff]
iotdb-collector/collector-openapi/src/main/openapi3/iotdb_collector_rest_v1.yaml[Deleted - diff]
iotdb-collector/collector-openapi/src/main/openapi3/ping/ping.yaml[Renamed from iotdb-collector/collector-openapi/src/main/openapi3/ping.yaml - diff]
iotdb-collector/collector-openapi/src/main/openapi3/v1/plugin.yaml[Added - diff]
iotdb-collector/collector-openapi/src/main/openapi3/v1/task.yaml[Added - diff]
pom.xml[diff]

63 files changed

tree: 2f6ae94a351dd62fc701cb6dc712d56541b22794