You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2025/02/20 07:02:04 UTC
(iotdb) branch iotdb-collector updated (27985e72ee6 -> c2405f494a7)
This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch iotdb-collector
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 27985e72ee6 Revert "Collector Node: Fix compile error & dependency issue" (#14908)
add a966f82d953 Fix duplicated time in result set bug
add 69d9dae6e93 Fix problem when import tsfile fail (#14792)
add e7d009cb725 Correct Block Queue Time metric
add 270e0d3a224 Region operations for table model (#14794)
add 063c8421ea0 Fix null measurement name issue in insertTablet (#14795)
add 9d6b811cca0 Add some tsfile-related tools (#14766)
add a49958c1f30 Correct binary column memory calculation (#14796)
add 0a628cbf596 Bump version to 2.0.2-SNAPSHOT
add 05003055930 Support authentication for query module
add bbaa63bbc13 Add maintenance commands for table model
add b166aa14f2c Insertion/deletion authentication
add d90088336d3 Read of .meta file is not included in the compaction io metrics (#14772)
add a1a10c1743a Fix setSystemStatusTableIT
add 70f02780a8a Support authentication for maintain and udf management statement
add 8b287ca9e16 Fix select time in TreeModel
add c2625d07ec0 Try fix error code different in each data node problem
add 46009936dcc Pipe IT: Refactor how IT is categorized to reduce overall runtime (#14719)
add e160e19789e Added regions/pipes/pipe_plugins/topics/subscriptions to information_schema & Fixed the time precision of + add "user" column for queries table (#14680)
add 1d93c99a9ca Implemented auth IT for load/pipe/subscription/database/table & Fixed the bug that partial pipe tree auth IT does not run & Fixed the tag data type of CompactionTableModelTestFileWriter (#14807)
add 5c4f0191132 Pipe IT: Modify the Git Action failure log name to be consistent with the Job (#14810)
add 2c0f7ec033b Pipe: Adapted pipe metadata sync for new permission (#14775)
add d8e6c303fb6 Fix some issues.
add 2eea334b93c fix auth parser error with grant all on root.** from non-root user.
add e5dacc08fcf Add Greatest and Least Comparison functions
add 27a3b944db5 [AINode] fix missing dependency in wheel file (#14818)
add 69b01012ade fix_docker (#14781)
add 9c54cfc4e26 feat: add generate-thrift-sources-csharp (#14824)
add 29b9ead7d85 Bump net.minidev:json-smart from 2.5.0 to 2.5.2
add eed0a4687b5 Added metrics to DeviceSchemaCache's memory and entries num (#14826)
add 7ac71fb2a33 Load: convert to insert tablet on region replica set changes (#14717)
add a798d2f0dbc Subscription: fix nack tablet response & periodically report the state of prefetching queue & improve logs for subscription providers (#14822)
add ac63e9aa79b Check time precision for negative timestamps (#14828)
add c8ea40f18d8 Fixed the bug that internalCreate(Multi)TimeSeries may write empty device when measurements are all trimmed (#14827)
add 4c65958e1d0 Update DualKeyCacheImpl.java (#14817)
add 8d08153d928 Pipe: Default parameters adjustment for pipe threads and pipeStuckRestartMinIntervalMs (#14819)
add af1db94f4b8 Pipe: avoid event accumulation in the stale sink pending queue & promptly clean up closed processor subtasks & close parser when releasing phantom reference of tsfile event (#14820)
add 3580c34e369 update workflow (#14837)
add 4d2ac447a88 Support 'set sql_dialect' in Tree and Table Model
add 338e715210b Fix NPE of RelationalDeleteDataNode merge method (#14834)
add b990b9e498b Enhance getLatestRegionRouteMap log for debugging #14830
add 0fa9fa1d3ab [IoTConsensusV2] Fix NPE when transfer tsfile mods #14840
add a0eab8f5eab Metric: Add pipe linked tsfile size and count metric (#14768)
add 6233e53acd4 [remove confignode] Add Remove ConfigNode SQL (#14813)
add b1e07c79f39 fix todos-check (#14851)
add 515991dc9f7 Pipe: adjust default pipeRealTimeQueuePollHistoryThreshold to reduce retransmission upon frequent rebooting (#14846)
add 563e42ac868 Pipe: fix the issue where the pipe still forwards insert events when the parameter source.mode.double-living is true. (#14839)
add 3edb24fe96c Delete remove-confignode.sh and remove-datanode.sh
add 9264b701a93 Do not print host and port when failed to connect through CLI (#14844)
add 57ede481a84 Pipe: Fix the problem that the receiver constructs InsertStatement causing the MeasurementShcema to not be correctly set to null (NPE) (#14831)
add 4bd2f259c50 IoTConsensus and IoTConsensusV2 no longer stores the peer list locally on the DataNode (#14814)
add 379993ec38a Add SSL support to Python client (#14789)
add 8e61e3072ab Remove JDBC sensitive information output (#14857)
add 1deffc58907 Pipe: Fix the issue where the pipe still forwards insert events in the table model when forwarding-pipe-requests is false (#14861)
add 330a683242d Pipe: Implement force forwarding feature where the Pipe sender can force the receiver to forward the received event (#14847)
add 3cc339bd47a Pipe: Introduce timely flush options & Execute flush after pipe watchdog restarts & Log degrade reasons for debugging (#14865)
add cb03ad80653 Subscription: fix consumer infinite pulling event & fully managed tsfile parsing process & increase the reference count for subscribed parsed raw tablet event & disrupt parsing requests through the introduction of randomness & disable prefetch by default (#14856)
add 92bb0a19f0a Pipe IT: explicitly declare `setUp` method for test class to avoid `UNKNOWN-IT` test class name (#14874)
add 2c4acfc1af8 Add query metrics AGGREGATION_FROM_RAW_DATA and AGGREGATION_FROM_STATISTICS for table model
add f2c1a2a68b7 Pipe: Fixed the bug that delete timeSeries / logicalView cannot be transferred (#14867)
add b4cec03c26f [remove datanode] Delete the SQL of removing multiple datanodes at the same time #14862
add 0cce0e277d6 Fix TableModelJDBCExample (#14878)
add 692b6bf4d8a Pipe: Fixed the DataNode startup failure caused by Pipe plugin loading (#14816)
add 33c9e3a1a54 fix table deletion with time predicate (#14870)
add 5f259bacc63 Remove attribute columns after attributes are updated (#14721)
add dc8418277ab Fix insert/load with timestamp of Long.MIN_VALUE and LONG.MAX_VALUE (#14491)
add 9e973b751cf Fix IoTConsensus safe deleted index (#14883)
add adba099046c Pipe: bind memory block for PipeTransferTsFileHandler and PipeInsertNodeTabletInsertionEvent & unify the memory threshold judgment for tablet and tsfile block & close data container when internally decrease reference count of PipeTsFileInsertionEvent (#14873)
add 85f85cec61d Pipe: Optimize the data logic of distinguishing table model and tree model (#14803)
add f8082c651aa Pipe: Reduce degrade log from PipeRealtimeDataRegionHybridExtractor (#14888)
add 2964bd20079 Pipe: Fixed the bug that the create/delete database cannot be passed to the receiver & SchemaRegionSnapshot parsing failure & The historical table/databases cannot be transferred & The class cast exception at receiver (#14876)
add 7883265abcc Fix the incorrect configuration of the JAVA_HOME environment variable in script." (#14893)
add 4e0ecc24541 Add Date and Float data IT (#14892)
add 4aadc09fb20 Fix IoTConsensus safe deleted index again (#14897)
add 7b588c81b17 Pipe: fix threshold judgment for tablet and tsfile memory block & Subscription: close data container for current PipeTsFileInsertionEvent in batch (#14901)
add 897e989261d Fixed the bug that procedure rollback may generate NPE && some of the rollback steps may not be / be extra executed (#14871)
add 065a58d68bd Subscription: add methods to obtain the consumer identifier in the top-level interface (#14904)
add 8760e10b796 Pipe: Avoid stuck in insertion process because failed to allocate memory (#14899)
add 4b5841fb3df Merge branch 'master' of https://github.com/apache/iotdb into iotdb-collector
add c2405f494a7 Merge branch 'iotdb-collector' of https://github.com/apache/iotdb into iotdb-collector
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 9 +-
.github/workflows/cluster-it-1c1d1a.yml | 9 +-
.github/workflows/cluster-it-1c3d.yml | 9 +-
.github/workflows/compile-check.yml | 11 +-
.github/workflows/dependency-check.yml | 1 -
.github/workflows/multi-language-client.yml | 1 -
.../{pipe-it-2cluster.yml => pipe-it.yml} | 314 +++++-
.github/workflows/sonar-codecov.yml | 1 -
.github/workflows/table-cluster-it-1c1d.yml | 9 +-
.github/workflows/table-cluster-it-1c3d.yml | 9 +-
.github/workflows/todos-check.yml | 27 +-
.github/workflows/unit-test.yml | 1 -
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 12 +-
docker/src/main/DockerCompose/entrypoint.sh | 5 +-
.../main/DockerCompose/replace-conf-from-env.sh | 33 +-
example/client-cpp-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
.../org/apache/iotdb/TableModelJDBCExample.java | 4 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
.../java/org/apache/iotdb/CountPointProcessor.java | 3 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../apache/iotdb/SubscriptionSessionExample.java | 2 +-
.../TableModelSubscriptionSessionExample.java | 16 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
integration-test/pom.xml | 74 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 12 +
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 8 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 10 +
.../category/MultiClusterIT2AutoCreateSchema.java | 22 -
...va => MultiClusterIT2DualTableManualBasic.java} | 2 +-
...=> MultiClusterIT2DualTableManualEnhanced.java} | 2 +-
....java => MultiClusterIT2DualTreeAutoBasic.java} | 2 +-
...va => MultiClusterIT2DualTreeAutoEnhanced.java} | 2 +-
...rIT.java => MultiClusterIT2DualTreeManual.java} | 2 +-
.../MultiClusterIT2ManualCreateSchema.java | 22 -
.../itbase/category/MultiClusterIT2TableModel.java | 22 -
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 3 +
.../iotdb/itbase/runtime/ClusterTestStatement.java | 5 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 4 +-
.../IoTDBRemoveConfigNodeITFramework.java | 206 ++++
.../IoTDBRemoveConfigNodeNormalIT.java} | 16 +-
.../IoTDBRemoveDataNodeITFramework.java | 2 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 45 +
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 1 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 73 ++
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 24 +
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 38 +
.../iotdb/db/it/auth/IoTDBRelationalAuthIT.java | 183 ++++
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 2 +-
.../apache/iotdb/db/it/query/IoTDBQueryDemoIT.java | 25 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 227 ++++-
.../it/{ => dual}/tablemodel/TableModelUtils.java | 2 +-
.../AbstractPipeTableModelDualManualIT.java} | 4 +-
.../tablemodel/manual/basic}/IoTDBPipeAlterIT.java | 17 +-
.../manual/basic}/IoTDBPipeDataSinkIT.java | 21 +-
.../manual/basic}/IoTDBPipeExtractorIT.java | 10 +-
.../manual/basic}/IoTDBPipeIsolationIT.java | 17 +-
.../manual/basic}/IoTDBPipeLifeCycleIT.java | 165 +++-
.../manual/basic}/IoTDBPipeProtocolIT.java | 11 +-
.../manual/basic}/IoTDBPipeSwitchStatusIT.java | 18 +-
.../manual/basic}/IoTDBPipeSyntaxIT.java | 17 +-
.../manual/basic}/IoTDBPipeWithLoadIT.java | 10 +-
.../manual/basic}/IoTDBTablePatternFormatIT.java | 17 +-
.../manual/enhanced}/IoTDBPipeAutoConflictIT.java | 11 +-
.../manual/enhanced}/IoTDBPipeAutoDropIT.java | 17 +-
.../manual/enhanced}/IoTDBPipeClusterIT.java | 10 +-
.../enhanced}/IoTDBPipeConnectorCompressionIT.java | 10 +-
.../enhanced}/IoTDBPipeConnectorParallelIT.java | 18 +-
.../manual/enhanced}/IoTDBPipeDoubleLivingIT.java | 20 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 205 ++++
.../manual/enhanced/IoTDBPipeMetaIT.java} | 95 +-
.../manual/enhanced}/IoTDBPipeNullValueIT.java | 17 +-
.../IoTDBPipeTypeConversionISessionIT.java | 26 +-
.../enhanced}/IoTDBPipeTypeConversionIT.java | 25 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java} | 4 +-
.../treemodel/auto/basic}/IoTDBPipeAlterIT.java | 16 +-
.../auto/basic}/IoTDBPipeConnectorParallelIT.java | 17 +-
.../treemodel/auto/basic}/IoTDBPipeDataSinkIT.java | 17 +-
.../auto/basic}/IoTDBPipeExtractorIT.java | 9 +-
.../auto/basic}/IoTDBPipeLifeCycleIT.java | 30 +-
.../auto/basic}/IoTDBPipeProcessorIT.java | 10 +-
.../treemodel/auto/basic}/IoTDBPipeProtocolIT.java | 10 +-
.../auto/basic}/IoTDBPipeSwitchStatusIT.java | 17 +-
.../treemodel/auto/basic}/IoTDBPipeSyntaxIT.java | 17 +-
.../auto/basic}/IoTDBTreePatternFormatIT.java | 17 +-
.../auto/enhanced}/IoTDBPipeAutoConflictIT.java | 10 +-
.../auto/enhanced}/IoTDBPipeAutoDropIT.java | 16 +-
.../auto/enhanced}/IoTDBPipeClusterIT.java | 11 +-
.../IoTDBPipeConditionalOperationsIT.java | 16 +-
.../enhanced}/IoTDBPipeConnectorCompressionIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeIdempotentIT.java | 117 +--
.../auto/enhanced}/IoTDBPipeNullValueIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeWithLoadIT.java | 9 +-
.../auto/enhanced}/PipeNowFunctionIT.java | 16 +-
.../manual/AbstractPipeDualTreeModelManualIT.java} | 4 +-
.../treemodel}/manual/IoTDBPipeInclusionIT.java | 8 +-
.../manual/IoTDBPipeManualConflictIT.java | 8 +-
.../manual/IoTDBPipeMetaHistoricalIT.java | 8 +-
.../manual/IoTDBPipeMetaLeaderChangeIT.java | 8 +-
.../treemodel}/manual/IoTDBPipeMetaRestartIT.java | 8 +-
.../manual/IoTDBPipeMultiSchemaRegionIT.java | 8 +-
.../treemodel}/manual/IoTDBPipePermissionIT.java | 8 +-
.../treemodel}/manual/IoTDBPipeReqAutoSliceIT.java | 8 +-
.../manual/IoTDBPipeTypeConversionISessionIT.java | 8 +-
.../manual/IoTDBPipeTypeConversionIT.java | 8 +-
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 2 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 1001 ++++++++++++++++++++
.../relational/it/db/it/IoTDBDeletionTableIT.java | 118 ++-
.../relational/it/db/it/IoTDBInsertTableIT.java | 17 +-
.../it/IoTDBLoadConfigurationTableIT.java} | 75 +-
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 104 ++
.../query/old/query/IoTDBGreatestLeastTableIT.java | 305 ++++++
.../it/query/recent/IoTDBMaintainAuthIT.java | 289 ++++++
.../it/query/recent/IoTDBNullIdQueryIT.java | 33 +
.../IoTDBNullValueIT.java} | 43 +-
.../it/query/recent/IoTDBQueryAuthIT.java | 320 +++++++
.../relational/it/schema/IoTDBDatabaseIT.java | 145 ++-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 57 ++
.../it/session/IoTDBSessionRelationalIT.java | 204 ++++
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 58 ++
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 174 +++-
.../it/local/IoTDBSubscriptionBasicIT.java | 67 ++
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
iotdb-client/cli/pom.xml | 22 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 4 +-
.../iotdb/tool/common/ImportTsFileOperation.java | 59 ++
.../apache/iotdb/tool/data/AbstractDataTool.java | 6 +-
.../org/apache/iotdb/tool/data/ImportData.java | 22 +-
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 57 +-
.../apache/iotdb/tool/tsfile/ImportTsFileBase.java | 9 +-
.../iotdb/tool/ImportTsFileOperationTest.java | 49 +
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-py/iotdb/Session.py | 44 +-
iotdb-client/client-py/iotdb/SessionPool.py | 8 +
iotdb-client/client-py/iotdb/table_session.py | 6 +
iotdb-client/client-py/iotdb/table_session_pool.py | 4 +
iotdb-client/client-py/pom.xml | 6 +-
iotdb-client/client-py/session_ssl_example.py | 85 ++
iotdb-client/isession/pom.xml | 8 +-
iotdb-client/jdbc/pom.xml | 8 +-
.../main/java/org/apache/iotdb/jdbc/Constant.java | 3 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 4 +
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 4 +-
.../apache/iotdb/jdbc/IoTDBDataSourceFactory.java | 3 -
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 7 +
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 14 +
.../iotdb/rpc/subscription/config/TopicConfig.java | 7 +-
.../subscription/payload/poll/TabletsPayload.java | 4 +-
.../java/org/apache/iotdb/rpc/RpcUtilsTest.java | 10 +
iotdb-client/session/pom.xml | 10 +-
.../java/org/apache/iotdb/session/Session.java | 25 +-
.../apache/iotdb/session/SessionConnection.java | 12 +-
.../apache/iotdb/session/TableSessionBuilder.java | 4 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 5 +-
.../iotdb/session/pool/TableSessionWrapper.java | 15 +
.../consumer/ISubscriptionTablePullConsumer.java | 18 +
.../consumer/ISubscriptionTablePushConsumer.java | 18 +
.../consumer/ISubscriptionTreePullConsumer.java | 18 +
.../consumer/ISubscriptionTreePushConsumer.java | 18 +
.../base/AbstractSubscriptionConsumer.java | 6 +-
.../base/AbstractSubscriptionProviders.java | 48 +-
.../consumer/table/SubscriptionTableProvider.java | 18 +-
.../table/SubscriptionTablePullConsumer.java | 34 +-
.../table/SubscriptionTablePushConsumer.java | 36 +-
.../consumer/tree/SubscriptionTreeProvider.java | 18 +-
.../tree/SubscriptionTreePullConsumer.java | 34 +-
.../tree/SubscriptionTreePushConsumer.java | 34 +-
iotdb-core/ainode/pom.xml | 10 +-
iotdb-core/ainode/pyproject.toml | 14 +-
iotdb-core/ainode/resources/conf/ainode-env.sh | 2 +-
iotdb-core/antlr/pom.xml | 2 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 6 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 23 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 24 +
iotdb-core/confignode/pom.xml | 26 +-
.../assembly/resources/sbin/remove-confignode.bat | 135 ---
.../assembly/resources/sbin/remove-confignode.sh | 69 --
.../confignode/conf/ConfigNodeRemoveCheck.java | 5 +-
.../request/ConfigPhysicalPlanVisitor.java | 221 ++++-
.../pipe/payload/PipeDeleteLogicalViewPlan.java | 5 +-
.../pipe/payload/PipeDeleteTimeSeriesPlan.java | 5 +-
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 3 +-
.../confignode/manager/PermissionManager.java | 7 +-
.../iotdb/confignode/manager/ProcedureManager.java | 36 +-
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 3 +
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 17 +-
.../extractor/ConfigRegionListeningFilter.java | 84 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 23 +-
...ConfigPhysicalPlanTablePatternParseVisitor.java | 62 ++
...peConfigPhysicalPlanTableScopeParseVisitor.java | 86 ++
...eConfigPhysicalPlanTreePatternParseVisitor.java | 30 +-
...ipeConfigPhysicalPlanTreeScopeParseVisitor.java | 80 ++
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 187 +++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 207 +++-
.../iotdb/confignode/persistence/AuthorInfo.java | 70 +-
.../schema/CNPhysicalPlanGenerator.java | 15 +-
...otParser.java => ConfigNodeSnapshotParser.java} | 24 +-
.../procedure/impl/StateMachineProcedure.java | 7 +-
.../impl/schema/AlterLogicalViewProcedure.java | 4 +-
...ipeConfigPhysicalPlanScopeParseVisitorTest.java | 116 +++
...igPhysicalPlanTablePatternParseVisitorTest.java | 25 +
iotdb-core/consensus/pom.xml | 14 +-
.../org/apache/iotdb/consensus/common/Peer.java | 13 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 30 +-
.../consensus/iot/IoTConsensusServerImpl.java | 258 +----
.../consensus/iot/logdispatcher/LogDispatcher.java | 9 +-
.../service/IoTConsensusRPCServiceProcessor.java | 2 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 90 +-
.../consensus/pipe/PipeConsensusPeerManager.java | 89 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 33 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 63 +-
iotdb-core/datanode/pom.xml | 40 +-
.../assembly/resources/sbin/remove-datanode.bat | 148 ---
.../src/assembly/resources/sbin/remove-datanode.sh | 91 --
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 3 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 9 +
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 3 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 59 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 12 +-
.../agent/task/connection/PipeEventCollector.java | 11 +-
.../agent/task/stage/PipeTaskProcessorStage.java | 9 +-
.../PipeRealtimePriorityBlockingQueue.java | 2 +
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../processor/PipeProcessorSubtaskWorker.java | 11 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../async/IoTDBDataRegionAsyncConnector.java | 18 +-
.../handler/PipeTransferTrackableHandler.java | 33 +-
.../async/handler/PipeTransferTsFileHandler.java | 66 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 64 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 27 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 56 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 26 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 86 +-
.../query/TsFileInsertionEventQueryParser.java | 70 +-
.../scan/TsFileInsertionEventScanParser.java | 35 +-
.../table/TsFileInsertionEventTableParser.java | 70 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 6 +
.../event/realtime/PipeRealtimeEventFactory.java | 12 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 10 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 26 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 136 ++-
.../realtime/assigner/PipeDataRegionAssigner.java | 19 +
.../listener/PipeInsertionDataNodeListener.java | 4 +-
.../schemaregion/SchemaRegionListeningFilter.java | 8 +-
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 34 +
.../processor/aggregate/AggregateProcessor.java | 18 +-
.../twostage/plugin/TwoStageCountProcessor.java | 14 +-
.../pipeconsensus/PipeConsensusReceiver.java | 55 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 10 +-
.../visitor/PipePlanToStatementVisitor.java | 18 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 137 ++-
.../resource/tsfile/PipeTsFileResourceManager.java | 15 +
.../iotdb/db/protocol/client/ConfigNodeClient.java | 3 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 27 +-
.../execution/exchange/SharedTsBlockQueue.java | 8 +-
.../execution/exchange/sink/SinkChannel.java | 11 +-
.../exchange/source/LocalSourceHandle.java | 4 +-
.../execution/executor/RegionWriteExecutor.java | 33 +-
.../fragment/FragmentInstanceContext.java | 49 +-
.../execution/operator/AbstractOperator.java | 2 +-
.../operator/process/AbstractSortOperator.java | 2 +-
.../execution/operator/process/SortOperator.java | 2 +-
.../operator/process/TableStreamSortOperator.java | 2 +-
.../execution/operator/source/FileLoaderUtils.java | 4 +-
.../InformationSchemaContentSupplierFactory.java | 341 +++++--
.../relational/aggregation/TableAggregator.java | 49 +-
.../grouped/HashAggregationOperator.java | 4 +-
.../grouped/StreamingAggregationOperator.java | 9 +-
.../grouped/StreamingHashAggregationOperator.java | 4 +-
.../relational/ColumnTransformerBuilder.java | 15 +
.../execution/schedule/DriverScheduler.java | 8 -
.../queryengine/metric/QueryPlanCostMetricSet.java | 68 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 18 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 9 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 20 +-
.../db/queryengine/plan/analyze/Analyzer.java | 3 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 3 +-
.../analyze/cache/partition/PartitionCache.java | 5 +
.../schema/dualkeycache/IDualKeyCacheStats.java | 6 +
.../cache/schema/dualkeycache/impl/CacheStats.java | 24 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 122 ++-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 7 +
.../analyze/load/LoadTsFileTableSchemaCache.java | 11 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 7 +-
.../plan/analyze/schema/SchemaValidator.java | 14 +-
.../plan/execution/IQueryExecution.java | 2 +
.../queryengine/plan/execution/QueryExecution.java | 19 +-
.../plan/execution/config/ConfigExecution.java | 9 +-
.../execution/config/TableConfigTaskVisitor.java | 91 ++
.../execution/config/TreeConfigTaskVisitor.java | 31 +
.../config/executor/ClusterConfigTaskExecutor.java | 114 ++-
.../config/executor/IConfigTaskExecutor.java | 23 +-
...DataNodeTask.java => RemoveConfigNodeTask.java} | 12 +-
.../config/metadata/ShowPipePluginsTask.java | 4 +-
.../config/metadata/region/ExtendRegionTask.java | 20 +-
.../config/metadata/region/MigrateRegionTask.java | 21 +-
.../metadata/region/ReconstructRegionTask.java | 25 +-
.../config/metadata/region/RemoveRegionTask.java | 20 +-
.../SetSqlDialectTask.java} | 15 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 57 +-
.../db/queryengine/plan/planner/IPlanner.java | 3 +-
.../queryengine/plan/planner/LogicalPlanner.java | 6 +-
.../plan/planner/TableOperatorGenerator.java | 9 +-
.../queryengine/plan/planner/TreeModelPlanner.java | 20 +-
.../plan/node/load/LoadSingleTsFileNode.java | 12 +-
.../plan/node/load/LoadTsFilePieceNode.java | 6 +-
.../plan/node/write/RelationalDeleteDataNode.java | 4 +-
.../plan/relational/analyzer/Analyzer.java | 3 +-
.../relational/analyzer/StatementAnalyzer.java | 11 +-
.../relational/metadata/TableMetadataImpl.java | 20 +
.../fetcher/cache/TableDeviceSchemaCache.java | 19 +-
.../cache/TableDeviceSchemaCacheMetrics.java | 34 +
.../relational/planner/TableLogicalPlanner.java | 16 +-
.../plan/relational/planner/TableModelPlanner.java | 32 +-
.../distribute/TableDistributedPlanner.java | 11 +-
.../DataNodeLocationSupplierFactory.java | 22 +-
.../optimizations/PushPredicateIntoTableScan.java | 6 +-
.../plan/relational/security/AccessControl.java | 8 +
.../relational/security/AccessControlImpl.java | 62 +-
.../relational/security/AllowAllAccessControl.java | 5 +
.../plan/relational/sql/ast/AstVisitor.java | 32 +
.../ast/{RemoveDataNode.java => ExtendRegion.java} | 45 +-
.../plan/relational/sql/ast/InsertRows.java | 2 +-
...{StopRepairData.java => LoadConfiguration.java} | 6 +-
.../sql/ast/{Values.java => MigrateRegion.java} | 67 +-
...{RemoveDataNode.java => ReconstructRegion.java} | 46 +-
.../{RemoveDataNode.java => RemoveConfigNode.java} | 22 +-
.../ast/{RemoveDataNode.java => RemoveRegion.java} | 45 +-
.../sql/ast/{KillQuery.java => SetSqlDialect.java} | 28 +-
.../{StartRepairData.java => SetSystemStatus.java} | 6 +-
.../relational/sql/ast/WrappedInsertStatement.java | 78 +-
.../plan/relational/sql/parser/AstBuilder.java | 175 +++-
.../plan/scheduler/load/LoadTsFileScheduler.java | 47 +-
.../plan/statement/StatementVisitor.java | 21 +
.../plan/statement/crud/InsertBaseStatement.java | 50 +
.../crud/InsertMultiTabletsStatement.java | 11 +
.../plan/statement/crud/InsertRowStatement.java | 7 +
.../crud/InsertRowsOfOneDeviceStatement.java | 5 +
.../plan/statement/crud/InsertRowsStatement.java | 11 +
.../plan/statement/crud/InsertTabletStatement.java | 10 +
...atement.java => RemoveConfigNodeStatement.java} | 17 +-
...nStatement.java => SetSqlDialectStatement.java} | 38 +-
...nt.java => ShowCurrentSqlDialectStatement.java} | 16 +-
...tatement.java => ShowCurrentUserStatement.java} | 16 +-
.../AbstractGreatestLeastColumnTransformer.java | 109 +++
.../multi/BinaryGreatestColumnTransformer.java | 53 ++
.../column/multi/BinaryLeastColumnTransformer.java | 53 ++
.../multi/BooleanGreatestColumnTransformer.java | 52 +
.../multi/BooleanLeastColumnTransformer.java | 49 +
.../multi/DoubleGreatestColumnTransformer.java | 52 +
.../column/multi/DoubleLeastColumnTransformer.java | 52 +
.../multi/FloatGreatestColumnTransformer.java | 52 +
.../column/multi/FloatLeastColumnTransformer.java | 52 +
.../multi/Int32GreatestColumnTransformer.java | 52 +
.../column/multi/Int32LeastColumnTransformer.java | 52 +
.../multi/Int64GreatestColumnTransformer.java | 52 +
.../column/multi/Int64LeastColumnTransformer.java | 52 +
.../schemaregion/utils/ResourceByPathUtils.java | 31 +-
.../iotdb/db/storageengine/StorageEngine.java | 31 +-
.../db/storageengine/dataregion/DataRegion.java | 13 +-
.../performer/impl/FastCompactionPerformer.java | 4 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 21 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 26 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 40 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 28 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 23 +-
.../executor/fast/SeriesCompactionExecutor.java | 30 +-
.../readchunk/AlignedSeriesCompactionExecutor.java | 4 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 37 +-
.../readchunk/SingleSeriesCompactionExecutor.java | 30 +-
.../utils/writer/AbstractCompactionWriter.java | 5 +-
.../writer/AbstractCrossCompactionWriter.java | 7 +-
.../writer/AbstractInnerCompactionWriter.java | 1 +
.../utils/writer/FastCrossCompactionWriter.java | 16 +-
.../utils/writer/FastInnerCompactionWriter.java | 16 +-
.../writer/ReadPointCrossCompactionWriter.java | 1 +
.../CompactionDiskTSMIterator.java} | 28 +-
.../compaction/io/CompactionTsFileInput.java | 122 ++-
.../compaction/io/CompactionTsFileReader.java | 60 +-
.../compaction/io/CompactionTsFileWriter.java | 9 +
.../compaction/repair/RepairDataFileScanUtil.java | 56 +-
.../estimator/AbstractCompactionEstimator.java | 9 +-
.../selector/impl/SettleSelectorImpl.java | 24 +-
.../selector/utils/TsFileResourceCandidate.java | 13 +-
.../dataregion/memtable/AbstractMemTable.java | 4 +-
.../memtable/AlignedReadOnlyMemChunk.java | 10 +-
.../dataregion/memtable/TsFileProcessor.java | 7 +-
.../dataregion/modification/ModificationFile.java | 16 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 5 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 4 +-
.../read/reader/chunk/MemAlignedPageReader.java | 6 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 4 +-
.../dataregion/tsfile/TsFileResource.java | 37 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 23 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 9 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 5 +-
.../utils/TsFileDeviceStartEndTimeIterator.java | 6 +-
.../dataregion/utils/TsFileResourceUtils.java | 30 +-
.../storageengine/dataregion/wal/io/WALReader.java | 2 +-
.../wal/recover/file/TsFilePlanRedoer.java | 9 +-
.../file/UnsealedTsFileRecoverPerformer.java | 10 +-
.../db/storageengine/load/LoadTsFileManager.java | 5 +-
...leStatementDataTypeConvertExecutionVisitor.java | 4 +
...eeStatementDataTypeConvertExecutionVisitor.java | 4 +
.../load/splitter/AlignedChunkData.java | 16 +-
.../splitter/BatchedAlignedValueChunkData.java | 8 +-
.../load/splitter/NonAlignedChunkData.java | 8 +-
.../load/splitter/TsFileSplitter.java | 7 +
.../broker/SubscriptionPrefetchingQueue.java | 14 +-
.../broker/SubscriptionPrefetchingTabletQueue.java | 2 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 2 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 52 +-
.../SubscriptionPipeTabletIterationSnapshot.java | 62 ++
.../pipe/SubscriptionPipeTabletBatchEvents.java | 29 +-
.../response/SubscriptionEventTabletResponse.java | 5 -
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 6 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 10 +-
.../utils/TsFileRewriteOverPrecisedI64Scan.java | 223 +++++
.../utils/TsFileRewriteSmallRangeI64Scan.java | 230 +++++
.../iotdb/db/tools/utils/TsFileSequenceScan.java | 34 +-
.../iotdb/db/tools/utils/TsFileStatisticScan.java | 266 ++++++
.../iotdb/db/tools/utils/TsFileValidationScan.java | 10 +-
.../TsFileOverlapValidationAndRepairTool.java | 8 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 6 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 24 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 26 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 20 +-
.../iotdb/db/utils/constant/SqlConstant.java | 2 +-
.../db/utils/datastructure/AlignedTVList.java | 3 +-
.../org/apache/iotdb/db/auth/entity/UserTest.java | 4 +-
.../db/queryengine/execution/exchange/Utils.java | 3 +
.../operator/MergeTreeSortOperatorTest.java | 6 +
.../execution/operator/OperatorMemoryTest.java | 2 +
.../plan/parser/StatementGeneratorTest.java | 3 +
.../plan/relational/analyzer/AnalyzerTest.java | 7 +-
.../plan/relational/analyzer/ShowQueriesTest.java | 7 +-
.../compaction/CompactionDataTypeNotMatchTest.java | 19 +-
.../FastCompactionPerformerWithEmptyPageTest.java | 5 +-
...InconsistentCompressionTypeAndEncodingTest.java | 6 +-
.../FastInnerCompactionPerformerTest.java | 140 +--
.../ReadPointCompactionPerformerTest.java | 134 +--
.../TsFileValidationCorrectnessTests.java | 14 +-
...eCompactionWithFastPerformerValidationTest.java | 14 +-
...actionWithReadPointPerformerValidationTest.java | 14 +-
.../InsertionCrossSpaceCompactionRecoverTest.java | 4 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 4 +-
.../cross/RewriteCompactionFileSelectorTest.java | 6 +-
.../repair/RepairUnsortedFileCompactionTest.java | 8 +-
.../CompactionTableModelTestFileWriter.java | 2 +-
.../compaction/utils/BatchCompactionUtilsTest.java | 39 +-
.../compaction/utils/CompactionCheckerUtils.java | 11 +-
.../dataregion/memtable/TsFileProcessorTest.java | 3 +-
.../dataregion/tsfile/TsFileResourceTest.java | 12 +-
.../wal/recover/WALRecoverManagerTest.java | 21 +-
.../file/SealedTsFileRecoverPerformerTest.java | 33 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 21 +-
.../db/utils/TimestampPrecisionUtilsTest.java | 10 +
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 24 +-
.../conf/iotdb-system.properties.template | 12 +-
.../src/assembly/resources/sbin/health_check.bat | 2 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 21 +
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 4 +
.../commons/auth/authorizer/OpenIdAuthorizer.java | 6 +-
.../org/apache/iotdb/commons/auth/entity/Role.java | 8 +
.../org/apache/iotdb/commons/auth/entity/User.java | 8 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 45 +-
.../iotdb/commons/conf/CommonDescriptor.java | 35 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 7 +-
.../commons/pipe/agent/task/PipeTaskAgent.java | 52 +-
.../task/connection/BlockingPendingQueue.java | 14 +
.../iotdb/commons/pipe/config/PipeConfig.java | 14 +-
.../config/constant/PipeConnectorConstant.java | 4 +
.../pipe/connector/client/IoTDBClientManager.java | 6 +-
.../connector/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 12 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../options/PipeInclusionOptions.java | 15 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 12 +-
.../schema/column/ColumnHeaderConstant.java | 30 +
.../commons/schema/table/InformationSchema.java | 109 +++
.../iotdb/commons/service/metric/enums/Metric.java | 2 +
.../relational/TableBuiltinScalarFunction.java | 2 +
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 40 +-
iotdb-protocol/openapi/pom.xml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-ainode/pom.xml | 4 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
.../src/main/thrift/confignode.thrift | 4 +
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
library-udf/pom.xml | 4 +-
pom.xml | 19 +-
522 files changed, 13009 insertions(+), 3657 deletions(-)
rename .github/workflows/{pipe-it-2cluster.yml => pipe-it.yml} (62%)
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2AutoCreateSchema.java
copy integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java => MultiClusterIT2DualTableManualBasic.java} (94%)
copy integration-test/src/main/java/org/apache/iotdb/itbase/category/{AIClusterIT.java => MultiClusterIT2DualTableManualEnhanced.java} (93%)
copy integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java => MultiClusterIT2DualTreeAutoBasic.java} (94%)
copy integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java => MultiClusterIT2DualTreeAutoEnhanced.java} (94%)
copy integration-test/src/main/java/org/apache/iotdb/itbase/category/{ClusterIT.java => MultiClusterIT2DualTreeManual.java} (94%)
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2ManualCreateSchema.java
delete mode 100644 integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2TableModel.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/confignode/it/removeconfignode/IoTDBRemoveConfigNodeITFramework.java
copy integration-test/src/test/java/org/apache/iotdb/confignode/it/{regionmigration/pass/commit/batch/IoTDBRegionMigrateNormalITForIoTV2Batch.java => removeconfignode/IoTDBRemoveConfigNodeNormalIT.java} (64%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual}/tablemodel/TableModelUtils.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel/AbstractPipeTableModelTestIT.java => dual/tablemodel/manual/AbstractPipeTableModelDualManualIT.java} (95%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeAlterIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeDataSinkIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeExtractorIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeIsolationIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeLifeCycleIT.java (82%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeProtocolIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeSwitchStatusIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeSyntaxIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBPipeWithLoadIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/basic}/IoTDBTablePatternFormatIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeAutoConflictIT.java (96%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeAutoDropIT.java (93%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeClusterIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeConnectorCompressionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeConnectorParallelIT.java (90%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeDoubleLivingIT.java (95%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/pipe/it/dual/tablemodel/manual/enhanced/IoTDBPipeIdempotentIT.java
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{manual/IoTDBPipeTableManualIT.java => dual/tablemodel/manual/enhanced/IoTDBPipeMetaIT.java} (76%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeNullValueIT.java (93%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeTypeConversionISessionIT.java (95%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel => dual/tablemodel/manual/enhanced}/IoTDBPipeTypeConversionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate/AbstractPipeDualAutoIT.java => dual/treemodel/auto/AbstractPipeDualTreeModelAutoIT.java} (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeAlterIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeConnectorParallelIT.java (90%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeDataSinkIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeExtractorIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeLifeCycleIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeProcessorIT.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeProtocolIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeSwitchStatusIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBPipeSyntaxIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/basic}/IoTDBTreePatternFormatIT.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeAutoConflictIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeAutoDropIT.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeClusterIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeConditionalOperationsIT.java (96%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeConnectorCompressionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeIdempotentIT.java (79%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeNullValueIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/IoTDBPipeWithLoadIT.java (93%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate => dual/treemodel/auto/enhanced}/PipeNowFunctionIT.java (96%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{manual/AbstractPipeDualManualIT.java => dual/treemodel/manual/AbstractPipeDualTreeModelManualIT.java} (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeInclusionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeManualConflictIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeMetaHistoricalIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeMetaLeaderChangeIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeMetaRestartIT.java (96%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeMultiSchemaRegionIT.java (95%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipePermissionIT.java (97%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeReqAutoSliceIT.java (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeTypeConversionISessionIT.java (99%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{ => dual/treemodel}/manual/IoTDBPipeTypeConversionIT.java (98%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBAuthenticationTableIT.java
copy integration-test/src/test/java/org/apache/iotdb/relational/it/{query/old/builtinfunction/scalar/IoTDBCastFunctionTableSpecialIT.java => db/it/IoTDBLoadConfigurationTableIT.java} (58%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBSetSystemStatusTableIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/query/IoTDBGreatestLeastTableIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBMaintainAuthIT.java
copy integration-test/src/test/java/org/apache/iotdb/relational/it/query/{old/aligned/IoTDBPredicatePushDownTable3IT.java => recent/IoTDBNullValueIT.java} (55%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBQueryAuthIT.java
create mode 100644 iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/ImportTsFileOperation.java
create mode 100644 iotdb-client/cli/src/test/java/org/apache/iotdb/tool/ImportTsFileOperationTest.java
create mode 100644 iotdb-client/client-py/session_ssl_example.py
delete mode 100644 iotdb-core/confignode/src/assembly/resources/sbin/remove-confignode.bat
delete mode 100755 iotdb-core/confignode/src/assembly/resources/sbin/remove-confignode.sh
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanTableScopeParseVisitor.java
create mode 100644 iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanTreeScopeParseVisitor.java
rename iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/{ConfignodeSnapshotParser.java => ConfigNodeSnapshotParser.java} (91%)
create mode 100644 iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/manager/pipe/extractor/PipeConfigPhysicalPlanScopeParseVisitorTest.java
delete mode 100644 iotdb-core/datanode/src/assembly/resources/sbin/remove-datanode.bat
delete mode 100755 iotdb-core/datanode/src/assembly/resources/sbin/remove-datanode.sh
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{RemoveDataNodeTask.java => RemoveConfigNodeTask.java} (82%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/{sys/MergeTask.java => session/SetSqlDialectTask.java} (76%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{RemoveDataNode.java => ExtendRegion.java} (64%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{StopRepairData.java => LoadConfiguration.java} (84%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{Values.java => MigrateRegion.java} (56%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{RemoveDataNode.java => ReconstructRegion.java} (62%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{RemoveDataNode.java => RemoveConfigNode.java} (75%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{RemoveDataNode.java => RemoveRegion.java} (64%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{KillQuery.java => SetSqlDialect.java} (72%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{StartRepairData.java => SetSystemStatus.java} (86%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{RemoveDataNodeStatement.java => RemoveConfigNodeStatement.java} (84%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{TestConnectionStatement.java => SetSqlDialectStatement.java} (63%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{ShowVersionStatement.java => ShowCurrentSqlDialectStatement.java} (78%)
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{ShowVersionStatement.java => ShowCurrentUserStatement.java} (78%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/AbstractGreatestLeastColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BinaryGreatestColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BinaryLeastColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BooleanGreatestColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/BooleanLeastColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/DoubleGreatestColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/DoubleLeastColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/FloatGreatestColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/FloatLeastColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int32GreatestColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int32LeastColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int64GreatestColumnTransformer.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/multi/Int64LeastColumnTransformer.java
copy iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/{selector/ICrossSpaceSelector.java => io/CompactionDiskTSMIterator.java} (56%)
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletIterationSnapshot.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileRewriteOverPrecisedI64Scan.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileRewriteSmallRangeI64Scan.java
create mode 100644 iotdb-core/datanode/src/main/java/org/apache/iotdb/db/tools/utils/TsFileStatisticScan.java