This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/TableModel
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from a7f827b33fd perfect PredicatePushDown optimize rule
add b231a1c7076 Remove duplicate point calculate because of consensus and
so on (#12459)
add d65543db668 Pipe: Reduce pipe logs generated by PipeEventCommitter
(#12616)
add 0974ee900b6 Reduce CI max-parallel (#12620)
add be643c08f50 Pipe: Removed useless PipeSetTTLPlan (#12619)
add 91b8f40b63b Forbid auto create database when disable auto create
schema (#12590)
add 36c7e09118c Pipe: Fix leader change is not handled correctly in auto
drop determination (#12617)
add a4a7be0e100 Fix restAPi return null message when meets multiple error
(#12621)
add 9b2efea9a2f Merge config files to iotdb-system.properties (#12570)
add 0a9b05b211f Subscription: shared thread pool between consumers in one
process (#12606)
add d9207b9a0e7 Update properties (#12625)
add 6ebaa435963 Generate compaction target file with tier level (#12597)
add fe35c8f6d42 Make UDTF execution framework batch processing (#12562)
add f460ef89032 Support special path for device TTL
add 4ff9c8373fe Revert auto create STRING type inference
add 52affcff02f load-tsfile script: optimization for loading tsfiles in
dir and error handling (#12541)
add 9d9f9460b4a Procedure: Fix thread-unsafe between procedure enqueue and
dequeue (#12629)
add db268afc910 Add datatype check for restapi insertRecords and fix query
bug (#12631)
add d83632d2cd4 fix scripts after merge config file (#12628)
add 7a2419ce1f1 Fix compaction metric and read device MetadataIndexNode
add 9000bad2a65 PipeConsensus: complete consensus prodedure and pipe
components with new thrift service (#12355)
add f28f1fd3787 JDBC: Support different charsets (#12632)
add 3d3fd86b16c [IOTDB-6325] Support RegionScan for active metadata
queries [BE Part Two]
add 8a6e31ffe5a add import-schema.sh/bat and export-schema.sh/bat in
cli/tools (#12623)
add 78660628e75 load-tsfile script:Addition of statistical information
(#12634)
add 7310a50c30a load-tsfile script: remove unnecessary logs (#12635)
add 76a8d6ca12a Change schema_region_total_device_cnt label to
SCHEMA_ENGINE (#12636)
add 28cd29c930e Remove unknown and vector in udf-api Type
add 54e566c2af2 resolve conflicts
add 48874801fc7 resolve conflicts
add b82b202a862 fix IT
add 3edd29ee010 change back cpp tablet.deviceId
add 036e1dc0083 change back cpp tablet.deviceId
add 1fb401a3a81 fix conflict in iotdb-system.properties
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 2 +-
.github/workflows/multi-language-client.yml | 7 +-
.github/workflows/pipe-it-2cluster.yml | 6 +-
.github/workflows/unit-test.yml | 2 +-
docker/src/main/DockerCompose/entrypoint.sh | 2 +-
.../main/DockerCompose/replace-conf-from-env.sh | 13 +-
docker/src/main/Dockerfile-1c1d | 14 +-
.../java/org/apache/iotdb/JDBCCharsetExample.java | 99 ++
.../apache/iotdb/SubscriptionSessionExample.java | 2 +-
.../iotdb/it/env/cluster/ClusterConstant.java | 4 +
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 18 +
.../iotdb/it/env/cluster/config/MppBaseConfig.java | 2 +-
.../it/env/cluster/node/AbstractNodeWrapper.java | 8 +-
.../it/env/cluster/node/ConfigNodeWrapper.java | 12 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 12 +-
.../db/it/regionscan/IoTDBActiveRegionScanIT.java | 480 ++++++++
.../db/it/regionscan/IoTDBActiveRegionScanIT2.java | 52 +
.../IoTDBActiveRegionScanWithModsIT.java | 188 +++
.../IoTDBActiveRegionScanWithModsIT2.java | 52 +
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 16 +-
.../it/schema/IoTDBDisableAutoCreateSchemaIT.java | 74 ++
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 33 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 2 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 6 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 3 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 11 +-
.../it/local/IoTDBSubscriptionIdempotentIT.java | 2 +-
.../it/local/IoTDBSubscriptionRestartIT.java | 2 +-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 149 +++
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 126 ++
.../main/java/org/apache/iotdb/udf/api/UDTF.java | 5 +
.../java/org/apache/iotdb/udf/api/access/Row.java | 2 +-
.../java/org/apache/iotdb/udf/api/type/Type.java | 7 +-
.../org/apache/iotdb/udf/api/utils/RowImpl.java | 4 +-
.../cli/src/assembly/resources/tools/backup.bat | 14 +-
.../cli/src/assembly/resources/tools/backup.sh | 7 +-
.../src/assembly/resources/tools/collect-info.bat | 6 +-
.../src/assembly/resources/tools/collect-info.sh | 6 +-
.../tools/{load-tsfile.bat => export-schema.bat} | 67 +-
.../src/assembly/resources/tools/export-schema.sh | 57 +
.../tools/{load-tsfile.bat => import-schema.bat} | 66 +-
.../src/assembly/resources/tools/import-schema.sh | 57 +
.../src/assembly/resources/tools/load-tsfile.bat | 67 +-
.../src/assembly/resources/tools/load-tsfile.sh | 80 +-
.../org/apache/iotdb/tool/AbstractSchemaTool.java | 242 ++++
.../org/apache/iotdb/tool/AbstractTsFileTool.java | 59 +-
.../java/org/apache/iotdb/tool/ExportSchema.java | 339 ++++++
.../java/org/apache/iotdb/tool/ExportTsFile.java | 11 +-
.../java/org/apache/iotdb/tool/ImportSchema.java | 653 ++++++++++
.../java/org/apache/iotdb/tool/ImportTsFile.java | 554 +++++++++
.../org/apache/iotdb/tool/IoTDBDataBackTool.java | 39 +-
iotdb-client/client-cpp/src/main/Session.cpp | 4 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 3 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 10 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 12 +
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 60 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 16 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 91 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 16 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 8 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 8 +
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 19 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 8 +
.../rpc/subscription/config/ConsumerConstant.java | 32 +-
.../subscription/{ => consumer}/AckStrategy.java | 2 +-
.../{ => consumer}/AsyncCommitCallback.java | 2 +-
.../{ => consumer}/ConsumeListener.java | 2 +-
.../subscription/{ => consumer}/ConsumeResult.java | 2 +-
.../{ => consumer}/SubscriptionConsumer.java | 376 +++---
.../SubscriptionExecutorServiceManager.java | 281 +++++
.../{ => consumer}/SubscriptionProvider.java | 4 +-
.../{ => consumer}/SubscriptionProviders.java | 21 +-
.../{ => consumer}/SubscriptionPullConsumer.java | 160 +--
.../{ => consumer}/SubscriptionPushConsumer.java | 249 ++--
iotdb-core/confignode/src/assembly/confignode.xml | 4 +-
.../resources/conf/iotdb-confignode.properties | 147 ---
.../assembly/resources/sbin/start-confignode.bat | 30 +-
.../assembly/resources/sbin/stop-confignode.bat | 10 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 8 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 34 -
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 -
.../confignode/conf/ConfigNodeDescriptor.java | 73 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 12 +
.../consensus/request/ConfigPhysicalPlan.java | 4 -
.../request/write/pipe/payload/PipeSetTTLPlan.java | 103 --
.../iotdb/confignode/manager/TTLManager.java | 7 +-
.../manager/load/balancer/RouteBalancer.java | 9 +-
.../manager/node/ClusterNodeStartUtils.java | 23 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 7 +-
.../extractor/ConfigRegionListeningFilter.java | 4 +-
.../PipeConfigPhysicalPlanPatternParseVisitor.java | 11 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 9 -
.../persistence/executor/ConfigPlanExecutor.java | 5 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 7 +
.../impl/pipe/task/CreatePipeProcedureV2.java | 79 +-
.../scheduler/SimpleProcedureScheduler.java | 7 +-
.../iotdb/confignode/service/ConfigNode.java | 3 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 11 -
...eConfigPhysicalPlanPatternParseVisitorTest.java | 26 +-
.../confignode1conf/iotdb-confignode.properties | 31 -
...b-common.properties => iotdb-system.properties} | 14 +
.../confignode2conf/iotdb-confignode.properties | 31 -
...b-common.properties => iotdb-system.properties} | 13 +
.../confignode3conf/iotdb-confignode.properties | 31 -
...b-common.properties => iotdb-system.properties} | 13 +
iotdb-core/consensus/pom.xml | 9 +-
.../apache/iotdb/consensus/ConsensusFactory.java | 22 +
.../common/request/IConsensusRequest.java | 4 +
.../iotdb/consensus/config/ConsensusConfig.java | 19 +-
.../consensus/config/PipeConsensusConfig.java | 358 ++++++
.../apache/iotdb/consensus/iot/IoTConsensus.java | 1 +
.../consensus/iot/IoTConsensusServerImpl.java | 1 +
.../iot/client/AsyncIoTConsensusServiceClient.java | 2 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 465 ++++++++
.../consensus/pipe/PipeConsensusPeerManager.java | 154 +++
.../consensus/pipe/PipeConsensusServerImpl.java | 543 +++++++++
.../consensuspipe/ConsensusPipeDispatcher.java} | 31 +-
.../pipe/consensuspipe/ConsensusPipeGuardian.java | 9 +-
.../pipe/consensuspipe/ConsensusPipeManager.java | 108 ++
.../pipe/consensuspipe/ConsensusPipeName.java | 98 ++
.../pipe/consensuspipe/ConsensusPipeReceiver.java | 12 +-
.../pipe/consensuspipe/ConsensusPipeSelector.java | 11 +-
.../pipe/consensuspipe/ProgressIndexManager.java} | 22 +-
.../pipe/service/PipeConsensusRPCService.java | 97 ++
.../service/PipeConsensusRPCServiceHandler.java} | 37 +-
.../pipe/service/PipeConsensusRPCServiceMBean.java | 7 +-
.../service/PipeConsensusRPCServiceProcessor.java | 210 ++++
.../ratis/ApplicationStateMachineProxy.java | 3 +
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +-
iotdb-core/datanode/pom.xml | 5 +
.../resources/conf/iotdb-datanode.properties | 316 -----
.../src/assembly/resources/sbin/start-datanode.bat | 48 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 10 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 7 +-
iotdb-core/datanode/src/assembly/server.xml | 4 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 68 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 105 +-
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 2 -
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 9 +-
.../db/consensus/DataRegionConsensusImpl.java | 38 +
.../IoTConsensusDataRegionStateMachine.java | 3 +-
.../metadata/DataTypeMismatchException.java | 13 +
.../PipeDataRegionConnectorConstructor.java | 7 +
.../PipeDataRegionProcessorConstructor.java | 4 +
.../agent/receiver/PipeDataNodeReceiverAgent.java | 13 +
.../agent/runtime/PipeDataNodeRuntimeAgent.java | 32 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 47 +
.../pipeconsensus/PipeConsensusAsyncConnector.java | 524 +++++++++
.../pipeconsensus/PipeConsensusSyncConnector.java | 455 +++++++
.../PipeConsensusTabletBatchEventHandler.java | 128 ++
.../PipeConsensusTabletInsertNodeEventHandler.java | 45 +
.../PipeConsensusTabletInsertionEventHandler.java | 109 ++
.../PipeConsensusTabletRawEventHandler.java | 45 +
.../PipeConsensusTsFileInsertionEventHandler.java | 279 +++++
.../PipeConsensusAsyncBatchReqBuilder.java} | 20 +-
.../builder/PipeConsensusSyncBatchReqBuilder.java | 45 +
.../PipeConsensusTransferBatchReqBuilder.java | 218 ++++
.../request/PipeConsensusTabletBatchReq.java | 83 ++
.../request/PipeConsensusTabletBinaryReq.java | 126 ++
.../request/PipeConsensusTabletInsertNodeReq.java | 154 +++
.../request/PipeConsensusTsFilePieceReq.java | 79 ++
.../PipeConsensusTsFilePieceWithModReq.java | 80 ++
.../request/PipeConsensusTsFileSealReq.java | 74 ++
.../request/PipeConsensusTsFileSealWithModReq.java | 85 ++
.../consensus/ConsensusPipeDataNodeDispatcher.java | 121 ++
.../ConsensusPipeDataNodeRuntimeAgentGuardian.java | 48 +
.../consensus/PipeConsensusSubtaskExecutor.java} | 25 +-
.../consensus/ProgressIndexDataNodeManager.java | 128 ++
.../pipe/execution/PipeSubtaskExecutorManager.java | 7 +
.../pipeconsensus/PipeConsensusProcessor.java | 103 ++
...igner.java => SimpleProgressIndexAssigner.java} | 11 +-
.../pipeconsensus/PipeConsensusReceiver.java | 1244 ++++++++++++++++++++
.../pipeconsensus/PipeConsensusReceiverAgent.java | 169 +++
.../pipe/task/builder/PipeDataNodeTaskBuilder.java | 2 +
.../pipe/task/connection/PipeEventCollector.java | 4 +
.../db/protocol/rest/utils/InsertRowDataUtils.java | 20 +-
.../v2/handler/StatementConstructionHandler.java | 27 +-
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 86 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 7 +-
.../queryengine/common/TimeseriesSchemaInfo.java | 54 +-
.../execution/driver/DataDriverContext.java | 30 +
.../fragment/FragmentInstanceContext.java | 10 +
.../process/ActiveRegionScanMergeOperator.java | 288 +++++
.../operator/process/TransformOperator.java | 127 +-
.../AbstractRegionScanDataSourceOperator.java | 141 +++
.../AbstractRegionScanForActiveDataUtil.java | 199 ++++
.../source/ActiveDeviceRegionScanOperator.java | 102 ++
.../source/ActiveTimeSeriesRegionScanOperator.java | 142 +++
.../source/RegionScanForActiveDeviceUtil.java | 173 +++
.../source/RegionScanForActiveTimeSeriesUtil.java | 172 +++
.../queryengine/plan/analyze/AnalyzeVisitor.java | 7 +-
.../plan/analyze/ClusterPartitionFetcher.java | 3 +-
.../analyze/cache/schema/DataNodeTTLCache.java | 36 +-
.../config/executor/ClusterConfigTaskExecutor.java | 3 +-
.../multi/builtin/BuiltInScalarFunctionHelper.java | 6 +-
.../multi/builtin/helper/CastFunctionHelper.java | 6 +-
.../multi/builtin/helper/DiffFunctionHelper.java | 6 +-
.../builtin/helper/ReplaceFunctionHelper.java | 6 +-
.../multi/builtin/helper/RoundFunctionHelper.java | 6 +-
.../builtin/helper/SubStringFunctionHelper.java | 6 +-
.../visitor/IntermediateLayerVisitor.java | 146 ++-
.../plan/planner/LocalExecutionPlanner.java | 17 +
.../plan/planner/OperatorTreeGenerator.java | 152 ++-
.../planner/distribution/ExchangeNodeAdder.java | 4 +-
.../plan/planner/distribution/SourceRewriter.java | 9 +-
.../plan/planner/plan/node/PlanNode.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 4 +-
.../plan/planner/plan/node/PlanVisitor.java | 4 +-
...rgeNode.java => ActiveRegionScanMergeNode.java} | 52 +-
.../plan/node/source/DeviceRegionScanNode.java | 8 +-
.../planner/plan/node/source/RegionScanNode.java | 2 +
.../plan/node/source/TimeseriesRegionScanNode.java | 70 +-
.../plan/node/write/InsertMultiTabletsNode.java | 6 +
.../planner/plan/node/write/InsertRowsNode.java | 6 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 6 +
.../plan/scheduler/load/LoadTsFileScheduler.java | 14 +
.../statement/metadata/ShowDatabaseStatement.java | 4 +-
.../transformation/api/LayerPointReader.java | 54 -
.../api/{LayerRowReader.java => LayerReader.java} | 20 +-
.../transformation/api/LayerRowWindowReader.java | 3 -
...izableRowRecordListBackedMultiColumnWindow.java | 6 +-
...wRecordListBackedMultiColumnWindowIterator.java | 6 +-
...ticSerializableTVListBackedSingleColumnRow.java | 2 +-
.../LayerPointReaderBackedSingleColumnRow.java | 99 --
.../dag/adapter/PointCollectorAdaptor.java | 97 ++
.../dag/builder/EvaluationDAGBuilder.java | 12 +-
.../dag/input/ConstantInputReader.java | 114 +-
.../transformation/dag/input/IUDFInputDataSet.java | 21 +-
.../dag/input/QueryDataSetInputLayer.java | 294 +----
.../dag/input/TsBlockInputDataSet.java | 37 +-
.../intermediate/ConstantIntermediateLayer.java | 17 +-
.../dag/intermediate/IntermediateLayer.java | 7 +-
.../MultiInputColumnIntermediateLayer.java | 797 -------------
.../dag/intermediate/MultiInputLayer.java | 666 +++++++++++
...InputColumnMultiReferenceIntermediateLayer.java | 797 -------------
...nputColumnSingleReferenceIntermediateLayer.java | 668 -----------
.../SingleInputMultiReferenceLayer.java | 724 ++++++++++++
.../SingleInputSingleReferenceLayer.java | 648 ++++++++++
.../transformation/dag/memory/SafetyLine.java | 4 +
.../dag/transformer/Transformer.java | 102 +-
.../binary/ArithmeticAdditionTransformer.java | 7 +-
.../binary/ArithmeticBinaryTransformer.java | 31 +-
.../binary/ArithmeticDivisionTransformer.java | 7 +-
.../binary/ArithmeticModuloTransformer.java | 7 +-
.../ArithmeticMultiplicationTransformer.java | 7 +-
.../binary/ArithmeticSubtractionTransformer.java | 7 +-
.../dag/transformer/binary/BinaryTransformer.java | 273 +++--
.../binary/CompareBinaryTransformer.java | 33 +-
.../binary/CompareEqualToTransformer.java | 22 +-
.../binary/CompareGreaterEqualTransformer.java | 22 +-
.../binary/CompareGreaterThanTransformer.java | 21 +-
.../binary/CompareLessEqualTransformer.java | 22 +-
.../binary/CompareLessThanTransformer.java | 21 +-
.../binary/CompareNonEqualTransformer.java | 21 +-
.../transformer/binary/LogicAndTransformer.java | 6 +-
.../transformer/binary/LogicBinaryTransformer.java | 259 ++--
.../dag/transformer/binary/LogicOrTransformer.java | 6 +-
.../multi/MappableUDFQueryRowTransformer.java | 102 +-
.../transformer/multi/UDFQueryRowTransformer.java | 44 +-
.../multi/UDFQueryRowWindowTransformer.java | 21 +-
.../dag/transformer/multi/UDFQueryTransformer.java | 12 +-
.../multi/UniversalUDFQueryTransformer.java | 73 +-
.../transformer/ternary/BetweenTransformer.java | 41 +-
.../ternary/CompareTernaryTransformer.java | 55 +-
.../transformer/ternary/TernaryTransformer.java | 342 +++---
.../unary/ArithmeticNegationTransformer.java | 92 +-
.../dag/transformer/unary/InTransformer.java | 144 ++-
.../dag/transformer/unary/IsNullTransformer.java | 39 +-
.../dag/transformer/unary/LogicNotTransformer.java | 32 +-
.../dag/transformer/unary/RegularTransformer.java | 35 +-
.../transformer/unary/TransparentTransformer.java | 37 +-
.../dag/transformer/unary/UnaryTransformer.java | 70 +-
.../unary/scalar/CastFunctionTransformer.java | 493 ++++++--
.../unary/scalar/DiffFunctionTransformer.java | 159 ++-
.../unary/scalar/ReplaceFunctionTransformer.java | 42 +-
.../unary/scalar/RoundFunctionTransformer.java | 94 +-
.../unary/scalar/SubStringFunctionTransformer.java | 53 +-
.../transformation/dag/udf/UDTFExecutor.java | 153 ++-
.../transformation/dag/util/LayerCacheUtils.java | 189 +--
.../transformation/dag/util/TransformUtils.java | 46 +-
.../transformation/dag/util/TypeUtils.java | 79 ++
.../transformation/datastructure/TVColumns.java | 74 ++
.../iterator/ListForwardIterator.java | 14 +-
.../iterator/RowListForwardIterator.java | 100 ++
.../iterator/TVListForwardIterator.java | 109 ++
.../row/ElasticSerializableRowList.java | 485 ++++++++
.../row/ElasticSerializableRowRecordList.java | 314 -----
.../datastructure/row/SerializableRowList.java | 373 ++++++
.../row/SerializableRowRecordList.java | 254 ----
.../tv/ElasticSerializableBinaryTVList.java | 160 ++-
.../tv/ElasticSerializableTVList.java | 364 +++---
.../tv/SerializableBooleanTVList.java | 75 --
.../datastructure/tv/SerializableDoubleTVList.java | 75 --
.../datastructure/tv/SerializableFloatTVList.java | 75 --
.../datastructure/tv/SerializableIntTVList.java | 73 --
.../datastructure/tv/SerializableLongTVList.java | 75 --
.../datastructure/tv/SerializableTVList.java | 383 +++++-
.../BinaryUtils.java} | 47 +-
.../schemaengine/metric/SchemaEngineMemMetric.java | 4 +-
.../schemaengine/schemaregion/tag/TagLogFile.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 3 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 28 +-
.../db/service/metrics/CompactionMetrics.java | 2 +-
.../iotdb/db/storageengine/StorageEngine.java | 21 +-
.../impl/ReadChunkCompactionPerformer.java | 2 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 45 +-
.../compaction/io/CompactionTsFileReader.java | 119 +-
.../compaction/repair/RepairDataFileScanUtil.java | 45 +-
.../dataregion/memtable/AbstractMemTable.java | 129 +-
.../dataregion/memtable/TsFileProcessor.java | 93 +-
.../read/QueryDataSourceForRegionScan.java | 38 +-
.../dataregion/read/filescan/IChunkHandle.java | 13 +-
.../dataregion/read/filescan/IFileScanHandle.java | 15 +-
.../filescan/impl/ClosedFileScanHandleImpl.java | 48 +-
.../filescan/impl/DiskAlignedChunkHandleImpl.java | 15 +-
.../read/filescan/impl/DiskChunkHandleImpl.java | 51 +-
.../filescan/impl/MemAlignedChunkHandleImpl.java | 17 +-
.../read/filescan/impl/MemChunkHandleImpl.java | 25 +-
.../filescan/impl/UnclosedFileScanHandleImpl.java | 76 +-
.../read/filescan/model/AbstractChunkOffset.java | 16 +-
.../model/AbstractDeviceChunkMetaData.java | 8 +-
.../read/filescan/model/AlignedChunkOffset.java | 19 +-
.../filescan/model/AlignedDeviceChunkMetaData.java | 48 +-
.../read/filescan/model/ChunkOffset.java | 12 +-
.../read/filescan/model/DeviceChunkMetaData.java | 20 +-
.../tsfile/generator/TsFileNameGenerator.java | 15 +-
.../dataregion/utils/SharedTimeDataBuffer.java | 10 +-
.../dataregion/utils/TsFileResourceUtils.java | 6 +-
.../event/SubscriptionEventBinaryCache.java | 2 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 12 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 13 -
.../schema/SchemaQueryScanOperatorTest.java | 1 +
.../distribution/RegionScanPlanningTest.java | 19 +-
.../logical/RegionScanLogicalPlannerTest.java | 52 +-
.../builder/EvaluationDAGBuilderTest.java | 4 +-
.../ElasticSerializableRowListTest.java | 415 +++++++
.../ElasticSerializableRowRecordListTest.java | 294 -----
.../ElasticSerializableTVListTest.java | 352 ++----
.../SerializableBinaryTVListTest.java | 87 --
.../SerializableBooleanTVListTest.java | 85 --
.../SerializableDoubleTVListTest.java | 84 --
.../datastructure/SerializableFloatTVListTest.java | 84 --
.../datastructure/SerializableIntTVListTest.java | 84 --
.../datastructure/SerializableLongTVListTest.java | 84 --
...dListTest.java => SerializableRowListTest.java} | 119 +-
.../datastructure/SerializableTVListTest.java | 452 ++++++-
.../TsFileValidationCorrectnessTests.java | 28 +
.../inner/InnerSequenceCompactionSpeedTest.java | 126 ++
.../settle/SettleCompactionTaskTest.java | 44 +-
.../compaction/utils/CompactionConfigRestorer.java | 2 -
.../utils/MultiTsFileDeviceIteratorTest.java | 3 +-
.../rescon/memory/ResourceManagerTest.java | 2 +-
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 2 +-
.../datanode1conf/iotdb-common.properties | 22 -
...datanode.properties => iotdb-system.properties} | 7 +-
.../datanode2conf/iotdb-common.properties | 22 -
...datanode.properties => iotdb-system.properties} | 5 +
.../datanode3conf/iotdb-common.properties | 22 -
...datanode.properties => iotdb-system.properties} | 7 +-
.../src/test/resources/iotdb-system.properties | 76 ++
.../metrics/config/MetricConfigDescriptor.java | 73 +-
.../iotdb/metrics/config/MetricConfigTest.java | 4 +-
iotdb-core/node-commons/pom.xml | 5 +
...b-common.properties => iotdb-system.properties} | 748 +++++++++++-
.../assembly/resources/sbin/destroy-confignode.bat | 6 +-
.../assembly/resources/sbin/destroy-confignode.sh | 7 +-
.../assembly/resources/sbin/destroy-datanode.bat | 40 +-
.../assembly/resources/sbin/destroy-datanode.sh | 10 +-
.../src/assembly/resources/sbin/health_check.bat | 76 +-
.../src/assembly/resources/sbin/health_check.sh | 7 +-
.../src/assembly/resources/sbin/iotdb-common.sh | 26 +-
.../iotdb/commons/client/ClientPoolFactory.java | 72 ++
.../async/AsyncPipeConsensusServiceClient.java} | 57 +-
.../container/PipeConsensusClientMgrContainer.java | 91 ++
.../property/PipeConsensusClientProperty.java | 99 ++
.../sync/SyncPipeConsensusServiceClient.java | 139 +++
.../iotdb/commons/concurrent/ThreadName.java | 14 +
.../apache/iotdb/commons/conf/CommonConfig.java | 7 +-
.../commons/conf/ConfigFileAutoUpdateTool.java | 126 ++
.../iotdb/commons/consensus/ConsensusGroupId.java | 29 +
.../consensus/index/impl/HybridProgressIndex.java | 4 +
.../consensus/index/impl/RecoverProgressIndex.java | 4 +
.../org/apache/iotdb/commons/path/AlignedPath.java | 5 +-
.../apache/iotdb/commons/path/MeasurementPath.java | 3 +
.../config/constant/PipeConnectorConstant.java | 2 +
.../config/constant/PipeExtractorConstant.java | 7 +
.../request/PipeConsensusRequestType.java | 67 ++
.../request/PipeConsensusRequestVersion.java | 17 +-
.../request/PipeConsensusTransferFilePieceReq.java | 139 +++
.../request/PipeConsensusTransferFileSealReq.java | 138 +++
.../PipeConsensusTransferFileSealWithModReq.java | 177 +++
.../PipeConsensusTransferFilePieceResp.java | 110 ++
.../iotdb/commons/pipe/event/EnrichedEvent.java | 27 +
.../pipe/plugin/builtin/BuiltinPipePlugin.java | 7 +
.../consensus/PipeConsensusAsyncConnector.java} | 31 +-
.../pipeconsensus/PipeConsensusProcessor.java} | 31 +-
.../commons/pipe/progress/PipeEventCommitter.java | 44 +-
.../commons/pipe/task/meta/PipeStaticMeta.java | 1 +
.../commons/pipe/task/meta/PipeTemporaryMeta.java | 4 +
.../iotdb/commons/pipe/task/meta/PipeType.java | 3 +
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 1 +
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../meta/consumer/ConsumerGroupMetaKeeper.java | 2 +-
.../subscription/meta/consumer/ConsumerMeta.java | 2 +-
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 2 +-
.../commons/udf/utils/UDFDataTypeTransformer.java | 12 -
.../src/main/thrift/pipeconsensus.thrift | 109 ++
.../iotdb/library/series/util/ConsecutiveUtil.java | 2 +-
409 files changed, 23472 insertions(+), 9575 deletions(-)
create mode 100644
example/jdbc/src/main/java/org/apache/iotdb/JDBCCharsetExample.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/regionscan/IoTDBActiveRegionScanIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/regionscan/IoTDBActiveRegionScanIT2.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/regionscan/IoTDBActiveRegionScanWithModsIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/regionscan/IoTDBActiveRegionScanWithModsIT2.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBDisableAutoCreateSchemaIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/tools/it/ExportSchemaTestIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/tools/it/ImportSchemaTestIT.java
copy iotdb-client/cli/src/assembly/resources/tools/{load-tsfile.bat =>
export-schema.bat} (50%)
create mode 100644
iotdb-client/cli/src/assembly/resources/tools/export-schema.sh
copy iotdb-client/cli/src/assembly/resources/tools/{load-tsfile.bat =>
import-schema.bat} (50%)
create mode 100644
iotdb-client/cli/src/assembly/resources/tools/import-schema.sh
mode change 100644 => 100755
iotdb-client/cli/src/assembly/resources/tools/load-tsfile.bat
mode change 100644 => 100755
iotdb-client/cli/src/assembly/resources/tools/load-tsfile.sh
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/AbstractSchemaTool.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ExportSchema.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ImportSchema.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/ImportTsFile.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/AckStrategy.java (94%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/AsyncCommitCallback.java (94%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/ConsumeListener.java (94%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/ConsumeResult.java (93%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/SubscriptionConsumer.java (83%)
create mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/SubscriptionExecutorServiceManager.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/SubscriptionProvider.java (98%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/SubscriptionProviders.java (94%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/SubscriptionPullConsumer.java (79%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/{ =>
consumer}/SubscriptionPushConsumer.java (57%)
delete mode 100644
iotdb-core/confignode/src/assembly/resources/conf/iotdb-confignode.properties
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeSetTTLPlan.java
delete mode 100644
iotdb-core/confignode/src/test/resources/confignode1conf/iotdb-confignode.properties
rename
iotdb-core/confignode/src/test/resources/confignode1conf/{iotdb-common.properties
=> iotdb-system.properties} (73%)
delete mode 100644
iotdb-core/confignode/src/test/resources/confignode2conf/iotdb-confignode.properties
rename
iotdb-core/confignode/src/test/resources/confignode2conf/{iotdb-common.properties
=> iotdb-system.properties} (73%)
delete mode 100644
iotdb-core/confignode/src/test/resources/confignode3conf/iotdb-confignode.properties
rename
iotdb-core/confignode/src/test/resources/confignode3conf/{iotdb-common.properties
=> iotdb-system.properties} (73%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/config/PipeConsensusConfig.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensus.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusPeerManager.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/PipeConsensusServerImpl.java
copy
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/{common/request/IConsensusRequest.java
=> pipe/consensuspipe/ConsensusPipeDispatcher.java} (57%)
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ConsumeResult.java
=>
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeGuardian.java
(81%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeManager.java
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeName.java
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ConsumeListener.java
=>
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeReceiver.java
(68%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ConsumeListener.java
=>
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ConsensusPipeSelector.java
(77%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeType.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/pipe/consensuspipe/ProgressIndexManager.java}
(64%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/PipeConsensusRPCService.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/filescan/impl/MemChunkHandleImpl.java
=>
consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/PipeConsensusRPCServiceHandler.java}
(50%)
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/ConsumeResult.java
=>
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/PipeConsensusRPCServiceMBean.java
(89%)
create mode 100644
iotdb-core/consensus/src/main/java/org/apache/iotdb/consensus/pipe/service/PipeConsensusRPCServiceProcessor.java
delete mode 100644
iotdb-core/datanode/src/assembly/resources/conf/iotdb-datanode.properties
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusAsyncConnector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/PipeConsensusSyncConnector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/handler/PipeConsensusTabletBatchEventHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/handler/PipeConsensusTabletInsertNodeEventHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/handler/PipeConsensusTabletInsertionEventHandler.java
create 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/connector/protocol/pipeconsensus/handler/PipeConsensusTsFileInsertionEventHandler.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/transformation/dag/transformer/binary/ArithmeticAdditionTransformer.java
=>
pipe/connector/protocol/pipeconsensus/payload/builder/PipeConsensusAsyncBatchReqBuilder.java}
(56%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/builder/PipeConsensusSyncBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/builder/PipeConsensusTransferBatchReqBuilder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusTabletBatchReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusTabletBinaryReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusTabletInsertNodeReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusTsFilePieceReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusTsFilePieceWithModReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusTsFileSealReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/pipeconsensus/payload/request/PipeConsensusTsFileSealWithModReq.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeDispatcher.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ConsensusPipeDataNodeRuntimeAgentGuardian.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/task/meta/PipeType.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/PipeConsensusSubtaskExecutor.java}
(63%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/consensus/ProgressIndexDataNodeManager.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/processor/pipeconsensus/PipeConsensusProcessor.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/progress/{SimpleConsensusProgressIndexAssigner.java
=> SimpleProgressIndexAssigner.java} (91%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiver.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/receiver/protocol/pipeconsensus/PipeConsensusReceiverAgent.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/ActiveRegionScanMergeOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/AbstractRegionScanDataSourceOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/AbstractRegionScanForActiveDataUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/ActiveDeviceRegionScanOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/ActiveTimeSeriesRegionScanOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/RegionScanForActiveDeviceUtil.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/RegionScanForActiveTimeSeriesUtil.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/{RegionMergeNode.java
=> ActiveRegionScanMergeNode.java} (70%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/api/LayerPointReader.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/api/{LayerRowReader.java
=> LayerReader.java} (71%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/adapter/LayerPointReaderBackedSingleColumnRow.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/adapter/PointCollectorAdaptor.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/intermediate/MultiInputColumnIntermediateLayer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/intermediate/MultiInputLayer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/intermediate/SingleInputColumnMultiReferenceIntermediateLayer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/intermediate/SingleInputColumnSingleReferenceIntermediateLayer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/intermediate/SingleInputMultiReferenceLayer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/intermediate/SingleInputSingleReferenceLayer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/util/TypeUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/TVColumns.java
copy
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/AsyncCommitCallback.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/iterator/ListForwardIterator.java
(78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/iterator/RowListForwardIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/iterator/TVListForwardIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/row/ElasticSerializableRowList.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/row/ElasticSerializableRowRecordList.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/row/SerializableRowList.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/row/SerializableRowRecordList.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/tv/SerializableBooleanTVList.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/tv/SerializableDoubleTVList.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/tv/SerializableFloatTVList.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/tv/SerializableIntTVList.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/tv/SerializableLongTVList.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/datastructure/{tv/SerializableBinaryTVList.java
=> util/BinaryUtils.java} (51%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/ElasticSerializableRowListTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/ElasticSerializableRowRecordListTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/SerializableBinaryTVListTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/SerializableBooleanTVListTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/SerializableDoubleTVListTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/SerializableFloatTVListTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/SerializableIntTVListTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/SerializableLongTVListTest.java
rename
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/datastructure/{SerializableRowRecordListTest.java
=> SerializableRowListTest.java} (57%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/InnerSequenceCompactionSpeedTest.java
delete mode 100644
iotdb-core/datanode/src/test/resources/datanode1conf/iotdb-common.properties
rename
iotdb-core/datanode/src/test/resources/datanode1conf/{iotdb-datanode.properties
=> iotdb-system.properties} (88%)
delete mode 100644
iotdb-core/datanode/src/test/resources/datanode2conf/iotdb-common.properties
rename
iotdb-core/datanode/src/test/resources/datanode2conf/{iotdb-datanode.properties
=> iotdb-system.properties} (90%)
delete mode 100644
iotdb-core/datanode/src/test/resources/datanode3conf/iotdb-common.properties
rename
iotdb-core/datanode/src/test/resources/datanode3conf/{iotdb-datanode.properties
=> iotdb-system.properties} (88%)
create mode 100644
iotdb-core/datanode/src/test/resources/iotdb-system.properties
rename
iotdb-core/node-commons/src/assembly/resources/conf/{iotdb-common.properties =>
iotdb-system.properties} (62%)
copy
iotdb-core/{consensus/src/main/java/org/apache/iotdb/consensus/iot/client/AsyncIoTConsensusServiceClient.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/client/async/AsyncPipeConsensusServiceClient.java}
(67%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/container/PipeConsensusClientMgrContainer.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/property/PipeConsensusClientProperty.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/SyncPipeConsensusServiceClient.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/ConfigFileAutoUpdateTool.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/pipeconsensus/request/PipeConsensusRequestType.java
rename
iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/AsyncCommitCallback.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/pipeconsensus/request/PipeConsensusRequestVersion.java
(73%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/pipeconsensus/request/PipeConsensusTransferFilePieceReq.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/pipeconsensus/request/PipeConsensusTransferFileSealReq.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/pipeconsensus/request/PipeConsensusTransferFileSealWithModReq.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/payload/pipeconsensus/response/PipeConsensusTransferFilePieceResp.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/api/LayerRowReader.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/connector/iotdb/consensus/PipeConsensusAsyncConnector.java}
(58%)
rename
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/api/LayerRowReader.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/plugin/builtin/processor/pipeconsensus/PipeConsensusProcessor.java}
(58%)
create mode 100644
iotdb-protocol/thrift-consensus/src/main/thrift/pipeconsensus.thrift
