Skip to content

Commit 4b5297e

Browse files
SteveYurongSuSteveYurongSu
committed
Pipe: Disable unstable features in the distribution
1 parent 85b7ac2 commit 4b5297e

File tree

9 files changed

+25
-1068
lines changed

9 files changed

+25
-1068
lines changed

‎.github/workflows/pipe-it.yml‎

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

‎iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/agent/plugin/PipeConfigRegionConnectorConstructor.java‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.BuiltinPipePlugin;
2323
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.donothing.DoNothingConnector;
2424
import org.apache.iotdb.commons.pipe.agent.plugin.constructor.PipeConnectorConstructor;
25-
import org.apache.iotdb.confignode.manager.pipe.connector.protocol.IoTDBConfigRegionAirGapConnector;
2625
import org.apache.iotdb.confignode.manager.pipe.connector.protocol.IoTDBConfigRegionConnector;
2726
import org.apache.iotdb.pipe.api.PipeConnector;
2827

@@ -42,9 +41,6 @@ protected void initConstructors() {
4241
pluginConstructors.put(
4342
BuiltinPipePlugin.IOTDB_THRIFT_ASYNC_CONNECTOR.getPipePluginName(),
4443
IoTDBConfigRegionConnector::new);
45-
pluginConstructors.put(
46-
BuiltinPipePlugin.IOTDB_AIR_GAP_CONNECTOR.getPipePluginName(),
47-
IoTDBConfigRegionAirGapConnector::new);
4844
pluginConstructors.put(
4945
BuiltinPipePlugin.DO_NOTHING_CONNECTOR.getPipePluginName(), DoNothingConnector::new);
5046

@@ -59,9 +55,6 @@ protected void initConstructors() {
5955
pluginConstructors.put(
6056
BuiltinPipePlugin.IOTDB_THRIFT_ASYNC_SINK.getPipePluginName(),
6157
IoTDBConfigRegionConnector::new);
62-
pluginConstructors.put(
63-
BuiltinPipePlugin.IOTDB_AIR_GAP_SINK.getPipePluginName(),
64-
IoTDBConfigRegionAirGapConnector::new);
6558
pluginConstructors.put(
6659
BuiltinPipePlugin.DO_NOTHING_SINK.getPipePluginName(), DoNothingConnector::new);
6760
}

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

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,7 @@
2323
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.donothing.DoNothingConnector;
2424
import org.apache.iotdb.commons.pipe.agent.plugin.constructor.PipeConnectorConstructor;
2525
import org.apache.iotdb.commons.pipe.agent.plugin.meta.DataNodePipePluginMetaKeeper;
26-
import org.apache.iotdb.db.pipe.connector.protocol.airgap.IoTDBDataRegionAirGapConnector;
2726
import org.apache.iotdb.db.pipe.connector.protocol.legacy.IoTDBLegacyPipeConnector;
28-
import org.apache.iotdb.db.pipe.connector.protocol.opcda.OpcDaConnector;
29-
import org.apache.iotdb.db.pipe.connector.protocol.opcua.OpcUaConnector;
3027
import org.apache.iotdb.db.pipe.connector.protocol.pipeconsensus.PipeConsensusAsyncConnector;
3128
import org.apache.iotdb.db.pipe.connector.protocol.thrift.async.IoTDBDataRegionAsyncConnector;
3229
import org.apache.iotdb.db.pipe.connector.protocol.thrift.sync.IoTDBDataRegionSyncConnector;
@@ -59,15 +56,8 @@ protected void initConstructors() {
5956
pluginConstructors.put(
6057
BuiltinPipePlugin.IOTDB_LEGACY_PIPE_CONNECTOR.getPipePluginName(),
6158
IoTDBLegacyPipeConnector::new);
62-
pluginConstructors.put(
63-
BuiltinPipePlugin.IOTDB_AIR_GAP_CONNECTOR.getPipePluginName(),
64-
IoTDBDataRegionAirGapConnector::new);
6559
pluginConstructors.put(
6660
BuiltinPipePlugin.WEBSOCKET_CONNECTOR.getPipePluginName(), WebSocketConnector::new);
67-
pluginConstructors.put(
68-
BuiltinPipePlugin.OPC_UA_CONNECTOR.getPipePluginName(), OpcUaConnector::new);
69-
pluginConstructors.put(
70-
BuiltinPipePlugin.OPC_DA_CONNECTOR.getPipePluginName(), OpcDaConnector::new);
7161
pluginConstructors.put(
7262
BuiltinPipePlugin.DO_NOTHING_CONNECTOR.getPipePluginName(), DoNothingConnector::new);
7363
pluginConstructors.put(
@@ -88,13 +78,8 @@ protected void initConstructors() {
8878
pluginConstructors.put(
8979
BuiltinPipePlugin.IOTDB_LEGACY_PIPE_SINK.getPipePluginName(),
9080
IoTDBLegacyPipeConnector::new);
91-
pluginConstructors.put(
92-
BuiltinPipePlugin.IOTDB_AIR_GAP_SINK.getPipePluginName(),
93-
IoTDBDataRegionAirGapConnector::new);
9481
pluginConstructors.put(
9582
BuiltinPipePlugin.WEBSOCKET_SINK.getPipePluginName(), WebSocketConnector::new);
96-
pluginConstructors.put(BuiltinPipePlugin.OPC_UA_SINK.getPipePluginName(), OpcUaConnector::new);
97-
pluginConstructors.put(BuiltinPipePlugin.OPC_DA_SINK.getPipePluginName(), OpcDaConnector::new);
9883
pluginConstructors.put(
9984
BuiltinPipePlugin.DO_NOTHING_SINK.getPipePluginName(), DoNothingConnector::new);
10085
pluginConstructors.put(

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

Lines changed: 0 additions & 30 deletions
Original file line numberDiff line numberDiff line change
@@ -21,18 +21,10 @@
2121

2222
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.BuiltinPipePlugin;
2323
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.donothing.DoNothingProcessor;
24-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.throwing.ThrowingExceptionProcessor;
2524
import org.apache.iotdb.commons.pipe.agent.plugin.constructor.PipeProcessorConstructor;
2625
import org.apache.iotdb.commons.pipe.agent.plugin.meta.DataNodePipePluginMetaKeeper;
27-
import org.apache.iotdb.db.pipe.processor.aggregate.AggregateProcessor;
28-
import org.apache.iotdb.db.pipe.processor.aggregate.operator.processor.StandardStatisticsOperatorProcessor;
29-
import org.apache.iotdb.db.pipe.processor.aggregate.window.processor.TumblingWindowingProcessor;
30-
import org.apache.iotdb.db.pipe.processor.downsampling.changing.ChangingValueSamplingProcessor;
31-
import org.apache.iotdb.db.pipe.processor.downsampling.sdt.SwingingDoorTrendingSamplingProcessor;
32-
import org.apache.iotdb.db.pipe.processor.downsampling.tumbling.TumblingTimeSamplingProcessor;
3326
import org.apache.iotdb.db.pipe.processor.pipeconsensus.PipeConsensusProcessor;
3427
import org.apache.iotdb.db.pipe.processor.schemachange.RenameDatabaseProcessor;
35-
import org.apache.iotdb.db.pipe.processor.twostage.plugin.TwoStageCountProcessor;
3628

3729
class PipeDataRegionProcessorConstructor extends PipeProcessorConstructor {
3830

@@ -44,28 +36,6 @@ class PipeDataRegionProcessorConstructor extends PipeProcessorConstructor {
4436
protected void initConstructors() {
4537
pluginConstructors.put(
4638
BuiltinPipePlugin.DO_NOTHING_PROCESSOR.getPipePluginName(), DoNothingProcessor::new);
47-
pluginConstructors.put(
48-
BuiltinPipePlugin.TUMBLING_TIME_SAMPLING_PROCESSOR.getPipePluginName(),
49-
TumblingTimeSamplingProcessor::new);
50-
pluginConstructors.put(
51-
BuiltinPipePlugin.SDT_SAMPLING_PROCESSOR.getPipePluginName(),
52-
SwingingDoorTrendingSamplingProcessor::new);
53-
pluginConstructors.put(
54-
BuiltinPipePlugin.CHANGING_VALUE_SAMPLING_PROCESSOR.getPipePluginName(),
55-
ChangingValueSamplingProcessor::new);
56-
pluginConstructors.put(
57-
BuiltinPipePlugin.THROWING_EXCEPTION_PROCESSOR.getPipePluginName(),
58-
ThrowingExceptionProcessor::new);
59-
pluginConstructors.put(
60-
BuiltinPipePlugin.AGGREGATE_PROCESSOR.getPipePluginName(), AggregateProcessor::new);
61-
pluginConstructors.put(
62-
BuiltinPipePlugin.STANDARD_STATISTICS_PROCESSOR.getPipePluginName(),
63-
StandardStatisticsOperatorProcessor::new);
64-
pluginConstructors.put(
65-
BuiltinPipePlugin.TUMBLING_WINDOWING_PROCESSOR.getPipePluginName(),
66-
TumblingWindowingProcessor::new);
67-
pluginConstructors.put(
68-
BuiltinPipePlugin.COUNT_POINT_PROCESSOR.getPipePluginName(), TwoStageCountProcessor::new);
6939
pluginConstructors.put(
7040
BuiltinPipePlugin.PIPE_CONSENSUS_PROCESSOR.getPipePluginName(),
7141
PipeConsensusProcessor::new);

‎iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/plugin/schemaregion/PipeSchemaRegionConnectorConstructor.java‎

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,6 @@
2222
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.BuiltinPipePlugin;
2323
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.donothing.DoNothingConnector;
2424
import org.apache.iotdb.commons.pipe.agent.plugin.constructor.PipeConnectorConstructor;
25-
import org.apache.iotdb.db.pipe.connector.protocol.airgap.IoTDBSchemaRegionAirGapConnector;
2625
import org.apache.iotdb.db.pipe.connector.protocol.thrift.sync.IoTDBSchemaRegionConnector;
2726
import org.apache.iotdb.pipe.api.PipeConnector;
2827

@@ -42,9 +41,6 @@ protected void initConstructors() {
4241
pluginConstructors.put(
4342
BuiltinPipePlugin.IOTDB_THRIFT_ASYNC_CONNECTOR.getPipePluginName(),
4443
IoTDBSchemaRegionConnector::new);
45-
pluginConstructors.put(
46-
BuiltinPipePlugin.IOTDB_AIR_GAP_CONNECTOR.getPipePluginName(),
47-
IoTDBSchemaRegionAirGapConnector::new);
4844
pluginConstructors.put(
4945
BuiltinPipePlugin.DO_NOTHING_CONNECTOR.getPipePluginName(), DoNothingConnector::new);
5046

@@ -59,9 +55,6 @@ protected void initConstructors() {
5955
pluginConstructors.put(
6056
BuiltinPipePlugin.IOTDB_THRIFT_ASYNC_SINK.getPipePluginName(),
6157
IoTDBSchemaRegionConnector::new);
62-
pluginConstructors.put(
63-
BuiltinPipePlugin.IOTDB_AIR_GAP_SINK.getPipePluginName(),
64-
IoTDBSchemaRegionAirGapConnector::new);
6558
pluginConstructors.put(
6659
BuiltinPipePlugin.DO_NOTHING_SINK.getPipePluginName(), DoNothingConnector::new);
6760
}

‎iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/IoTDBDataRegionExtractor.java‎

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@
2121

2222
import org.apache.iotdb.commons.consensus.DataRegionId;
2323
import org.apache.iotdb.commons.exception.IllegalPathException;
24+
import org.apache.iotdb.commons.pipe.agent.task.meta.PipeStaticMeta;
2425
import org.apache.iotdb.commons.pipe.config.constant.PipeExtractorConstant;
2526
import org.apache.iotdb.commons.pipe.config.constant.SystemConstant;
2627
import org.apache.iotdb.commons.pipe.datastructure.pattern.IoTDBTreePattern;
@@ -145,6 +146,21 @@ public class IoTDBDataRegionExtractor extends IoTDBExtractor {
145146
public void validate(final PipeParameterValidator validator) throws Exception {
146147
super.validate(validator);
147148

149+
final boolean forwardingPipeRequests =
150+
validator
151+
.getParameters()
152+
.getBooleanOrDefault(
153+
Arrays.asList(
154+
PipeExtractorConstant.EXTRACTOR_FORWARDING_PIPE_REQUESTS_KEY,
155+
PipeExtractorConstant.SOURCE_FORWARDING_PIPE_REQUESTS_KEY),
156+
PipeExtractorConstant.EXTRACTOR_FORWARDING_PIPE_REQUESTS_DEFAULT_VALUE);
157+
if (!forwardingPipeRequests) {
158+
throw new PipeParameterNotValidException(
159+
String.format(
160+
"The parameter %s cannot be set to false.",
161+
PipeExtractorConstant.SOURCE_FORWARDING_PIPE_REQUESTS_KEY));
162+
}
163+
148164
final boolean isTreeDialect =
149165
validator
150166
.getParameters()
@@ -465,6 +481,11 @@ private void constructRealtimeExtractor(final PipeParameters parameters)
465481
return;
466482
}
467483

484+
if (pipeName == null || !pipeName.startsWith(PipeStaticMeta.CONSENSUS_PIPE_PREFIX)) {
485+
realtimeExtractor = new PipeRealtimeDataRegionTsFileExtractor();
486+
return;
487+
}
488+
468489
// Use hybrid mode by default
469490
if (!parameters.hasAnyAttributes(EXTRACTOR_MODE_STREAMING_KEY, SOURCE_MODE_STREAMING_KEY)
470491
&& !parameters.hasAnyAttributes(EXTRACTOR_REALTIME_MODE_KEY, SOURCE_REALTIME_MODE_KEY)) {

‎iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/PipeRealtimeDataRegionExtractor.java‎

Lines changed: 2 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ public abstract class PipeRealtimeDataRegionExtractor implements PipeExtractor {
111111
private final AtomicReference<Pair<Long, Long>> dataRegionTimePartitionIdBound =
112112
new AtomicReference<>();
113113

114-
protected boolean isForwardingPipeRequests;
114+
protected boolean isForwardingPipeRequests = true;
115115

116116
private boolean shouldTransferModFile; // Whether to transfer mods
117117

@@ -241,22 +241,7 @@ public void customize(
241241
? TimePartitionUtils.getTimePartitionId(realtimeDataExtractionEndTime)
242242
: TimePartitionUtils.getTimePartitionId(realtimeDataExtractionEndTime) - 1;
243243

244-
final boolean isDoubleLiving =
245-
parameters.getBooleanOrDefault(
246-
Arrays.asList(
247-
PipeExtractorConstant.EXTRACTOR_MODE_DOUBLE_LIVING_KEY,
248-
PipeExtractorConstant.SOURCE_MODE_DOUBLE_LIVING_KEY),
249-
PipeExtractorConstant.EXTRACTOR_MODE_DOUBLE_LIVING_DEFAULT_VALUE);
250-
if (isDoubleLiving) {
251-
isForwardingPipeRequests = false;
252-
} else {
253-
isForwardingPipeRequests =
254-
parameters.getBooleanOrDefault(
255-
Arrays.asList(
256-
PipeExtractorConstant.EXTRACTOR_FORWARDING_PIPE_REQUESTS_KEY,
257-
PipeExtractorConstant.SOURCE_FORWARDING_PIPE_REQUESTS_KEY),
258-
PipeExtractorConstant.EXTRACTOR_FORWARDING_PIPE_REQUESTS_DEFAULT_VALUE);
259-
}
244+
isForwardingPipeRequests = true;
260245

261246
if (parameters.hasAnyAttributes(EXTRACTOR_MODS_KEY, SOURCE_MODS_KEY)) {
262247
shouldTransferModFile =

‎iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/builtin/BuiltinPipePlugin.java‎

Lines changed: 0 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -20,30 +20,19 @@
2020
package org.apache.iotdb.commons.pipe.agent.plugin.builtin;
2121

2222
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.donothing.DoNothingConnector;
23-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.airgap.IoTDBAirGapConnector;
2423
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.consensus.PipeConsensusAsyncConnector;
2524
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBLegacyPipeConnector;
2625
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftAsyncConnector;
2726
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftConnector;
2827
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftSslConnector;
2928
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.iotdb.thrift.IoTDBThriftSyncConnector;
30-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.opcda.OpcDaConnector;
31-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.opcua.OpcUaConnector;
3229
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.websocket.WebSocketConnector;
3330
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.connector.writeback.WriteBackConnector;
3431
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.extractor.donothing.DoNothingExtractor;
3532
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.extractor.iotdb.IoTDBExtractor;
36-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.aggregate.AggregateProcessor;
37-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.aggregate.StandardStatisticsProcessor;
38-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.aggregate.TumblingWindowingProcessor;
3933
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.donothing.DoNothingProcessor;
40-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.downsampling.ChangingValueSamplingProcessor;
41-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.downsampling.SwingingDoorTrendingSamplingProcessor;
42-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.downsampling.TumblingTimeSamplingProcessor;
4334
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.pipeconsensus.PipeConsensusProcessor;
4435
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.schemachange.RenameDatabaseProcessor;
45-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.throwing.ThrowingExceptionProcessor;
46-
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.processor.twostage.TwoStageCountProcessor;
4736

4837
import java.util.Arrays;
4938
import java.util.Collections;
@@ -61,18 +50,8 @@ public enum BuiltinPipePlugin {
6150

6251
// processors
6352
DO_NOTHING_PROCESSOR("do-nothing-processor", DoNothingProcessor.class),
64-
TUMBLING_TIME_SAMPLING_PROCESSOR(
65-
"tumbling-time-sampling-processor", TumblingTimeSamplingProcessor.class),
66-
SDT_SAMPLING_PROCESSOR("sdt-sampling-processor", SwingingDoorTrendingSamplingProcessor.class),
67-
CHANGING_VALUE_SAMPLING_PROCESSOR(
68-
"changing-value-sampling-processor", ChangingValueSamplingProcessor.class),
69-
THROWING_EXCEPTION_PROCESSOR("throwing-exception-processor", ThrowingExceptionProcessor.class),
70-
AGGREGATE_PROCESSOR("aggregate-processor", AggregateProcessor.class),
71-
COUNT_POINT_PROCESSOR("count-point-processor", TwoStageCountProcessor.class),
7253

7354
// Hidden-processors, which are plugins of the processors
74-
STANDARD_STATISTICS_PROCESSOR("standard-statistics-processor", StandardStatisticsProcessor.class),
75-
TUMBLING_WINDOWING_PROCESSOR("tumbling-windowing-processor", TumblingWindowingProcessor.class),
7655
PIPE_CONSENSUS_PROCESSOR("pipe-consensus-processor", PipeConsensusProcessor.class),
7756
RENAME_DATABASE_PROCESSOR("rename-database-processor", RenameDatabaseProcessor.class),
7857

@@ -83,13 +62,10 @@ public enum BuiltinPipePlugin {
8362
IOTDB_THRIFT_SYNC_CONNECTOR("iotdb-thrift-sync-connector", IoTDBThriftSyncConnector.class),
8463
IOTDB_THRIFT_ASYNC_CONNECTOR("iotdb-thrift-async-connector", IoTDBThriftAsyncConnector.class),
8564
IOTDB_LEGACY_PIPE_CONNECTOR("iotdb-legacy-pipe-connector", IoTDBLegacyPipeConnector.class),
86-
IOTDB_AIR_GAP_CONNECTOR("iotdb-air-gap-connector", IoTDBAirGapConnector.class),
8765
PIPE_CONSENSUS_ASYNC_CONNECTOR(
8866
"pipe-consensus-async-connector", PipeConsensusAsyncConnector.class),
8967

9068
WEBSOCKET_CONNECTOR("websocket-connector", WebSocketConnector.class),
91-
OPC_UA_CONNECTOR("opc-ua-connector", OpcUaConnector.class),
92-
OPC_DA_CONNECTOR("opc-da-connector", OpcDaConnector.class),
9369
WRITE_BACK_CONNECTOR("write-back-connector", WriteBackConnector.class),
9470

9571
DO_NOTHING_SINK("do-nothing-sink", DoNothingConnector.class),
@@ -98,10 +74,7 @@ public enum BuiltinPipePlugin {
9874
IOTDB_THRIFT_SYNC_SINK("iotdb-thrift-sync-sink", IoTDBThriftSyncConnector.class),
9975
IOTDB_THRIFT_ASYNC_SINK("iotdb-thrift-async-sink", IoTDBThriftAsyncConnector.class),
10076
IOTDB_LEGACY_PIPE_SINK("iotdb-legacy-pipe-sink", IoTDBLegacyPipeConnector.class),
101-
IOTDB_AIR_GAP_SINK("iotdb-air-gap-sink", IoTDBAirGapConnector.class),
10277
WEBSOCKET_SINK("websocket-sink", WebSocketConnector.class),
103-
OPC_UA_SINK("opc-ua-sink", OpcUaConnector.class),
104-
OPC_DA_SINK("opc-da-sink", OpcDaConnector.class),
10578
WRITE_BACK_SINK("write-back-sink", WriteBackConnector.class),
10679
SUBSCRIPTION_SINK("subscription-sink", DoNothingConnector.class),
10780
PIPE_CONSENSUS_ASYNC_SINK("pipe-consensus-async-sink", PipeConsensusAsyncConnector.class),
@@ -139,14 +112,6 @@ public String getClassName() {
139112
// Sources
140113
DO_NOTHING_SOURCE.getPipePluginName().toUpperCase(),
141114
// Processors
142-
TUMBLING_TIME_SAMPLING_PROCESSOR.getPipePluginName().toUpperCase(),
143-
SDT_SAMPLING_PROCESSOR.getPipePluginName().toUpperCase(),
144-
CHANGING_VALUE_SAMPLING_PROCESSOR.getPipePluginName().toUpperCase(),
145-
THROWING_EXCEPTION_PROCESSOR.getPipePluginName().toUpperCase(),
146-
AGGREGATE_PROCESSOR.getPipePluginName().toUpperCase(),
147-
COUNT_POINT_PROCESSOR.getPipePluginName().toUpperCase(),
148-
STANDARD_STATISTICS_PROCESSOR.getPipePluginName().toUpperCase(),
149-
TUMBLING_WINDOWING_PROCESSOR.getPipePluginName().toUpperCase(),
150115
PIPE_CONSENSUS_PROCESSOR.getPipePluginName().toUpperCase(),
151116
RENAME_DATABASE_PROCESSOR.getPipePluginName().toUpperCase(),
152117
// Connectors
@@ -156,19 +121,14 @@ public String getClassName() {
156121
IOTDB_THRIFT_SYNC_CONNECTOR.getPipePluginName().toUpperCase(),
157122
IOTDB_THRIFT_ASYNC_CONNECTOR.getPipePluginName().toUpperCase(),
158123
IOTDB_LEGACY_PIPE_CONNECTOR.getPipePluginName().toUpperCase(),
159-
IOTDB_AIR_GAP_CONNECTOR.getPipePluginName().toUpperCase(),
160124
WEBSOCKET_CONNECTOR.getPipePluginName().toUpperCase(),
161-
OPC_UA_CONNECTOR.getPipePluginName().toUpperCase(),
162-
OPC_DA_CONNECTOR.getPipePluginName().toUpperCase(),
163125
WRITE_BACK_CONNECTOR.getPipePluginName().toUpperCase(),
164126
PIPE_CONSENSUS_ASYNC_CONNECTOR.getPipePluginName().toUpperCase(),
165127
// Sinks
166128
IOTDB_THRIFT_SYNC_SINK.getPipePluginName().toUpperCase(),
167129
IOTDB_THRIFT_ASYNC_SINK.getPipePluginName().toUpperCase(),
168130
IOTDB_LEGACY_PIPE_SINK.getPipePluginName().toUpperCase(),
169131
WEBSOCKET_SINK.getPipePluginName().toUpperCase(),
170-
OPC_UA_SINK.getPipePluginName().toUpperCase(),
171-
OPC_DA_SINK.getPipePluginName().toUpperCase(),
172132
SUBSCRIPTION_SINK.getPipePluginName().toUpperCase(),
173133
PIPE_CONSENSUS_ASYNC_SINK.getPipePluginName().toUpperCase())));
174134
}

0 commit comments

Comments
 (0)