[IOTDB-3251] ForwardTrigger: support MQTT/HTTP data forwarding (#5870)
author刘威 <51618159+LIU-WEI-git@users.noreply.github.com>
Sun, 29 May 2022 07:56:10 +0000 (15:56 +0800)
committerGitHub <noreply@github.com>
Sun, 29 May 2022 07:56:10 +0000 (15:56 +0800)
commitc64366776113cccb67374b4b86d65935bc4a07e2
tree946f78100cb5c62e93e979b4a18a750a04c61fe9
parent6ec70deb51f6cb033f2e60ea22c57204b3dac5d7
[IOTDB-3251] ForwardTrigger: support MQTT/HTTP data forwarding (#5870)

Co-authored-by: gongning <iskytek@gmail.com>
28 files changed:
example/trigger/src/main/java/org/apache/iotdb/trigger/AlertingExample.java
example/trigger/src/main/java/org/apache/iotdb/trigger/TriggerExample.java
integration/pom.xml
integration/src/test/java/org/apache/iotdb/db/engine/trigger/example/Accumulator.java
integration/src/test/java/org/apache/iotdb/db/engine/trigger/example/Counter.java
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBTriggerForwardIT.java [new file with mode: 0644]
server/src/assembly/resources/conf/iotdb-engine.properties
server/src/main/java/org/apache/iotdb/db/conf/IoTDBConfig.java
server/src/main/java/org/apache/iotdb/db/conf/IoTDBDescriptor.java
server/src/main/java/org/apache/iotdb/db/engine/trigger/api/Trigger.java
server/src/main/java/org/apache/iotdb/db/engine/trigger/builtin/ForwardTrigger.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerEngine.java
server/src/main/java/org/apache/iotdb/db/engine/trigger/executor/TriggerExecutor.java
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/api/Event.java
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/api/Handler.java
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/forward/ForwardEvent.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardConfiguration.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardEvent.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/http/HTTPForwardHandler.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardConfiguration.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardEvent.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/sink/mqtt/MQTTForwardHandler.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/BatchHandlerQueue.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/HTTPConnectionPool.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/MQTTConnectionFactory.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/engine/trigger/utils/MQTTConnectionPool.java [new file with mode: 0644]
server/src/main/java/org/apache/iotdb/db/protocol/mqtt/JSONPayloadFormatter.java
server/src/test/java/org/apache/iotdb/db/metadata/idtable/trigger_example/Counter.java