This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/TableModelGrammar0617
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a215c28993c remove redundant project in appendProjects method
add 0343fc2a777 Mergemaster0620 (#12779)
add 25012cf57c1 Merge branch 'ty/TableModelGrammar' of
github.com:apache/iotdb into ty/TableModelGrammar
add 1afc4b5ad31 merge ty/TableGrammar
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/CountPointProcessor.java | 14 +-
example/schema/pom.xml | 1 -
.../apache/iotdb/SubscriptionSessionExample.java | 154 ++-
.../iotdb/it/env/cluster/ClusterConstant.java | 3 -
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 6 +-
.../it/env/cluster/config/MppCommonConfig.java | 26 +
.../env/cluster/config/MppSharedCommonConfig.java | 25 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 4 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 73 +-
.../it/env/cluster/node/ConfigNodeWrapper.java | 4 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 4 +-
.../it/env/remote/config/RemoteCommonConfig.java | 17 +
.../org/apache/iotdb/it/utils/TsFileGenerator.java | 103 +-
.../apache/iotdb/itbase/env/BaseNodeWrapper.java | 16 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 7 +
.../iotdb/itbase/runtime/RequestDelegate.java | 10 +-
...TDBLoadTsFileIT.java => IoTDBLoadTsFileIT.java} | 394 +++++---
.../org/apache/iotdb/db/it/IoTDBRecoverIT.java | 2 +-
.../iotdb/db/it/IoTDBVerifyConnectionIT.java | 115 +++
...oTDBAlignByDeviceWithTemplateAggregationIT.java | 130 ++-
.../db/it/aligned/IoTDBPredicatePushDownIT.java | 27 +
.../regionscan/IoTDBActiveRegionScanIT.java | 12 +-
.../regionscan/IoTDBActiveRegionScanIT2.java | 9 +-
.../IoTDBActiveRegionScanWithModsIT.java | 26 +-
.../IoTDBActiveRegionScanWithModsIT2.java | 9 +-
.../regionscan/IoTDBActiveSchemaQueryIT.java | 363 +++++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 36 +
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 105 ++
.../pipe/it/autocreate/IoTDBPipeExtractorIT.java | 166 ++++
.../iotdb/pipe/it/single/IoTDBPipeAggregateIT.java | 14 +
.../subscription/it/AbstractSubscriptionIT.java | 49 +
.../it/IoTDBSubscriptionITConstant.java | 19 +-
.../iotdb/subscription/it/SkipOnSetUpFailure.java | 82 ++
.../IoTDBSubscriptionRestartIT.java | 84 +-
.../it/dual/AbstractSubscriptionDualIT.java | 13 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 42 +-
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 33 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 389 ++++++--
.../it/local/AbstractSubscriptionLocalIT.java | 39 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 204 ++--
.../it/local/IoTDBSubscriptionIdempotentIT.java | 14 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 8 +-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 8 +
.../java/org/apache/iotdb/pipe/api/access/Row.java | 46 +-
.../java/org/apache/iotdb/pipe/api/type/Type.java | 15 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 8 +
.../org/apache/iotdb/tool/AbstractTsFileTool.java | 12 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 10 +-
.../java/org/apache/iotdb/tool/ImportTsFile.java | 4 +-
iotdb-client/client-cpp/README.md | 86 +-
.../client-cpp/src/assembly/client-cpp.xml | 12 +-
.../client-py/iotdb/utils/IoTDBRpcDataSet.py | 14 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 20 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 48 +-
.../rpc/subscription/config/TopicConstant.java | 11 +
.../SubscriptionIdentifierSemanticException.java | 30 +-
.../payload/poll/SubscriptionPollResponse.java | 3 +
.../payload/poll/SubscriptionPollResponseType.java | 2 +
.../payload/poll/TerminationPayload.java | 38 +-
.../response/PipeSubscribeSubscribeResp.java | 51 +-
.../response/PipeSubscribeUnsubscribeResp.java | 51 +-
.../consumer/SubscriptionConsumer.java | 116 ++-
.../SubscriptionExecutorServiceManager.java | 8 +-
.../consumer/SubscriptionProvider.java | 12 +-
.../consumer/SubscriptionPullConsumer.java | 9 +-
.../consumer/SubscriptionPushConsumer.java | 8 +-
.../payload/SubscriptionFileHandler.java | 20 +-
.../payload/SubscriptionSessionDataSet.java | 9 +-
.../session/subscription/util/IdentifierUtils.java | 51 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 13 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../src/assembly/resources/sbin/stop-confignode.sh | 2 +
...RequestType.java => CnToCnNodeRequestType.java} | 4 +-
...NodeRequestType.java => CnToDnRequestType.java} | 5 +-
.../async/AsyncConfigNodeHeartbeatClientPool.java | 7 +-
.../client/async/AsyncDataNodeClientPool.java | 559 -----------
.../CnToCnInternalServiceAsyncRequestManager.java | 74 ++
.../CnToDnInternalServiceAsyncRequestManager.java | 376 ++++++++
.../handlers/ConfigNodeAsyncRequestContext.java} | 44 +-
.../handlers/DataNodeAsyncRequestContext.java | 50 +
.../rpc/CheckTimeSeriesExistenceRPCHandler.java | 22 +-
.../rpc/ConfigNodeAsyncRequestRPCHandler.java | 88 ++
...dler.java => ConfigNodeTSStatusRPCHandler.java} | 32 +-
.../rpc/CountPathsUsingTemplateRPCHandler.java | 22 +-
.../DataNodeAsyncRequestRPCHandler.java} | 175 +---
...andler.java => DataNodeTSStatusRPCHandler.java} | 12 +-
.../rpc/FetchSchemaBlackListRPCHandler.java | 20 +-
.../handlers/rpc/PipeHeartbeatRPCHandler.java | 8 +-
.../async/handlers/rpc/PipePushMetaRPCHandler.java | 8 +-
.../async/handlers/rpc/SchemaUpdateRPCHandler.java | 14 +-
...ava => SubmitTestConnectionTaskRPCHandler.java} | 42 +-
...itTestConnectionTaskToConfigNodeRPCHandler.java | 74 ++
.../handlers/rpc/TransferLeaderRPCHandler.java | 9 +-
.../CheckSchemaRegionUsingTemplateRPCHandler.java | 27 +-
.../ConsumerGroupPushMetaRPCHandler.java | 10 +-
.../rpc/subscription/TopicPushMetaRPCHandler.java | 10 +-
.../client/sync/SyncConfigNodeClientPool.java | 12 +-
.../client/sync/SyncDataNodeClientPool.java | 9 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 15 +
.../confignode/conf/ConfigNodeRemoveCheck.java | 4 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 2 +-
.../conf/ConfigNodeSystemPropertiesHandler.java} | 36 +-
.../confignode/conf/SystemPropertiesUtils.java | 86 +-
.../consensus/request/read/ttl/ShowTTLPlan.java | 13 +
.../response/datanode/DataNodeRegisterResp.java | 6 +-
.../iotdb/confignode/manager/ClusterManager.java | 221 +++++
.../confignode/manager/ClusterQuotaManager.java | 23 +-
.../iotdb/confignode/manager/ConfigManager.java | 20 +-
.../apache/iotdb/confignode/manager/IManager.java | 2 +-
.../iotdb/confignode/manager/TTLManager.java | 4 +-
.../iotdb/confignode/manager/TriggerManager.java | 14 +-
.../iotdb/confignode/manager/UDFManager.java | 20 +-
.../confignode/manager/cq/CQScheduleTask.java | 5 +-
.../manager/load/balancer/RouteBalancer.java | 26 +-
.../manager/node/ClusterNodeStartUtils.java | 121 ++-
.../iotdb/confignode/manager/node/NodeManager.java | 90 +-
.../manager/partition/PartitionManager.java | 39 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 10 +
.../protocol/IoTDBConfigRegionAirGapConnector.java | 7 +-
.../protocol/IoTDBConfigRegionConnector.java | 7 +-
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 15 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 13 +-
.../pipe/event/PipeConfigRegionWritePlanEvent.java | 8 +-
.../execution/PipeConfigNodeSubtaskExecutor.java | 6 +-
.../metric/PipeConfigNodeRemainingTimeMetrics.java | 32 +-
.../PipeConfigNodeRemainingTimeOperator.java | 99 +-
.../metric/PipeConfigRegionConnectorMetrics.java | 2 +-
.../manager/pipe/task/PipeConfigNodeTaskStage.java | 16 +-
.../manager/schema/ClusterSchemaManager.java | 14 +-
.../confignode/persistence/ProcedureInfo.java | 2 +-
.../iotdb/confignode/persistence/TTLInfo.java | 21 +-
.../persistence/executor/ConfigPlanExecutor.java | 3 +-
.../schema/CNPhysicalPlanGenerator.java | 11 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 219 ++---
.../procedure/env/RegionMaintainHandler.java | 31 +-
.../impl/schema/AlterLogicalViewProcedure.java | 18 +-
.../impl/schema/DataNodeRegionTaskExecutor.java | 25 +-
.../impl/schema/DeactivateTemplateProcedure.java | 27 +-
.../impl/schema/DeleteDatabaseProcedure.java | 16 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 22 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 26 +-
.../procedure/impl/schema/SchemaUtils.java | 6 +-
.../procedure/impl/schema/SetTTLProcedure.java | 14 +-
.../impl/schema/SetTemplateProcedure.java | 30 +-
.../impl/schema/UnsetTemplateProcedure.java | 22 +-
.../impl/schema/table/AddTableColumnProcedure.java | 24 +-
.../impl/schema/table/CreateTableProcedure.java | 26 +-
.../subscription/CreateSubscriptionProcedure.java | 2 +
.../subscription/DropSubscriptionProcedure.java | 151 +--
.../impl/sync/AuthOperationProcedure.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 8 +-
.../confignode/service/ConfigNodeShutdownHook.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 28 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 3 +-
.../iotdb/confignode/persistence/TTLInfoTest.java | 39 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 9 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 67 +-
.../consensuspipe/ConsensusPipeConnector.java} | 16 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 4 +
.../pipe/metric/PipeConsensusServerMetrics.java | 190 ++++
.../pipe/metric/PipeConsensusSyncLagManager.java | 131 +++
.../iotdb/consensus/ratis/RatisConsensus.java | 22 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 3 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 32 +-
.../DataNodeSystemPropertiesHandler.java} | 38 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 63 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 71 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 173 +---
.../db/consensus/DataRegionConsensusImpl.java | 9 +-
.../schemaregion/SchemaExecutionVisitor.java | 4 +-
.../schemaregion/SchemaRegionStateMachine.java | 16 +-
.../{PipeAgent.java => PipeDataNodeAgent.java} | 20 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 6 +-
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 10 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 43 +-
.../IoTDBDataNodeCacheLeaderClientManager.java | 21 +-
.../payload/evolvable/builder/PipeEventBatch.java | 18 +-
.../request/PipeTransferTabletRawReq.java | 70 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 1 +
.../airgap/IoTDBDataRegionAirGapConnector.java | 16 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 6 +-
.../connector/protocol/opcua/OpcUaConnector.java | 14 +
.../pipeconsensus/PipeConsensusAsyncConnector.java | 151 ++-
.../pipeconsensus/PipeConsensusSyncConnector.java | 25 +-
.../PipeConsensusTabletBatchEventHandler.java | 7 +-
.../PipeConsensusTabletInsertNodeEventHandler.java | 6 +-
.../PipeConsensusTabletInsertionEventHandler.java | 14 +-
.../PipeConsensusTabletRawEventHandler.java | 45 -
.../PipeConsensusTsFileInsertionEventHandler.java | 22 +-
.../PipeTransferTabletBatchEventHandler.java | 9 +-
.../PipeTransferTabletInsertionEventHandler.java | 22 +-
.../PipeTransferTsFileInsertionEventHandler.java | 8 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 1 +
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 20 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 6 +-
.../protocol/writeback/WriteBackConnector.java | 4 +-
.../consensus/ConsensusPipeDataNodeDispatcher.java | 4 +-
.../ConsensusPipeDataNodeRuntimeAgentGuardian.java | 4 +-
.../consensus/PipeConsensusConnectorMetrics.java | 290 ++++++
.../consensus/PipeConsensusReceiverMetrics.java | 384 ++++++++
.../consensus/PipeConsensusSubtaskExecutor.java | 4 +-
.../consensus/ProgressIndexDataNodeManager.java | 6 +-
.../db/pipe/event/UserDefinedEnrichedEvent.java | 28 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 20 +-
.../event/common/row/PipeDataTypeTransformer.java | 14 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 53 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 1 +
.../schema/PipeSchemaRegionSnapshotEvent.java | 14 +-
.../schema/PipeSchemaRegionWritePlanEvent.java | 8 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 150 +--
.../common/tablet/PipeRawTabletInsertionEvent.java | 83 +-
.../tablet/TabletInsertionDataContainer.java | 99 +-
.../event/common/terminate/PipeTerminateEvent.java | 19 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 106 +-
.../tsfile/TsFileInsertionDataContainer.java | 73 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 40 +-
.../execution/PipeConnectorSubtaskExecutor.java | 7 +-
.../execution/PipeProcessorSubtaskExecutor.java | 3 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 110 ++-
.../realtime/PipeRealtimeDataRegionExtractor.java | 86 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 8 +-
.../PipeRealtimeDataRegionLogExtractor.java | 11 +-
.../PipeRealtimeDataRegionTsFileExtractor.java | 8 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 2 +-
.../listener/PipeInsertionDataNodeListener.java | 4 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 13 +-
.../PipeDataNodeRemainingEventAndTimeMetrics.java | 58 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 178 ++--
.../metric/PipeDataRegionConnectorMetrics.java | 4 +-
.../db/pipe/metric/PipeDataRegionEventCounter.java | 7 +
.../metric/PipeDataRegionExtractorMetrics.java | 8 +-
.../iotdb/db/pipe/metric/PipeProcessorMetrics.java | 48 +-
.../metric/PipeSchemaRegionConnectorMetrics.java | 2 +-
.../processor/aggregate/AggregateProcessor.java | 47 +-
.../aggregate/TimeSeriesRuntimeState.java | 94 ++
.../CustomizedReadableIntermediateResults.java | 49 +-
.../IntermediateResultOperator.java | 41 +-
.../numeric/AbstractSameTypeNumericOperator.java | 46 +-
.../doubletype/FractionPoweredSumOperator.java | 56 +-
.../specifictype/integertype/CountOperator.java | 54 +-
.../window/datastructure/TimeSeriesWindow.java | 111 +++
.../AbstractSimpleTimeWindowingProcessor.java | 52 +-
.../processor/AbstractWindowingProcessor.java | 45 +-
.../downsampling/PartialPathLastObjectCache.java | 16 +-
.../downsampling/changing/ChangingValueFilter.java | 22 +-
.../sdt/SwingingDoorTrendingFilter.java | 20 +-
.../twostage/combiner/PipeCombineHandler.java | 4 +-
.../combiner/PipeCombineHandlerManager.java | 4 +-
.../twostage/plugin/TwoStageCountProcessor.java | 2 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 6 +-
.../pipeconsensus/PipeConsensusReceiver.java | 470 ++++++---
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
.../visitor/PipeStatementExceptionVisitor.java | 2 +-
.../visitor/PipeStatementTSStatusVisitor.java | 33 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 4 +-
.../resource/tsfile/PipeTsFileResourceManager.java | 42 +-
.../pipe/resource/wal/PipeWALResourceManager.java | 4 +-
.../pipe/task/builder/PipeDataNodeTaskBuilder.java | 4 +-
.../pipe/task/connection/PipeEventCollector.java | 14 +-
.../db/pipe/task/stage/PipeTaskExtractorStage.java | 6 +-
.../db/pipe/task/stage/PipeTaskProcessorStage.java | 6 +-
.../subtask/connector/PipeConnectorSubtask.java | 30 +-
.../connector/PipeConnectorSubtaskManager.java | 8 +-
.../subtask/processor/PipeProcessorSubtask.java | 22 +-
.../processor/PipeProcessorSubtaskWorker.java | 21 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 34 +-
.../iotdb/db/protocol/client/ConfigNodeInfo.java | 66 +-
.../cn/AsyncConfigNodeTSStatusRPCHandler.java} | 34 +-
.../cn/ConfigNodeAsyncRequestRPCHandler.java | 79 ++
.../DnToCnInternalServiceAsyncRequestManager.java | 64 ++
.../db/protocol/client/cn/DnToCnRequestType.java} | 17 +-
.../client/dn}/AsyncTSStatusRPCHandler.java | 9 +-
.../client/dn/DataNodeAsyncRequestRPCHandler.java | 84 ++
...DataNodeExternalServiceAsyncRequestManager.java | 83 ++
.../dn/DataNodeMPPServiceAsyncRequestManager.java | 84 ++
.../DnToDnInternalServiceAsyncRequestManager.java | 64 ++
.../db/protocol/client/dn/DnToDnRequestType.java} | 16 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 32 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 125 ++-
.../thrift/impl/DataNodeRegionManager.java | 4 +-
.../iotdb/db/queryengine/common/DeviceContext.java | 81 ++
...eriesSchemaInfo.java => TimeseriesContext.java} | 48 +-
.../common/header/ColumnHeaderConstant.java | 11 +
.../common/header/DatasetHeaderFactory.java | 4 +
.../common/schematree/ClusterSchemaTree.java | 13 +-
.../common/schematree/IMeasurementSchemaInfo.java | 2 +
.../common/schematree/MeasurementSchemaInfo.java | 13 +-
.../schematree/node/SchemaMeasurementNode.java | 14 +-
.../visitor/SchemaTreeDeviceVisitor.java | 3 +-
.../execution/driver/DataDriverContext.java | 19 +-
.../execution/exchange/MPPDataExchangeManager.java | 22 +-
.../fragment/FragmentInstanceContext.java | 29 +-
.../fragment/FragmentInstanceExecution.java | 2 +-
.../fragment/FragmentInstanceManager.java | 10 +
.../execution/load/AlignedChunkData.java | 124 ++-
.../execution/load/LoadTsFileManager.java | 147 ++-
.../execution/load/LoadTsFileRateLimiter.java | 45 +-
.../execution/load/NonAlignedChunkData.java | 65 +-
.../queryengine/execution/memory/MemoryPool.java | 9 +-
.../operator/schema/SchemaFetchScanOperator.java | 73 +-
.../operator/schema/source/DeviceSchemaSource.java | 4 +-
...erator.java => AbstractSeriesScanOperator.java} | 123 +--
.../source/ActiveDeviceRegionScanOperator.java | 43 +-
.../source/ActiveTimeSeriesRegionScanOperator.java | 14 +-
.../operator/source/AlignedSeriesScanOperator.java | 110 +--
.../source/RegionScanForActiveDeviceUtil.java | 3 +-
.../source/RegionScanForActiveTimeSeriesUtil.java | 6 +-
.../operator/source/SeriesScanOperator.java | 111 +--
.../load/LoadTsFileAnalyzeSchemaMemoryBlock.java | 2 +-
.../queryengine/load/LoadTsFileMemoryManager.java | 10 +-
.../metric/load/LoadTsFileCostMetricsSet.java | 131 +++
.../metric/{ => load}/LoadTsFileMemMetricSet.java | 2 +-
.../db/queryengine/plan/analyze/Analysis.java | 19 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 169 +++-
.../plan/analyze/LoadTsfileAnalyzer.java | 40 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 58 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 11 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 20 -
.../schema/DeviceUsingTemplateSchemaCache.java | 5 +
.../analyze/cache/schema/SchemaCacheEntry.java | 5 +
.../cache/schema/TimeSeriesSchemaCache.java | 2 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 2 +
.../analyze/schema/ClusterSchemaFetchExecutor.java | 46 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 16 +
.../plan/analyze/schema/ISchemaFetcher.java | 25 +-
.../queryengine/plan/execution/QueryExecution.java | 3 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 44 +-
.../config/executor/IConfigTaskExecutor.java | 2 +
.../execution/config/sys/TestConnectionTask.java | 218 +++++
.../plan/expression/multi/FunctionExpression.java | 8 +
.../db/queryengine/plan/parser/ASTVisitor.java | 22 +-
.../plan/parser/StatementGenerator.java | 2 +-
.../plan/planner/LocalExecutionPlanner.java | 28 +-
.../plan/planner/LogicalPlanBuilder.java | 52 +-
.../plan/planner/LogicalPlanVisitor.java | 38 +-
.../plan/planner/OperatorTreeGenerator.java | 168 +++-
.../planner/distribution/ExchangeNodeAdder.java | 12 +-
.../plan/planner/plan/node/PlanNodeType.java | 10 +-
.../plan/planner/plan/node/PlanVisitor.java | 9 +-
.../metedata/read/DeviceSchemaFetchScanNode.java | 101 ++
.../node/metedata/read/SchemaFetchScanNode.java | 123 +--
...canNode.java => SeriesSchemaFetchScanNode.java} | 115 +--
.../write/CreateAlignedTimeSeriesNode.java | 3 +-
.../plan/node/source/DeviceRegionScanNode.java | 46 +-
.../plan/node/source/TimeseriesRegionScanNode.java | 37 +-
.../planner/plan/node/write/InsertRowNode.java | 8 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 5 +-
.../planner/plan/node/write/InsertTabletNode.java | 8 +-
.../planner/optimizations/IndexScan.java | 8 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 6 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 46 +-
.../plan/statement/StatementVisitor.java | 18 +-
.../plan/statement/crud/InsertTabletStatement.java | 4 +
...tement.java => DeviceSchemaFetchStatement.java} | 37 +-
...tement.java => SeriesSchemaFetchStatement.java} | 22 +-
.../statement/metadata/CountDevicesStatement.java | 27 +
.../metadata/CountTimeSeriesStatement.java | 27 +
.../statement/metadata/ShowDevicesStatement.java | 27 +
.../plan/statement/metadata/ShowTTLStatement.java | 11 +-
.../metadata/ShowTimeSeriesStatement.java | 27 +
.../TestConnectionStatement.java} | 32 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 17 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 23 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 21 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 64 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 62 +-
.../schemaengine/schemaregion/tag/TagManager.java | 15 +
.../java/org/apache/iotdb/db/service/DataNode.java | 60 +-
.../db/service/metrics/DataNodeMetricsHelper.java | 6 +-
.../iotdb/db/storageengine/StorageEngine.java | 8 +-
.../db/storageengine/dataregion/DataRegion.java | 7 +-
.../dataregion/IDataRegionForQuery.java | 3 +-
.../dataregion/VirtualDataRegion.java | 3 +-
.../CompactionLastTimeCheckFailedException.java | 17 +
.../CompactionValidationFailedException.java | 14 +-
.../impl/ReadChunkCompactionPerformer.java | 7 +-
.../execute/task/AbstractCompactionTask.java | 17 +-
.../execute/utils/CompactionPathUtils.java | 13 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 120 +--
.../readchunk/SingleSeriesCompactionExecutor.java | 20 +-
.../executor/readchunk/loader/ChunkLoader.java | 3 +
.../writer/RepairUnsortedFileCompactionWriter.java | 18 +-
.../dataregion/memtable/TsFileProcessor.java | 15 +-
.../allocation/AbstractNodeAllocationStrategy.java | 8 +-
.../dataregion/wal/buffer/AbstractWALBuffer.java | 3 +-
.../dataregion/wal/buffer/WALBuffer.java | 16 +-
.../wal/checkpoint/CheckpointManager.java | 8 +-
.../dataregion/wal/io/CheckpointReader.java | 5 +-
.../dataregion/wal/io/CheckpointWriter.java | 4 +-
.../dataregion/wal/io/ILogWriter.java | 3 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 88 +-
.../dataregion/wal/io/WALByteBufReader.java | 12 +-
.../dataregion/wal/io/WALInputStream.java | 365 +++++++
.../dataregion/wal/io/WALMetaData.java | 25 +-
.../storageengine/dataregion/wal/io/WALReader.java | 12 +-
.../storageengine/dataregion/wal/io/WALWriter.java | 30 +-
.../storageengine/dataregion/wal/node/WALNode.java | 5 +-
.../dataregion/wal/recover/WALNodeRecoverTask.java | 1 +
.../dataregion/wal/recover/WALRecoverWriter.java | 4 +-
.../file/AbstractTsFileRecoverPerformer.java | 4 +-
.../file/UnsealedTsFileRecoverPerformer.java | 4 +-
.../dataregion/wal/utils/WALEntryPosition.java | 31 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 43 +-
.../storageengine/rescon/disk/FolderManager.java | 4 +
.../agent/SubscriptionAgentLauncher.java | 8 +-
.../agent/SubscriptionBrokerAgent.java | 11 +-
.../agent/SubscriptionConsumerAgent.java | 29 +-
.../agent/SubscriptionReceiverAgent.java | 6 +-
.../subscription/agent/SubscriptionTopicAgent.java | 32 +-
.../db/subscription/broker/SubscriptionBroker.java | 46 +-
.../broker/SubscriptionPrefetchingQueue.java | 60 +-
.../SubscriptionPrefetchingTabletsQueue.java | 21 +
.../broker/SubscriptionPrefetchingTsFileQueue.java | 59 +-
.../db/subscription/event/SubscriptionEvent.java | 6 +
.../event/SubscriptionEventBinaryCache.java | 8 +-
.../receiver/SubscriptionReceiverV1.java | 37 +-
.../task/subtask/SubscriptionConnectorSubtask.java | 18 +-
.../SubscriptionConnectorSubtaskLifeCycle.java | 57 +-
.../SubscriptionConnectorSubtaskManager.java | 4 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 6 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 2 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 21 +-
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 6 +
.../schemaRegion/SchemaRegionBasicTest.java | 13 +-
.../SchemaRegionSimpleRecoverTest.java | 18 +-
.../schemaRegion/SchemaRegionTemplateTest.java | 19 +-
.../connector/PipeDataNodeThriftRequestTest.java | 116 ++-
.../db/pipe/event/PipeDataTypeTransformerTest.java | 13 +-
.../pipe/event/PipeTabletInsertionEventTest.java | 40 +-
.../extractor/SchemaRegionListeningQueueTest.java | 22 +-
.../pattern/CachedSchemaPatternMatcherTest.java | 30 +-
.../resource/PipeTsFileResourceManagerTest.java | 8 +-
.../common/schematree/ClusterSchemaTreeTest.java | 2 +
.../execution/operator/OperatorMemoryTest.java | 4 +-
.../schema/SchemaFetchScanOperatorTest.java | 16 +-
.../plan/analyze/FakeSchemaFetcherImpl.java | 14 +
.../plan/analyze/QueryTimePartitionTest.java | 33 +-
.../plan/planner/distribution/Util.java | 12 +
.../plan/planner/distribution/Util2.java | 12 +
.../logical/RegionScanLogicalPlannerTest.java | 94 +-
...est.java => DeviceSchemaFetchScanNodeTest.java} | 26 +-
.../metadata/read/SchemaFetchMergeNodeTest.java | 12 +-
...est.java => SeriesSchemaFetchScanNodeTest.java} | 17 +-
.../iotdb/db/storageengine/dataregion/TTLTest.java | 3 +-
.../repair/RepairUnsortedFileCompactionTest.java | 26 +
.../storageengine/dataregion/wal/WALTestUtils.java | 90 ++
.../wal/compression/WALCompressionTest.java | 409 ++++++++
.../dataregion/wal/node/WALNodeTest.java | 4 +
.../wal/recover/WALRecoverManagerTest.java | 4 +
.../wal/recover/WALRecoverWriterTest.java | 14 +-
.../metrics/metricsets/system/SystemMetrics.java | 4 +-
iotdb-core/node-commons/pom.xml | 8 +
.../resources/conf/generate_properties.bat | 3 +-
.../resources/conf/iotdb-system.properties | 44 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 23 +
.../iotdb/commons/client/ClientPoolFactory.java | 58 +-
...a => AsyncConfigNodeInternalServiceClient.java} | 23 +-
...ava => AsyncDataNodeExternalServiceClient.java} | 39 +-
.../container/PipeConsensusClientMgrContainer.java | 2 +-
.../client/request/AsyncRequestContext.java | 138 +++
.../client/request/AsyncRequestManager.java | 192 ++++
.../client/request/AsyncRequestRPCHandler.java} | 49 +-
...nfigNodeInternalServiceAsyncRequestManager.java | 43 +
.../DataNodeInternalServiceRequestManager.java | 43 +
.../apache/iotdb/commons/client/request/Utils.java | 78 ++
.../threadpool/WrappedThreadPoolExecutor.java | 7 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 35 +-
.../iotdb/commons/conf/CommonDescriptor.java | 21 +-
.../iotdb/commons/conf/ConfigurationFileUtils.java | 68 +-
.../enums/PipeRemainingTimeRateAverageTime.java} | 34 +-
.../iotdb/commons/file/SystemFileFactory.java | 4 -
.../commons/file/SystemPropertiesHandler.java | 180 ++++
.../org/apache/iotdb/commons/path/PartialPath.java | 13 +
.../iotdb/commons/path/PathPatternTreeUtils.java | 5 +
.../commons/pipe/agent/task/PipeTaskAgent.java | 45 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 22 +-
.../config/constant/PipeConnectorConstant.java | 1 +
.../config/constant/PipeExtractorConstant.java | 6 +
.../pipe/connector/compressor/PipeCompressor.java | 19 +
.../connector/compressor/PipeGZIPCompressor.java | 7 +
.../connector/compressor/PipeLZ4Compressor.java | 7 +
.../connector/compressor/PipeLZMA2Compressor.java | 7 +
.../connector/compressor/PipeSnappyCompressor.java | 7 +
.../connector/compressor/PipeZSTDCompressor.java | 5 +
.../pipe/connector/limiter/GlobalRateLimiter.java | 43 +-
.../connector/limiter/PipeEndPointRateLimiter.java | 39 +-
.../thrift/request/PipeTransferCompressedReq.java | 36 +-
.../connector/protocol/IoTDBAirGapConnector.java | 38 +-
.../pipe/connector/protocol/IoTDBConnector.java | 15 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 14 +-
.../queue/ConcurrentIterableLinkedQueue.java | 27 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 38 +-
.../commons/pipe/event/PipeSnapshotEvent.java | 8 +-
.../commons/pipe/event/PipeWritePlanEvent.java | 8 +-
.../commons/pipe/event/ProgressReportEvent.java | 12 +-
.../execution/executor/PipeSubtaskExecutor.java | 30 +-
.../extractor/IoTDBNonDataRegionExtractor.java | 11 +-
.../commons/pipe/metric/PipeRemainingOperator.java | 87 ++
.../commons/pipe/pattern/IoTDBPipePattern.java | 4 +-
.../pipe/progress/PipeEventCommitManager.java | 51 +-
.../commons/pipe/progress/PipeEventCommitter.java | 4 +
.../commons/pipe/task/meta/PipeTemporaryMeta.java | 8 +-
.../task/subtask/PipeAbstractConnectorSubtask.java | 42 +-
.../pipe/task/subtask/PipeReportableSubtask.java | 28 +-
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 60 +-
.../iotdb/commons/service/metric/enums/Metric.java | 11 +-
.../meta/consumer/ConsumerGroupMeta.java | 79 +-
.../commons/subscription/meta/topic/TopicMeta.java | 4 +
.../iotdb/commons/utils/TimePartitionUtils.java | 4 +
.../utils/function/CheckedTriConsumer.java} | 16 +-
.../thrift-commons/src/main/thrift/common.thrift | 45 +-
.../src/main/thrift/confignode.thrift | 13 +-
.../thrift-datanode/src/main/thrift/client.thrift | 3 +
.../src/main/thrift/datanode.thrift | 8 +
pom.xml | 1010 +-------------------
518 files changed, 14685 insertions(+), 6689 deletions(-)
rename
integration-test/src/test/java/org/apache/iotdb/db/it/{IOTDBLoadTsFileIT.java
=> IoTDBLoadTsFileIT.java} (65%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBVerifyConnectionIT.java
rename integration-test/src/test/java/org/apache/iotdb/db/it/{ =>
schema}/regionscan/IoTDBActiveRegionScanIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{ =>
schema}/regionscan/IoTDBActiveRegionScanIT2.java (91%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{ =>
schema}/regionscan/IoTDBActiveRegionScanWithModsIT.java (85%)
rename integration-test/src/test/java/org/apache/iotdb/db/it/{ =>
schema}/regionscan/IoTDBActiveRegionScanWithModsIT2.java (91%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/regionscan/IoTDBActiveSchemaQueryIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/AbstractSubscriptionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/SkipOnSetUpFailure.java
rename integration-test/src/test/java/org/apache/iotdb/subscription/it/{local
=> cluster}/IoTDBSubscriptionRestartIT.java (89%)
copy iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/type/Type.java
=>
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/AbstractSubscriptionLocalIT.java
(61%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/DecoratingLock.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/exception/SubscriptionIdentifierSemanticException.java
(52%)
copy iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/type/Type.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/payload/poll/TerminationPayload.java
(63%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/util/IdentifierUtils.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/{ConfigNodeRequestType.java
=> CnToCnNodeRequestType.java} (92%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/{DataNodeRequestType.java
=> CnToDnRequestType.java} (97%)
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncDataNodeClientPool.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToCnInternalServiceAsyncRequestManager.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/CnToDnInternalServiceAsyncRequestManager.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/common/schematree/IMeasurementSchemaInfo.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/ConfigNodeAsyncRequestContext.java}
(52%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/DataNodeAsyncRequestContext.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/ConfigNodeAsyncRequestRPCHandler.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{AsyncTSStatusRPCHandler.java
=> ConfigNodeTSStatusRPCHandler.java} (70%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/{AsyncClientHandler.java
=> rpc/DataNodeAsyncRequestRPCHandler.java} (58%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{AsyncTSStatusRPCHandler.java
=> DataNodeTSStatusRPCHandler.java} (87%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{PipeHeartbeatRPCHandler.java
=> SubmitTestConnectionTaskRPCHandler.java} (59%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/SubmitTestConnectionTaskToConfigNodeRPCHandler.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeRuntimeAgentGuardian.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/conf/ConfigNodeSystemPropertiesHandler.java}
(51%)
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/ConfigNodeRequestType.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeConnector.java}
(71%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/PipeConsensusServerMetrics.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/metric/PipeConsensusSyncLagManager.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/consensus/ConsensusPipeDataNodeRuntimeAgentGuardian.java
=> conf/DataNodeSystemPropertiesHandler.java} (51%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/agent/{PipeAgent.java
=> PipeDataNodeAgent.java} (81%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/handler/PipeConsensusTabletRawEventHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/PipeConsensusConnectorMetrics.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/PipeConsensusReceiverMetrics.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/AsyncTSStatusRPCHandler.java
=>
datanode/src/main/java/org/apache/iotdb/db/protocol/client/cn/AsyncConfigNodeTSStatusRPCHandler.java}
(70%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/cn/ConfigNodeAsyncRequestRPCHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/cn/DnToCnInternalServiceAsyncRequestManager.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/ConfigNodeRequestType.java
=>
datanode/src/main/java/org/apache/iotdb/db/protocol/client/cn/DnToCnRequestType.java}
(71%)
rename
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc
=>
datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn}/AsyncTSStatusRPCHandler.java
(90%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DataNodeAsyncRequestRPCHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DataNodeExternalServiceAsyncRequestManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DataNodeMPPServiceAsyncRequestManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DnToDnInternalServiceAsyncRequestManager.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/ConfigNodeRequestType.java
=>
datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/DnToDnRequestType.java}
(71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/DeviceContext.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/{TimeseriesSchemaInfo.java
=> TimeseriesContext.java} (76%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/{SeriesScanOperator.java
=> AbstractSeriesScanOperator.java} (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/metric/load/LoadTsFileCostMetricsSet.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/metric/{ =>
load}/LoadTsFileMemMetricSet.java (98%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/TestConnectionTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/DeviceSchemaFetchScanNode.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metedata/read/{SchemaFetchScanNode.java
=> SeriesSchemaFetchScanNode.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/internal/{SchemaFetchStatement.java
=> DeviceSchemaFetchStatement.java} (67%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/internal/{SchemaFetchStatement.java
=> SeriesSchemaFetchStatement.java} (80%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/{metadata/ShowTTLStatement.java
=> sys/TestConnectionStatement.java} (65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/io/WALInputStream.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/metadata/read/{SchemaFetchScanNodeTest.java
=> DeviceSchemaFetchScanNodeTest.java} (75%)
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/metadata/read/{SchemaFetchScanNodeTest.java
=> SeriesSchemaFetchScanNodeTest.java} (83%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/WALTestUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/wal/compression/WALCompressionTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/async/{AsyncConfigNodeIServiceClient.java
=> AsyncConfigNodeInternalServiceClient.java} (83%)
rename
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/async/{AsyncConfigNodeIServiceClient.java
=> AsyncDataNodeExternalServiceClient.java} (75%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/request/AsyncRequestContext.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/request/AsyncRequestManager.java
rename
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/AbstractAsyncRPCHandler.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/client/request/AsyncRequestRPCHandler.java}
(56%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/request/ConfigNodeInternalServiceAsyncRequestManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/request/DataNodeInternalServiceRequestManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/request/Utils.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/execution/PipeConnectorSubtaskExecutor.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/enums/PipeRemainingTimeRateAverageTime.java}
(52%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/file/SystemPropertiesHandler.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/metric/PipeRemainingOperator.java
rename
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/client/ConfigNodeRequestType.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/utils/function/CheckedTriConsumer.java}
(71%)
