This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch optimize_infer_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6f4ed08754a fix review and test
add 8b5626c8922 Pipe: filtered empty tsFiles which should not be parsed or
reported (#12216)
add 56e21e4fee1 support config snapshot parser (#12211)
add fa9f21e23cd Pipe Subscription: initialize the subscription agent on DN
(#12138)
add 0a65556c6fa Fix NPE problem in EXPLAIN ANALYZE
add 9feffb1510d Allow series data type not consistent in compaction
add 1e129ec8096 Remove duplicate lookups in dictionary encoder (#12224)
add f04e020df77 fix: consider more general type of nodes above TopK-Node
as parent
add 945112d642d Pipe: Introduced aggregate processor as the universal
aggregation framework (#12210)
add 8c8f66668bd Fix procedure concurrency problem caused by non-atomic
procedure Id generation (#12229)
add 58ade690a9c fix cn parser and code style. (#12231)
add d96556cfc7e Fix envelope function execution error without frequency
parameter (#12233)
add 99c16cf3f55 Merge branch 'master' of github.com:apache/iotdb into
optimize_infer_type
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/opcua/ClientExampleRunner.java | 13 +-
.../java/org/apache/iotdb/opcua/ClientTest.java | 19 +-
.../iotdb/opcua/IoTDBKeyStoreLoaderClient.java | 14 +-
.../apache/iotdb/SubscriptionSessionExample.java | 99 +++
.../pipe/it/autocreate/IoTDBPipeProcessorIT.java | 9 +-
.../iotdb/pipe/it/single/AbstractPipeSingleIT.java | 28 +-
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 121 ++++
.../it/{ => single}/IoTDBPipeSingleEnvDemoIT.java | 20 +-
.../subscription/it/IoTDBSubscriptionBasicIT.java | 245 +++++++
.../it/IoTDBSubscriptionConsumerGroupIT.java | 342 ++++++++++
.../subscription/it/IoTDBSubscriptionTopicIT.java | 250 +++++++
.../api/customizer/parameter/PipeParameters.java | 21 +-
.../java/org/apache/iotdb/isession/ISession.java | 19 +
iotdb-client/service-rpc/pom.xml | 5 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +-
.../payload}/config/ConsumerConfig.java | 32 +-
.../payload/config/ConsumerConstant.java | 13 +-
.../subscription/payload/config/TopicConfig.java | 94 +++
.../payload}/config/TopicConstant.java | 6 +-
.../payload/request/ConsumerConfig.java | 85 ---
.../payload/request/PipeSubscribeCommitReq.java | 35 +-
.../payload/request/PipeSubscribeHandshakeReq.java | 3 +-
.../payload/request/PipeSubscribePollReq.java | 18 +-
.../payload/request/PipeSubscribeSubscribeReq.java | 16 +-
.../request/PipeSubscribeUnsubscribeReq.java | 16 +-
.../payload/response/EnrichedTablets.java | 47 +-
.../response/PipeSubscribeHandshakeResp.java | 21 +-
.../payload/response/PipeSubscribePollResp.java | 55 +-
.../java/org/apache/iotdb/session/Session.java | 37 ++
.../apache/iotdb/session/SessionConnection.java | 67 ++
.../flink/sql/client/IoTDBWebSocketClient.java | 9 +-
.../consensus/request/auth/AuthorPlan.java | 20 +-
.../response/pipe/task/PipeTableResp.java | 3 +
.../subscription/SubscriptionTableResp.java | 16 +-
.../confignode/manager/PermissionManager.java | 1 +
.../iotdb/confignode/manager/ProcedureManager.java | 138 ++--
.../agent/plugin/PipeConfigNodePluginAgent.java | 10 +-
.../PipeConfigRegionConnectorConstructor.java | 2 +-
.../PipeConfigRegionExtractorConstructor.java | 2 +-
.../PipeConfigRegionProcessorConstructor.java | 2 +-
.../transfer/execution/PipeConfigNodeSubtask.java | 21 +-
.../subscription/SubscriptionCoordinator.java | 21 +-
.../confignode/persistence/ProcedureInfo.java | 16 +-
.../persistence/pipe/PipePluginInfo.java | 4 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 6 +-
.../schema/CNPhysicalPlanGenerator.java | 390 +++++++++++
.../persistence/schema/CNSnapshotFileType.java} | 16 +-
.../schema/ConfignodeSnapshotParser.java | 167 +++++
.../persistence/subscription/SubscriptionInfo.java | 43 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 23 +-
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 8 +
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../impl/pipe/task/DropPipeProcedureV2.java | 2 +-
.../impl/pipe/task/StartPipeProcedureV2.java | 4 +-
.../impl/pipe/task/StopPipeProcedureV2.java | 4 +-
.../AbstractOperateSubscriptionProcedure.java | 14 +-
.../consumer/CreateConsumerProcedure.java | 6 +-
.../subscription/CreateSubscriptionProcedure.java | 23 +-
.../subscription/DropSubscriptionProcedure.java | 29 +-
.../impl/sync/AuthOperationProcedure.java | 21 +-
.../persistence/CNPhysicalPlanGeneratorTest.java | 446 +++++++++++++
.../PipeDataRegionConnectorConstructor.java | 2 +
.../dataregion/PipeDataRegionPluginAgent.java | 10 +-
.../PipeDataRegionProcessorConstructor.java | 11 +
.../PipeSchemaRegionConnectorConstructor.java | 2 +-
.../PipeSchemaRegionExtractorConstructor.java | 2 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 10 +-
.../PipeSchemaRegionProcessorConstructor.java | 2 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 6 +
.../protocol/legacy/IoTDBLegacyPipeConnector.java | 6 +-
.../connector/protocol/opcua/OpcUaConnector.java | 16 +-
.../protocol/opcua/OpcUaKeyStoreLoader.java | 20 +-
.../protocol/opcua/OpcUaServerBuilder.java | 44 +-
.../async/IoTDBDataRegionAsyncConnector.java | 3 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 6 +-
.../protocol/writeback/WriteBackConnector.java | 2 +-
.../pipe/event/common/row/PipeResetTabletRow.java | 54 ++
.../db/pipe/event/common/row/PipeRowCollector.java | 9 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 14 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 23 +-
.../tablet/TabletInsertionDataContainer.java | 2 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 38 +-
.../executor/PipeConnectorSubtaskExecutor.java | 4 +
.../executor/PipeSubtaskExecutorManager.java | 8 +
.../PipeHistoricalDataRegionTsFileExtractor.java | 29 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 6 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 4 +-
.../aggregate/AbstractFormalProcessor.java | 54 ++
.../processor/aggregate/AggregateProcessor.java | 719 +++++++++++++++++++++
.../aggregate/TimeSeriesRuntimeState.java | 396 ++++++++++++
.../aggregatedresult/AggregatedResultOperator.java | 62 ++
.../standardstatistics/AverageOperator.java | 56 ++
.../ClearanceFactorOperator.java | 60 ++
.../standardstatistics/CrestFactorOperator.java | 59 ++
.../standardstatistics/FormFactorOperator.java | 57 ++
.../standardstatistics/KurtosisOperator.java | 67 ++
.../standardstatistics/PeakOperator.java | 52 ++
.../standardstatistics/PulseFactorOperator.java | 57 ++
.../standardstatistics/RootMeanSquareOperator.java | 57 ++
.../standardstatistics/SkewnessOperator.java | 63 ++
.../standardstatistics/VarianceOperator.java | 59 ++
.../CustomizedReadableIntermediateResults.java | 158 +++++
.../IntermediateResultOperator.java | 113 ++++
.../sametype/numeric/AbsoluteMaxOperator.java | 71 ++
.../numeric/AbstractSameTypeNumericOperator.java | 152 +++++
.../numeric/IntegralPoweredSumOperator.java | 77 +++
.../doubletype/FractionPoweredSumOperator.java | 137 ++++
.../specifictype/integertype/CountOperator.java | 125 ++++
.../processor/AbstractOperatorProcessor.java | 73 +++
.../StandardStatisticsOperatorProcessor.java | 76 +++
.../window/datastructure/TimeSeriesWindow.java | 495 ++++++++++++++
.../window/datastructure/WindowOutput.java | 71 ++
.../window/datastructure/WindowState.java | 75 +++
.../AbstractSimpleTimeWindowingProcessor.java | 102 +++
.../processor/AbstractWindowingProcessor.java | 119 ++++
.../processor/TumblingWindowingProcessor.java | 110 ++++
.../sdt/SwingingDoorTrendingFilter.java | 8 +-
.../sdt/SwingingDoorTrendingSamplingProcessor.java | 6 +-
.../SimpleConsensusProgressIndexAssigner.java | 6 +
.../receiver/thrift/IoTDBDataNodeReceiver.java | 2 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 2 +-
.../pipe/task/builder/PipeDataNodeTaskBuilder.java | 46 +-
.../db/pipe/task/stage/PipeTaskConnectorStage.java | 19 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 47 +-
.../subtask/connector/PipeConnectorSubtask.java | 4 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 4 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 5 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 29 +-
.../db/queryengine/common/DataNodeEndPoints.java | 26 +
.../fragment/FragmentInstanceManager.java | 12 +-
.../config/executor/ClusterConfigTaskExecutor.java | 189 ++++--
.../OrderByExpressionWithLimitChangeToTopK.java | 68 +-
.../SimpleFragmentParallelPlanner.java | 5 +-
.../planner/plan/node/write/InsertTabletNode.java | 3 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 3 +
.../impl/ReadChunkCompactionPerformer.java | 47 ++
.../execute/utils/MultiTsFileDeviceIterator.java | 16 +-
.../fast/AlignedSeriesCompactionExecutor.java | 22 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 13 +-
.../compaction/io/CompactionTsFileReader.java | 51 ++
.../dataregion/memtable/TsFileProcessor.java | 2 +-
.../dataregion/tsfile/TsFileManager.java | 6 +-
.../dataregion/tsfile/TsFileResource.java | 2 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 2 +-
.../db/subscription/agent/SubscriptionAgent.java | 32 +-
.../agent/SubscriptionAgentLauncher.java | 170 +++++
.../agent/SubscriptionBrokerAgent.java | 135 ++++
.../agent/SubscriptionConsumerAgent.java | 202 ++++++
.../agent/SubscriptionReceiverAgent.java | 108 ++++
.../agent/SubscriptionRuntimeAgent.java | 98 +++
...TopicAgent.java => SubscriptionTopicAgent.java} | 62 +-
.../broker/EnrichedTabletsBinaryCache.java | 62 ++
.../broker/SerializedEnrichedEvent.java | 114 ++++
.../db/subscription/broker/SubscriptionBroker.java | 119 ++++
.../broker/SubscriptionPrefetchingQueue.java | 263 ++++++++
.../executor/SubscriptionSubtaskExecutor.java} | 14 +-
.../receiver/SubscriptionReceiver.java} | 17 +-
.../receiver/SubscriptionReceiverV1.java | 553 ++++++++++++++++
.../stage/SubscriptionTaskConnectorStage.java} | 40 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 75 +++
.../SubscriptionConnectorSubtaskLifeCycle.java} | 56 +-
.../SubscriptionConnectorSubtaskManager.java | 198 ++++++
.../db/tools/schema/SRStatementGenerator.java | 13 +-
.../tools/schema/SchemaRegionSnapshotParser.java | 11 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 9 +-
.../plan/planner/FragmentInstanceSerdeTest.java | 1 +
.../compaction/CompactionDataTypeNotMatchTest.java | 212 ++++++
...nkCompactionPerformerWithAlignedSeriesTest.java | 2 +-
.../db/utils/SchemaRegionSnapshotParserTest.java | 2 +-
.../iotdb/commons/auth/entity/PathPrivilege.java | 41 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 11 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 63 +-
.../commons/auth/role/LocalFileRoleAccessor.java | 2 +
.../iotdb/commons/auth/user/BasicUserManager.java | 8 +-
.../commons/auth/user/LocalFileUserAccessor.java | 8 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 83 +++
.../iotdb/commons/conf/CommonDescriptor.java | 47 ++
.../commons/consensus/index/ProgressIndexType.java | 8 +
.../index/impl/TimeWindowStateProgressIndex.java | 280 ++++++++
.../commons/pipe/agent/plugin/PipePluginAgent.java | 88 ++-
.../pipe/agent/plugin/PipePluginConstructor.java | 2 +-
.../config/constant/PipeConnectorConstant.java | 3 +
.../config/constant/PipeProcessorConstant.java | 20 +
.../env/PipeTaskProcessorRuntimeEnvironment.java | 12 +-
.../pipe/connector/client/IoTDBSyncClient.java | 2 +-
.../queue/ConcurrentIterableLinkedQueue.java | 18 +
.../iotdb/commons/pipe/event/EnrichedEvent.java | 14 +-
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 15 +-
.../processor/aggregate/AggregateProcessor.java} | 15 +-
.../aggregate/StandardStatisticsProcessor.java} | 15 +-
.../aggregate/TumblingWindowingProcessor.java} | 15 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 2 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 13 +
.../task/meta/PipeType.java} | 21 +-
.../apache/iotdb/commons/service/ServiceType.java | 2 +
.../subscription/config/SubscriptionConfig.java | 100 +++
.../meta/consumer/ConsumerGroupMeta.java | 17 +
.../meta/consumer/ConsumerGroupMetaKeeper.java | 76 ++-
.../subscription/meta/consumer/ConsumerMeta.java | 2 +-
.../commons/subscription/meta/topic/TopicMeta.java | 90 ++-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 85 +++
.../commons/pipe/task/meta/PipeMetaDeSerTest.java | 20 +
.../consumer/ConsumerGroupDeSerTest.java | 2 +
.../commons/subscription/topic/TopicDeSerTest.java | 2 +-
.../tsfile/encoding/encoder/DictionaryEncoder.java | 17 +-
.../org/apache/iotdb/tsfile/read/TsFileReader.java | 2 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 48 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 70 +-
.../thrift-datanode/src/main/thrift/client.thrift | 2 +-
.../library/frequency/UDFEnvelopeAnalysis.java | 6 +-
212 files changed, 10852 insertions(+), 1041 deletions(-)
create mode 100644
example/session/src/main/java/org/apache/iotdb/SubscriptionSessionExample.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionAgent.java
=>
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/AbstractPipeSingleIT.java
(60%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/single/IoTDBPipeAggregateIT.java
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ =>
single}/IoTDBPipeSingleEnvDemoIT.java (81%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/IoTDBSubscriptionBasicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/IoTDBSubscriptionConsumerGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/IoTDBSubscriptionTopicIT.java
copy
{iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/subscription =>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload}/config/ConsumerConfig.java
(53%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/subscription/config/ConsumerConfig.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/config/ConsumerConstant.java
(73%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/config/TopicConfig.java
rename
{iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/subscription =>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload}/config/TopicConstant.java
(87%)
delete mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/request/ConsumerConfig.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/CNPhysicalPlanGenerator.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/subscription/config/TopicConfig.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/CNSnapshotFileType.java}
(74%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/ConfignodeSnapshotParser.java
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/persistence/CNPhysicalPlanGeneratorTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/row/PipeResetTabletRow.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AbstractFormalProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/AggregateProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/TimeSeriesRuntimeState.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/AggregatedResultOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/AverageOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/ClearanceFactorOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/CrestFactorOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/FormFactorOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/KurtosisOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/PeakOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/PulseFactorOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/RootMeanSquareOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/SkewnessOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/aggregatedresult/standardstatistics/VarianceOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/intermediateresult/CustomizedReadableIntermediateResults.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/intermediateresult/IntermediateResultOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/intermediateresult/sametype/numeric/AbsoluteMaxOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/intermediateresult/sametype/numeric/AbstractSameTypeNumericOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/intermediateresult/sametype/numeric/IntegralPoweredSumOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/intermediateresult/specifictype/doubletype/FractionPoweredSumOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/intermediateresult/specifictype/integertype/CountOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/processor/AbstractOperatorProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/operator/processor/StandardStatisticsOperatorProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/window/datastructure/TimeSeriesWindow.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/window/datastructure/WindowOutput.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/window/datastructure/WindowState.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/window/processor/AbstractSimpleTimeWindowingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/window/processor/AbstractWindowingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/aggregate/window/processor/TumblingWindowingProcessor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionAgentLauncher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionBrokerAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionReceiverAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionRuntimeAgent.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/{topic/TopicAgent.java
=> SubscriptionTopicAgent.java} (59%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/EnrichedTabletsBinaryCache.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SerializedEnrichedEvent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionBroker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionPrefetchingQueue.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/execution/executor/PipeConnectorSubtaskExecutor.java
=> subscription/execution/executor/SubscriptionSubtaskExecutor.java} (65%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/subscription/config/TopicConfig.java
=>
datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiver.java}
(65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/task/stage/PipeTaskConnectorStage.java
=> subscription/task/stage/SubscriptionTaskConnectorStage.java} (63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/task/subtask/connector/PipeConnectorSubtaskLifeCycle.java
=> subscription/task/subtask/SubscriptionConnectorSubtaskLifeCycle.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionConnectorSubtaskManager.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/CompactionDataTypeNotMatchTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/consensus/index/impl/TimeWindowStateProgressIndex.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{config/plugin/env/PipeTaskProcessorRuntimeEnvironment.java
=> plugin/builtin/processor/aggregate/AggregateProcessor.java} (59%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{config/plugin/env/PipeTaskProcessorRuntimeEnvironment.java
=> plugin/builtin/processor/aggregate/StandardStatisticsProcessor.java} (58%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/{config/plugin/env/PipeTaskProcessorRuntimeEnvironment.java
=> plugin/builtin/processor/aggregate/TumblingWindowingProcessor.java} (58%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{subscription/config/TopicConfig.java
=> pipe/task/meta/PipeType.java} (68%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/subscription/config/SubscriptionConfig.java
