Skip to content

Commit 03e8e51

Browse files
authored
Pipe: Removed the MQTT source (apache#16405)
* removal * fix * fix
1 parent 40b2b33 commit 03e8e51

File tree

6 files changed

+0
-687
lines changed

6 files changed

+0
-687
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/dataregion/PipeDataRegionSourceConstructor.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.apache.iotdb.commons.pipe.agent.plugin.constructor.PipeSourceConstructor;
2525
import org.apache.iotdb.commons.pipe.agent.plugin.meta.DataNodePipePluginMetaKeeper;
2626
import org.apache.iotdb.db.pipe.source.dataregion.IoTDBDataRegionSource;
27-
import org.apache.iotdb.db.pipe.source.mqtt.MQTTSource;
2827

2928
class PipeDataRegionSourceConstructor extends PipeSourceConstructor {
3029

@@ -43,8 +42,5 @@ protected void initConstructors() {
4342
BuiltinPipePlugin.DO_NOTHING_SOURCE.getPipePluginName(), DoNothingSource::new);
4443
pluginConstructors.put(
4544
BuiltinPipePlugin.IOTDB_SOURCE.getPipePluginName(), IoTDBDataRegionSource::new);
46-
47-
pluginConstructors.put(BuiltinPipePlugin.MQTT_EXTRACTOR.getPipePluginName(), MQTTSource::new);
48-
pluginConstructors.put(BuiltinPipePlugin.MQTT_SOURCE.getPipePluginName(), MQTTSource::new);
4945
}
5046
}

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/source/mqtt/MQTTPublishHandler.java

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

0 commit comments

Comments
 (0)