This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch refactor-pipe-package
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from fd0ab7e2c8d Pipe: Refactor pipe related packages
add a4030612f2f refactor
No new revisions were added by this update.
Summary of changes:
.../pipe/it/autocreate/IoTDBPipeProtocolIT.java | 2 +-
.../write/pipe/plugin/CreatePipePluginPlan.java | 2 +-
.../response/pipe/plugin/PipePluginTableResp.java | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 2 +-
.../agent/plugin/PipeConfigNodePluginAgent.java | 8 ++--
.../PipeConfigRegionConnectorConstructor.java | 6 +--
.../PipeConfigRegionExtractorConstructor.java | 6 +--
.../PipeConfigRegionProcessorConstructor.java | 6 +--
.../coordinator/plugin/PipePluginCoordinator.java | 2 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 2 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 2 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 2 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 2 +-
.../manager/pipe/task/PipeConfigNodeSubtask.java | 2 +-
.../persistence/pipe/PipePluginInfo.java | 12 +++---
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 2 +-
.../response/pipe/PipePluginTableRespTest.java | 6 +--
.../connector/IoTDBConfigRegionConnectorTest.java | 2 +-
.../PipeConfigNodeSubtaskExecutorTest.java | 2 +-
...eConfigPhysicalPlanPatternParseVisitorTest.java | 2 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 2 +-
.../pipe/plugin/CreatePipePluginProcedureTest.java | 2 +-
.../consensus/config/PipeConsensusConfig.java | 2 +-
.../db/consensus/DataRegionConsensusImpl.java | 2 +-
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 10 ++---
.../PipeDataRegionConnectorConstructor.java | 8 ++--
.../PipeDataRegionExtractorConstructor.java | 8 ++--
.../dataregion/PipeDataRegionPluginAgent.java | 10 ++---
.../PipeDataRegionProcessorConstructor.java | 10 ++---
.../PipeSchemaRegionConnectorConstructor.java | 6 +--
.../PipeSchemaRegionExtractorConstructor.java | 6 +--
.../schemaregion/PipeSchemaRegionPluginAgent.java | 8 ++--
.../PipeSchemaRegionProcessorConstructor.java | 6 +--
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 6 +--
.../db/pipe/event/UserDefinedEnrichedEvent.java | 2 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 2 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 2 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 2 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 2 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 2 +-
.../tablet/TabletInsertionDataContainer.java | 2 +-
.../event/common/terminate/PipeTerminateEvent.java | 2 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../common/tsfile/TsFileInsertionPointCounter.java | 2 +-
.../container/TsFileInsertionDataContainer.java | 2 +-
.../TsFileInsertionDataContainerProvider.java | 4 +-
.../query/TsFileInsertionQueryDataContainer.java | 2 +-
.../scan/TsFileInsertionScanDataContainer.java | 2 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../dataregion/IoTDBDataRegionExtractor.java | 4 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 2 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 2 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 4 +-
.../CachedSchemaPatternMatcher.java | 4 +-
.../PipeDataRegionMatcher.java | 2 +-
.../schemaregion/PipePlanPatternParseVisitor.java | 2 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 2 +-
...peStatementDataTypeConvertExecutionVisitor.java | 2 +-
.../visitor/PipeStatementPatternParseVisitor.java | 2 +-
.../pipe/task/connection/PipeEventCollector.java | 2 +-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 2 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 4 +-
.../connector/PipeConnectorSubtaskManager.java | 2 +-
.../subtask/processor/PipeProcessorSubtask.java | 2 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 4 +-
.../config/metadata/ShowPipePluginsTask.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../db/service/ResourcesInformationHolder.java | 2 +-
.../SubscriptionConnectorSubtaskManager.java | 4 +-
.../agent/plugin/PipeDataNodePluginAgentTest.java | 8 ++--
.../iotdb/db/pipe/connector/PipeConnectorTest.java | 2 +-
.../PipeStatementPatternParseVisitorTest.java | 2 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 2 +-
.../event/TsFileInsertionDataContainerTest.java | 6 +--
.../PipeProcessorSubtaskExecutorTest.java | 2 +-
.../extractor/PipePlanPatternParseVisitorTest.java | 2 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 6 +--
.../db/pipe/pattern/IoTDBPipePatternTest.java | 2 +-
.../db/pipe/pattern/PrefixPipePatternTest.java | 2 +-
.../commons/pipe/agent/plugin/PipePluginAgent.java | 5 ++-
.../plugin/builtin/BuiltinPipePlugin.java | 50 +++++++++++-----------
.../builtin/connector/PlaceholderConnector.java | 2 +-
.../connector/donothing/DoNothingConnector.java | 2 +-
.../iotdb/airgap/IoTDBAirGapConnector.java | 4 +-
.../consensus/PipeConsensusAsyncConnector.java | 4 +-
.../iotdb/thrift/IoTDBLegacyPipeConnector.java | 4 +-
.../iotdb/thrift/IoTDBThriftAsyncConnector.java | 2 +-
.../iotdb/thrift/IoTDBThriftConnector.java | 4 +-
.../iotdb/thrift/IoTDBThriftSslConnector.java | 4 +-
.../iotdb/thrift/IoTDBThriftSyncConnector.java | 2 +-
.../builtin/connector/opcua/OpcUaConnector.java | 4 +-
.../connector/websocket/WebSocketConnector.java | 4 +-
.../connector/writeback/WriteBackConnector.java | 4 +-
.../extractor/donothing/DoNothingExtractor.java | 2 +-
.../builtin/extractor/iotdb/IoTDBExtractor.java | 2 +-
.../builtin/processor/PlaceHolderProcessor.java | 2 +-
.../processor/aggregate/AggregateProcessor.java | 4 +-
.../aggregate/StandardStatisticsProcessor.java | 4 +-
.../aggregate/TumblingWindowingProcessor.java | 4 +-
.../processor/donothing/DoNothingProcessor.java | 2 +-
.../ChangingValueSamplingProcessor.java | 4 +-
.../SwingingDoorTrendingSamplingProcessor.java | 4 +-
.../TumblingTimeSamplingProcessor.java | 4 +-
.../pipeconsensus/PipeConsensusProcessor.java | 4 +-
.../throwing/ThrowingExceptionProcessor.java | 2 +-
.../processor/twostage/TwoStageCountProcessor.java | 4 +-
.../PipeConnectorConstructor.java | 6 +--
.../PipeExtractorConstructor.java | 6 +--
.../{ => constructor}/PipePluginConstructor.java | 8 ++--
.../PipeProcessorConstructor.java | 6 +--
.../meta/ConfigNodePipePluginMetaKeeper.java | 2 +-
.../plugin/meta/DataNodePipePluginMetaKeeper.java | 2 +-
.../{ => agent}/plugin/meta/PipePluginMeta.java | 2 +-
.../plugin/meta/PipePluginMetaKeeper.java | 4 +-
.../plugin/service/PipePluginClassLoader.java | 2 +-
.../service/PipePluginClassLoaderManager.java | 2 +-
.../service/PipePluginExecutableManager.java | 4 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +--
.../pattern/IoTDBPipePattern.java | 2 +-
.../{ => datastructure}/pattern/PipePattern.java | 2 +-
.../pattern/PrefixPipePattern.java | 2 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 2 +-
.../commons/pipe/event/PipeSnapshotEvent.java | 2 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 2 +-
.../commons/pipe/event/ProgressReportEvent.java | 2 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 4 +-
.../pipe/task/{ => connection}/EventSupplier.java | 2 +-
.../pipe/plugin/builtin/BuiltinPipePluginTest.java | 10 ++---
.../pipe/plugin/meta/PipePluginMetaTest.java | 4 +-
133 files changed, 257 insertions(+), 252 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/{pattern
=> matcher}/CachedSchemaPatternMatcher.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/{pattern
=> matcher}/PipeDataRegionMatcher.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/BuiltinPipePlugin.java (74%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/PlaceholderConnector.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/donothing/DoNothingConnector.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/airgap/IoTDBAirGapConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/connector/iotdb/consensus/PipeConsensusAsyncConnector.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBLegacyPipeConnector.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftAsyncConnector.java
(93%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSslConnector.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/iotdb/thrift/IoTDBThriftSyncConnector.java
(93%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/opcua/OpcUaConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/websocket/WebSocketConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/connector/writeback/WriteBackConnector.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/extractor/donothing/DoNothingExtractor.java (95%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/extractor/iotdb/IoTDBExtractor.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/PlaceHolderProcessor.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/aggregate/AggregateProcessor.java (87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/aggregate/StandardStatisticsProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/aggregate/TumblingWindowingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/donothing/DoNothingProcessor.java (96%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/processor/downsampling/ChangingValueSamplingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/processor/downsampling/SwingingDoorTrendingSamplingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=>
agent}/plugin/builtin/processor/downsampling/TumblingTimeSamplingProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/pipeconsensus/PipeConsensusProcessor.java
(87%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/throwing/ThrowingExceptionProcessor.java
(97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/builtin/processor/twostage/TwoStageCountProcessor.java (87%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipeConnectorConstructor.java (89%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipeExtractorConstructor.java (89%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipePluginConstructor.java (92%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/agent/plugin/{
=> constructor}/PipeProcessorConstructor.java (89%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/ConfigNodePipePluginMetaKeeper.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/DataNodePipePluginMetaKeeper.java (93%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/PipePluginMeta.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/meta/PipePluginMetaKeeper.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/service/PipePluginClassLoader.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/service/PipePluginClassLoaderManager.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> agent}/plugin/service/PipePluginExecutableManager.java (97%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> datastructure}/pattern/IoTDBPipePattern.java (99%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> datastructure}/pattern/PipePattern.java (98%)
rename iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{
=> datastructure}/pattern/PrefixPipePattern.java (98%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/{ =>
connection}/EventSupplier.java (95%)
