This is an automated email from the ASF dual-hosted git repository.
lancelly pushed a change to branch support_correlated_scalar_subquery
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 27e721b51e1 add some ITs
add 9c9b2393af3 Fix query error after insert an all null aligned tablet
and flush (#14777)
add 024b05cc4d8 Fixed the bug that the database is not totally separated
in partition cache
add 526f678f746 [RatisConsensus] Prevent misuse of addRemotePeer (#14779)
add 43eb55ad927 Pipe: Introduce periodic verification for username and
password on receiver side (#14764)
add 02ff0d27c57 Pipe / Load: Enable validation skip for load tsFile
(#14774)
add cbd683ece36 Adapte table model in import/export tools (#14677)
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)
new 113c0051f72 merge master
new 8fcbf177a0c fix visitAssignUniqueId in TableDistributedPlanGenerator
new 0bce073b1fd add IT and fix assignUniqueId
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 | 19 +-
.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 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
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 +-
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/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/IoTDBInsertWithQueryIT.java | 1 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 73 ++
.../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 | 10 +-
.../manual/basic}/IoTDBPipeDataSinkIT.java | 111 ++-
.../manual/basic}/IoTDBPipeExtractorIT.java | 10 +-
.../manual/basic}/IoTDBPipeIsolationIT.java | 10 +-
.../manual/basic}/IoTDBPipeLifeCycleIT.java | 157 ++-
.../manual/basic}/IoTDBPipeProtocolIT.java | 10 +-
.../manual/basic}/IoTDBPipeSwitchStatusIT.java | 10 +-
.../manual/basic}/IoTDBPipeSyntaxIT.java | 9 +-
.../manual/basic}/IoTDBPipeWithLoadIT.java | 10 +-
.../manual/basic}/IoTDBTablePatternFormatIT.java | 10 +-
.../manual/enhanced}/IoTDBPipeAutoConflictIT.java | 10 +-
.../manual/enhanced}/IoTDBPipeAutoDropIT.java | 10 +-
.../manual/enhanced}/IoTDBPipeClusterIT.java | 10 +-
.../enhanced}/IoTDBPipeConnectorCompressionIT.java | 10 +-
.../enhanced}/IoTDBPipeConnectorParallelIT.java | 10 +-
.../manual/enhanced}/IoTDBPipeDoubleLivingIT.java | 13 +-
.../manual/enhanced/IoTDBPipeIdempotentIT.java | 197 ++++
.../manual/enhanced/IoTDBPipeMetaIT.java} | 87 +-
.../manual/enhanced}/IoTDBPipeNullValueIT.java | 10 +-
.../IoTDBPipeTypeConversionISessionIT.java | 18 +-
.../enhanced}/IoTDBPipeTypeConversionIT.java | 18 +-
.../auto/AbstractPipeDualTreeModelAutoIT.java} | 4 +-
.../treemodel/auto/basic}/IoTDBPipeAlterIT.java | 9 +-
.../auto/basic}/IoTDBPipeConnectorParallelIT.java | 9 +-
.../treemodel/auto/basic}/IoTDBPipeDataSinkIT.java | 80 +-
.../auto/basic}/IoTDBPipeExtractorIT.java | 9 +-
.../auto/basic}/IoTDBPipeLifeCycleIT.java | 22 +-
.../auto/basic}/IoTDBPipeProcessorIT.java | 9 +-
.../treemodel/auto/basic}/IoTDBPipeProtocolIT.java | 9 +-
.../auto/basic}/IoTDBPipeSwitchStatusIT.java | 9 +-
.../treemodel/auto/basic}/IoTDBPipeSyntaxIT.java | 9 +-
.../auto/basic}/IoTDBTreePatternFormatIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeAutoConflictIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeAutoDropIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeClusterIT.java | 11 +-
.../IoTDBPipeConditionalOperationsIT.java | 9 +-
.../enhanced}/IoTDBPipeConnectorCompressionIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeIdempotentIT.java | 100 +-
.../auto/enhanced}/IoTDBPipeNullValueIT.java | 9 +-
.../auto/enhanced}/IoTDBPipeWithLoadIT.java | 9 +-
.../auto/enhanced}/PipeNowFunctionIT.java | 9 +-
.../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 | 44 +-
.../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 ++++++
.../IoTDBCorrelatedExistsSubqueryIT.java | 2 +-
.../IoTDBCorrelatedScalarSubqueryIT.java | 282 +++++-
.../relational/it/schema/IoTDBDatabaseIT.java | 151 ++-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 57 ++
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 128 +++
.../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 +-
.../org/apache/iotdb/tool/common/Constants.java | 319 ++++++
.../iotdb/tool/common/ImportTsFileOperation.java | 59 ++
.../org/apache/iotdb/tool/common/OptionsUtil.java | 915 ++++++++++++++++++
.../apache/iotdb/tool/data/AbstractDataTool.java | 1019 +++++---------------
.../apache/iotdb/tool/data/AbstractExportData.java | 70 ++
.../AbstractImportData.java} | 216 +++--
.../apache/iotdb/tool/data/AsyncImportData.java | 160 ---
.../org/apache/iotdb/tool/data/ExportData.java | 775 +++------------
.../apache/iotdb/tool/data/ExportDataTable.java | 341 +++++++
.../org/apache/iotdb/tool/data/ExportDataTree.java | 420 ++++++++
.../org/apache/iotdb/tool/data/ImportData.java | 795 ++++++---------
.../apache/iotdb/tool/data/ImportDataScanTool.java | 4 -
.../apache/iotdb/tool/data/ImportDataTable.java | 392 ++++++++
.../org/apache/iotdb/tool/data/ImportDataTree.java | 476 +++++++++
.../org/apache/iotdb/tool/tsfile/ImportTsFile.java | 69 +-
.../apache/iotdb/tool/tsfile/ImportTsFileBase.java | 9 +-
.../iotdb/tool/tsfile/ImportTsFileLocally.java | 8 +-
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 8 +
.../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 +-
.../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 +
.../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 +
.../base/AbstractSubscriptionConsumer.java | 4 +-
.../base/AbstractSubscriptionProviders.java | 48 +-
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 | 21 +-
.../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 ++++-
.../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 | 14 +-
.../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 | 162 +++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 207 +++-
.../iotdb/confignode/persistence/AuthorInfo.java | 70 +-
.../persistence/schema/ClusterSchemaInfo.java | 6 +-
...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 | 226 +----
.../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 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 11 +-
.../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 --
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 3 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 11 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +
.../PipeRealtimePriorityBlockingQueue.java | 2 +
.../subtask/processor/PipeProcessorSubtask.java | 5 +-
.../processor/PipeProcessorSubtaskWorker.java | 13 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../async/IoTDBDataRegionAsyncConnector.java | 3 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 49 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 18 +-
.../schemaregion/SchemaRegionListeningFilter.java | 8 +-
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 6 +
.../pipeconsensus/PipeConsensusReceiver.java | 55 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 44 +-
.../visitor/PipePlanToStatementVisitor.java | 18 +-
.../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 +++++--
.../grouped/HashAggregationOperator.java | 4 +-
.../grouped/StreamingAggregationOperator.java | 9 +-
.../grouped/StreamingHashAggregationOperator.java | 4 +-
.../relational/ColumnTransformerBuilder.java | 15 +
.../execution/schedule/DriverScheduler.java | 8 -
.../iotdb/db/queryengine/plan/Coordinator.java | 18 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 9 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 +-
.../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 | 9 +-
.../plan/analyze/schema/SchemaValidator.java | 13 +-
.../plan/execution/IQueryExecution.java | 2 +
.../queryengine/plan/execution/QueryExecution.java | 5 +
.../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 | 43 +-
.../plan/planner/TableOperatorGenerator.java | 9 +-
.../plan/node/load/LoadTsFilePieceNode.java | 6 +-
.../plan/node/write/RelationalDeleteDataNode.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 11 +-
.../relational/metadata/TableMetadataImpl.java | 20 +
.../fetcher/cache/TableDeviceSchemaCache.java | 19 +-
.../cache/TableDeviceSchemaCacheMetrics.java | 34 +
.../distribute/TableDistributedPlanGenerator.java | 58 +-
.../DataNodeLocationSupplierFactory.java | 22 +-
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../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 +-
.../plan/relational/sql/ast/LoadTsFile.java | 7 +
.../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 +-
.../plan/relational/sql/parser/AstBuilder.java | 170 +++-
.../plan/scheduler/load/LoadTsFileScheduler.java | 47 +-
.../plan/statement/StatementVisitor.java | 21 +
...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 | 23 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../execute/utils/MultiTsFileDeviceIterator.java | 14 +-
...BatchedFastAlignedSeriesCompactionExecutor.java | 26 +-
...edReadChunkAlignedSeriesCompactionExecutor.java | 40 +-
.../utils/AlignedSeriesBatchCompactionUtils.java | 28 +-
.../fast/FastAlignedSeriesCompactionExecutor.java | 23 +-
.../executor/fast/SeriesCompactionExecutor.java | 10 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 31 +-
.../utils/writer/FastCrossCompactionWriter.java | 10 +-
.../utils/writer/FastInnerCompactionWriter.java | 10 +-
.../CompactionDiskTSMIterator.java} | 28 +-
.../compaction/io/CompactionTsFileInput.java | 122 ++-
.../compaction/io/CompactionTsFileReader.java | 60 +-
.../compaction/io/CompactionTsFileWriter.java | 9 +
.../dataregion/flush/MemTableFlushTask.java | 2 +-
.../memtable/AlignedReadOnlyMemChunk.java | 10 +-
.../memtable/AlignedWritableMemChunk.java | 13 +-
.../dataregion/memtable/TsFileProcessor.java | 7 +-
.../dataregion/memtable/WritableMemChunkGroup.java | 2 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 5 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 4 +-
.../read/reader/chunk/MemAlignedPageReader.java | 6 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 4 +-
.../db/storageengine/load/LoadTsFileManager.java | 5 +-
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../load/config/LoadTsFileConfigurator.java | 20 +
...leStatementDataTypeConvertExecutionVisitor.java | 4 +
...eeStatementDataTypeConvertExecutionVisitor.java | 4 +
.../broker/SubscriptionPrefetchingQueue.java | 11 +
.../response/SubscriptionEventTabletResponse.java | 5 -
.../utils/TsFileRewriteOverPrecisedI64Scan.java | 223 +++++
.../utils/TsFileRewriteSmallRangeI64Scan.java | 230 +++++
.../iotdb/db/tools/utils/TsFileSequenceScan.java | 34 +-
.../iotdb/db/tools/utils/TsFileStatisticScan.java | 266 +++++
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 6 +-
.../apache/iotdb/db/utils/ModificationUtils.java | 9 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 4 +-
.../iotdb/db/utils/constant/SqlConstant.java | 2 +-
.../db/queryengine/execution/exchange/Utils.java | 3 +
.../operator/MergeTreeSortOperatorTest.java | 6 +
.../execution/operator/OperatorMemoryTest.java | 2 +
.../plan/parser/StatementGeneratorTest.java | 3 +
.../plan/relational/analyzer/ShowQueriesTest.java | 7 +-
...InconsistentCompressionTypeAndEncodingTest.java | 6 +-
.../FastInnerCompactionPerformerTest.java | 6 +-
.../repair/RepairUnsortedFileCompactionTest.java | 8 +-
.../CompactionTableModelTestFileWriter.java | 2 +-
.../compaction/utils/BatchCompactionUtilsTest.java | 39 +-
.../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 | 10 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 21 +
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 4 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 8 +
.../apache/iotdb/commons/conf/CommonConfig.java | 29 +-
.../iotdb/commons/conf/CommonDescriptor.java | 30 +-
.../iotdb/commons/consensus/ConsensusGroupId.java | 7 +-
.../task/connection/BlockingPendingQueue.java | 14 +
.../iotdb/commons/pipe/config/PipeConfig.java | 10 +
.../config/constant/PipeConnectorConstant.java | 5 +
.../pipe/connector/client/IoTDBClientManager.java | 6 +-
.../connector/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 8 +
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../options/PipeInclusionOptions.java | 15 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 11 +-
.../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 | 38 +-
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 +-
413 files changed, 14502 insertions(+), 4922 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 (98%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/basic}/IoTDBPipeDataSinkIT.java (85%)
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 (83%)
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 (94%)
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 (91%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeDoubleLivingIT.java (96%)
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} (77%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeNullValueIT.java (94%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{tablemodel =>
dual/tablemodel/manual/enhanced}/IoTDBPipeTypeConversionISessionIT.java (96%)
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 (92%)
rename integration-test/src/test/java/org/apache/iotdb/pipe/it/{autocreate =>
dual/treemodel/auto/basic}/IoTDBPipeDataSinkIT.java (85%)
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 (95%)
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 (95%)
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 (80%)
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 (97%)
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/Constants.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/ImportTsFileOperation.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/common/OptionsUtil.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AbstractExportData.java
copy
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/{tsfile/ImportTsFileBase.java
=> data/AbstractImportData.java} (55%)
delete mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/AsyncImportData.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ExportDataTable.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ExportDataTree.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataTable.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/data/ImportDataTree.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
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/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
