This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch share_mod_file
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from d8bfc98fb9a change test param
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 4ea1dc51be8 Merge branch 'master' into share_mod_file
add 622c1f996e2 move update mod file existence inside
add cf3d204501b Fix npe of ModFileManagement during compaction
No new revisions were added by this update.
Summary of changes:
.github/workflows/compile-check.yml | 2 +-
.../{pipe-it-2cluster.yml => pipe-it.yml} | 305 +++++-
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 12 +-
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 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 73 ++
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 25 +
.../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 +-
.../it/IoTDBLoadConfigurationTableIT.java} | 75 +-
.../it/db/it/IoTDBSetSystemStatusTableIT.java | 104 ++
.../query/old/query/IoTDBGreatestLeastTableIT.java | 305 ++++++
.../it/query/recent/IoTDBMaintainAuthIT.java | 289 ++++++
.../IoTDBNullValueIT.java} | 43 +-
.../it/query/recent/IoTDBQueryAuthIT.java | 320 ++++++
.../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 +-
.../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/pom.xml | 6 +-
iotdb-client/isession/pom.xml | 8 +-
iotdb-client/jdbc/pom.xml | 8 +-
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
iotdb-client/session/pom.xml | 10 +-
.../java/org/apache/iotdb/session/Session.java | 6 +
iotdb-core/ainode/pom.xml | 10 +-
iotdb-core/antlr/pom.xml | 2 +-
iotdb-core/confignode/pom.xml | 26 +-
.../request/ConfigPhysicalPlanVisitor.java | 221 ++++-
.../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 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 11 +-
iotdb-core/datanode/pom.xml | 40 +-
.../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 +
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../airgap/IoTDBDataNodeAirGapConnector.java | 3 +
.../async/IoTDBDataRegionAsyncConnector.java | 3 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../schemaregion/SchemaRegionListeningFilter.java | 8 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 44 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 10 +-
.../execution/exchange/SharedTsBlockQueue.java | 8 +-
.../execution/exchange/sink/SinkChannel.java | 11 +-
.../exchange/source/LocalSourceHandle.java | 4 +-
.../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 | 14 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 9 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 2 +-
.../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 | 68 ++
.../config/executor/ClusterConfigTaskExecutor.java | 56 +-
.../config/executor/IConfigTaskExecutor.java | 17 +-
.../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 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 16 +-
.../plan/planner/TableOperatorGenerator.java | 9 +-
.../relational/analyzer/StatementAnalyzer.java | 11 +-
.../relational/metadata/TableMetadataImpl.java | 20 +
.../DataNodeLocationSupplierFactory.java | 22 +-
.../plan/relational/security/AccessControl.java | 8 +
.../relational/security/AccessControlImpl.java | 62 +-
.../relational/security/AllowAllAccessControl.java | 5 +
.../plan/relational/sql/ast/AstVisitor.java | 24 +
.../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 +-
.../ast/{RemoveDataNode.java => RemoveRegion.java} | 45 +-
.../{StartRepairData.java => SetSystemStatus.java} | 6 +-
.../plan/relational/sql/parser/AstBuilder.java | 154 ++-
.../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 +-
.../impl/ReadChunkCompactionPerformer.java | 11 +-
.../task/InsertionCrossSpaceCompactionTask.java | 2 +-
.../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 +-
.../dataregion/modification/ModificationFile.java | 20 +-
.../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 | 1 +
.../db/storageengine/load/LoadTsFileManager.java | 5 +-
.../load/active/ActiveLoadTsFileLoader.java | 3 +-
.../load/config/LoadTsFileConfigurator.java | 20 +
.../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/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 +-
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 +-
.../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 | 12 +
.../iotdb/commons/conf/CommonDescriptor.java | 6 +
.../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 | 7 +
.../schema/column/ColumnHeaderConstant.java | 30 +
.../commons/schema/table/InformationSchema.java | 109 +++
.../relational/TableBuiltinScalarFunction.java | 2 +
iotdb-core/pom.xml | 2 +-
iotdb-core/relational-grammar/pom.xml | 2 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 23 +-
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 | 4 +-
313 files changed, 12666 insertions(+), 3607 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
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-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
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
=> RemoveRegion.java} (64%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{StartRepairData.java
=> SetSystemStatus.java} (86%)
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
