This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-collector
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f79440d7306 Collector Node: Build basic architecture, configuration
file reading and REST service (#14689)
add 4e93faa0062 CollectorNode built-in data acquisition plug-in pipeline
simple implementation. (#14725)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/collector/Collector.java | 50 +++------
.../iotdb/collector/agent/CollectorAgent.java | 50 +++++++++
.../agent/collect/CollectorEventCollector.java | 32 +++---
.../executor/CollectorProcessorTaskExecutor.java | 68 ++++++++++++
.../agent/executor/CollectorSinkTaskExecutor.java | 67 ++++++++++++
.../executor/CollectorSourceTaskExecutor.java | 67 ++++++++++++
.../agent/executor/CollectorTaskExecutor.java | 63 +++++++++++
.../agent/executor/CollectorTaskExecutorAgent.java | 53 ++++++++++
.../agent/plugin/CollectorPluginAgent.java | 31 +++---
.../agent/plugin/CollectorPluginConstructor.java | 77 ++++++++++++++
.../agent/task/CollectorProcessorTask.java | 88 ++++++++++++++++
.../collector/agent/task/CollectorSinkTask.java | 87 +++++++++++++++
.../collector/agent/task/CollectorSourceTask.java | 69 ++++++++++++
.../iotdb/collector/agent/task/CollectorTask.java | 19 ++--
.../collector/agent/task/CollectorTaskAgent.java | 117 +++++++++++++++++++++
.../iotdb/collector/config/CollectorConfig.java | 42 +++++++-
.../iotdb/collector/config/CollectorConstant.java | 24 -----
.../collector/config/CollectorDescriptor.java | 62 +++++------
.../config/CollectorSystemPropertiesHandler.java | 52 ---------
.../iotdb/collector/config/ConfigFileUtils.java | 101 ------------------
.../collector/plugin/BuiltinCollectorPlugin.java | 74 +++++++++++++
.../builtin/processor}/DoNothingProcessor.java | 35 +++---
.../collector/plugin/builtin/sink/SessionSink.java | 50 ++++-----
.../plugin/builtin/source/HttpSource.java | 57 ++++++----
.../plugin/builtin/source/event/SourceEvent.java | 19 ++--
.../protocol/rest/filter/AuthorizationFilter.java | 46 --------
.../rest/v1/handler/RequestValidationHandler.java | 19 ++--
.../protocol/rest/v1/impl/AdminApiServiceImpl.java | 34 +++++-
.../iotdb/collector/service/RegisterManager.java | 4 +-
.../resources/iotdb-collector-system.properties | 2 +-
.../src/main/openapi3/iotdb_collector_rest_v1.yaml | 55 +++-------
31 files changed, 1143 insertions(+), 471 deletions(-)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/CollectorAgent.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/DisruptorQueueExceptionHandler.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/collect/CollectorEventCollector.java
(57%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorProcessorTaskExecutor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorSinkTaskExecutor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorSourceTaskExecutor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorTaskExecutor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/executor/CollectorTaskExecutorAgent.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/SubscriptionOperation.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/plugin/CollectorPluginAgent.java
(58%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/plugin/CollectorPluginConstructor.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorProcessorTask.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorSinkTask.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorSourceTask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/PipeStatement.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTask.java
(69%)
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/agent/task/CollectorTaskAgent.java
delete mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/CollectorConstant.java
delete mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/CollectorSystemPropertiesHandler.java
delete mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/config/ConfigFileUtils.java
create mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/BuiltinCollectorPlugin.java
copy
{iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/processor/donothing
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/processor}/DoNothingProcessor.java
(69%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/connector/donothing/DoNothingConnector.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/sink/SessionSink.java
(53%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/extractor/iotdb/IoTDBExtractor.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/HttpSource.java
(51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/mtree/impl/mem/mnode/info/BasicMNodeInfo.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/plugin/builtin/source/event/SourceEvent.java
(71%)
delete mode 100644
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/protocol/rest/filter/AuthorizationFilter.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/ConfigRegionId.java
=>
iotdb-collector/collector-core/src/main/java/org/apache/iotdb/collector/protocol/rest/v1/handler/RequestValidationHandler.java
(59%)
