This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch force_ci/prepstm
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 43a754c4009 Implement PreparedStmt on the Server side (#16764)
add d48347cdc8d Pipe: support path exclusion under tree model (#16632)
add 43b89b9a480 Change the privilege of showVersionStatement #16736
add 49c625bb83e [AINode] Package AINode via PyInstaller (#16707)
add 96e8681dd51 Support the JDBC client to prevent SQL injection (#16734)
add b7f9f8d49af Fix that a deletion test may fail due to inconsistency
caused by leader redistribution (#16744)
add 7515568c8e4 Fixed the NPE caused by concurrent "check for
createTimeSeries" and deleteTimeSeries (#16742)
add 6e8748e0256 Pipe: Optimized the default behavior in meta sync for
retries to wait for other regions (#16740)
add f608a2d2e6a Adjust the exception message cause by the WHERE clause,
which uses a range comparison on the same field, specifically when the left
value of the range is greater than the right value of the range. (#16741)
add e53d27c0ad0 Pipe: Trimmed some of the pipe logs (#16747)
add db7c801d846 Active Load: Fixes errors caused by Load copying resource
files. (#16753)
add a6191d916b2 Pipe: Modify the Pipe configuration item log name to be
consistent with the Properties name. (#16732)
add 91e48f07f63 feat: encode load attributes in active load directories
(#16722)
add 1ebb9515767 [AINode] Enable AINode start as background (-d) (#16762)
add 3a6322028cd fix (#16702)
add a7f1527d04c reduce error log when compaction service is stopped & fix
bugs (#16756)
add d49d7dd7711 [AINode] Update AINodeClient for DataNode to borrow
(#16647)
add cd443ba9996 [AINode] Fix bug that AINode cannot compile in Windows
(#16767)
add bd97844bb7f fix (#16773)
add 2c381feda25 Load: Fixed the bug that mods is not deleted in load
tsFile when there are exceptions & Fixed the potential NPE in air gap agent
close() method (#16775)
add 2b47be756ad [AINode] Fix bug of sundial and forecast udf (#16768)
add 9fd9d7e818a Fixed the bugs related to device auto-create alignment
ignorance (#16780)
add f708b966238 Load: Active Load supports ModV2 (#16769)
add 0f2483fbe2e Load: Fixed the issue of TSFile parent directory being
null and TSFile resource being updated during the Load process. (#16751)
add b3509d6d6bf Load: Fixed parameter passing error in MoveFile function
(#16748)
add 0e209e73c21 Refine CN consensus layer API for procedure robustness
(#16303)
add 0ebdb878e57 Pipe: improved the memory calculation for tablets (#16739)
add c76c5fe3d5a Fixed the bug related to "Fixed the bugs related to device
auto-create alignment ignorance" (#16781)
add 9121208304c Load: Remove the getParentFile and exists checks from Load
New File (#16787)
add 36154e50300 Optimized the error message when the column is not
tag/attribute in device related SQLs (#16750)
add fbcb8a2c6ed Avoid connection reset error log printed (#16797)
add 0c23da2551f Fix that settle compaction may lgnore some newly incoming
deletions (#16799)
add 03b60d1390c Fix slowQueryThreshold & optimize encodeBatch (#16765)
add 4525d075867 Pipe: Adjusted the waiting time of temporary unavailable
exceptions (#16798)
add 50f92e48cf6 [AINode] Delete poetry.lock for easier maintain different
operating systems (#16793)
add 1c6a2b02ab9 Bump ratis to apache 3.2.1 (#16801)
add 448592e3c8d Pipe: Fixed the check for no permission 2 (#16804)
add 0431d5abd45 Update ratis-thirdparty-misc version to 1.0.10 (#16807)
add 100c5a3c5c6 Fix window partiton across two TsBlock bugs (#16809)
add d99740860c2 may_fix (#16814)
add fb899b16b92 Fixed the bug of 305 error for unsupported table
opreations #16816
add ddcc64618b5 Fixed the calculation error of schema cache (#16818)
add 03bc2606563 Fixed the concurrency issue of region migrate and load
(#16796)
add c4114b95d94 Add 'show available urls' (#16441)
add 19ebbe31099 Added back the mis-deleted "()" in last cache (#16824)
add 8cb4b9be877 Reduced the auth log when paths are too many (#16825)
add 23be2201b81 perf: Optimize wide table write performance (#16699)
add 85b8f168d7c implement the except (distinct | all ) for table model
#16760
add 85281fac2a3 added support for Blob objects to the length() function,
allowing for calculating the byte size for Blob inputs (#16170)
add bd813d85c62 implement intersect and except related optimization rule:
MergeIntersect, MergeExcept, RemoveEmptyIntersectBranchs,
EvaluateEmptyIntersect, PruneIntersectSourceColumns, PruneExceptSourceColmns
(#16761)
add e3127e6c61f Pipe: Ignore logging when `returnSelf` is called in the
event of an exception in `AsyncClient`. (#16827)
add cb705d17b85 Fixed the schema cache calculation 2 & The potential NPE
caused by concurrent invalidate and update (#16834)
add 8cd141895b1 Fix the check of grant option for tree model (#16845)
add f68c49e349b Pipe: Fixed the bug that lower version tablet may cause
NPE when sent to 2.x version & The temporary exception may be wrongly reported
(#16843)
add 263c23bd69d Pipe: Fixed the auth implementation error (#16847)
add 45f26455926 Fix NPE during compaction when disk space is insufficient
(#16841)
add db02437f00f PipePlugin: Optimized the errorCode && Fixed the
case-sensitive semantic (#16851)
add 5bc4779ba43 Pipe: Fix NullPointerException in concurrent event access
(#16849)
add 5cf60df3afc may-c (#16859)
add f4d628a7d6a Pipe: Prevent duplicate error logging in
AsyncPipeDataTransferServiceClient (#16856)
add 1b2b32bc2a3 perf: Optimize TypeManager allocation in StatementAnalyzer
(#16870)
add 1746cdb28b1 Add system table named connections to resolve the idle
session can be found (#16846)
add 2db7b21bce1 Switch to at.yawk.lz4:lz4-java:1.10.0 (#16871)
add 0bb9e96ece7 Bump at.yawk.lz4:lz4-java from 1.10.0 to 1.10.1 (#16874)
new ab853e8c9b9 Resolve conflicts
The 1 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-1c1d1a.yml | 2 +-
LICENSE-binary | 4 +-
dependencies.json | 16 +-
integration-test/src/assembly/mpp-test.xml | 2 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 25 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 62 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 21 +
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 145 ++
.../iotdb/db/it/IoTDBLoadTsFileWithModIT.java | 60 +-
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 16 +
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 3 +-
.../it/auth/IoTDBSystemPermissionRelationalIT.java | 3 +-
.../it/schema/IoTDBCreateAlignedTimeseriesIT.java | 22 +
.../db/it/schema/IoTDBCreateTimeseriesIT.java | 8 +
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 13 +-
.../iotdb/db/it/utils/TSDataTypeTestUtils.java | 113 +
.../pipe/it/dual/tablemodel/TableModelUtils.java | 8 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 61 +
.../auto/basic/IoTDBTreePatternFormatIT.java | 616 +++---
.../treemodel/manual/IoTDBPipeInclusionIT.java | 72 +
.../pipe/it/single/IoTDBPipePermissionIT.java | 27 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 8 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 6 +
.../scalar/IoTDBScalarFunctionTableIT.java | 23 +-
...tersectTableIT.java => IoTDBExceptTableIT.java} | 72 +-
...nFunctionIT.java => IoTDBLengthFunctionIT.java} | 80 +-
.../it/query/recent/IoTDBMaintainAuthIT.java | 8 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 12 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 44 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 16 +
.../it/session/IoTDBSessionRelationalIT.java | 12 +-
.../iotdb/session/it/IoTDBConnectionsIT.java | 364 ++++
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 17 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 154 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 5 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 +-
iotdb-client/session/pom.xml | 14 +
.../org/apache/iotdb/session/NodesSupplier.java | 49 +-
iotdb-core/ainode/.gitignore | 9 +-
iotdb-core/ainode/ainode.spec | 199 ++
iotdb-core/ainode/ainode.xml | 17 +-
iotdb-core/ainode/build_binary.py | 602 ++++++
iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 10 +-
iotdb-core/ainode/iotdb/ainode/core/config.py | 28 +-
iotdb-core/ainode/iotdb/ainode/core/constant.py | 18 +-
.../iotdb/ainode/core/inference/pool_controller.py | 49 +-
.../pool_scheduler/basic_pool_scheduler.py | 7 +-
iotdb-core/ainode/iotdb/ainode/core/log.py | 4 +-
.../iotdb/ainode/core/manager/inference_manager.py | 4 +-
.../ainode/core/model/sundial/modeling_sundial.py | 13 +-
.../ainode/core/model/timerxl/modeling_timer.py | 6 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 2 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 1 +
iotdb-core/ainode/iotdb/ainode/core/script.py | 80 +-
iotdb-core/ainode/poetry.lock | 2226 --------------------
iotdb-core/ainode/pom.xml | 92 +-
iotdb-core/ainode/pyproject.toml | 29 +-
.../ainode/resources/syncPythonVersion.groovy | 33 -
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 2 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 7 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
iotdb-core/confignode/pom.xml | 2 +-
.../async/AsyncAINodeHeartbeatClientPool.java | 7 +-
.../request/read/model/ShowModelPlan.java | 4 +-
.../iotdb/confignode/manager/ConfigManager.java | 26 +-
.../apache/iotdb/confignode/manager/IManager.java | 18 +-
.../iotdb/confignode/manager/ModelManager.java | 37 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 6 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 13 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 6 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 6 +-
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 46 +-
.../procedure/CompletedProcedureRecycler.java | 21 +-
.../iotdb/confignode/procedure/Procedure.java | 27 +-
.../confignode/procedure/ProcedureExecutor.java | 88 +-
.../procedure/TimeoutExecutorThread.java | 12 +-
.../procedure/impl/model/CreateModelProcedure.java | 4 +-
.../procedure/impl/model/DropModelProcedure.java | 7 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 4 +-
.../procedure/store/ConfigProcedureStore.java | 26 +-
.../procedure/store/IProcedureStore.java | 10 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 69 +-
...figPhysicalPlanTreePatternParseVisitorTest.java | 7 +-
iotdb-core/consensus/pom.xml | 14 +-
iotdb-core/datanode/pom.xml | 4 +-
.../assembly/resources/conf/logback-datanode.xml | 15 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 9 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 12 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 -
.../db/consensus/DataRegionConsensusImpl.java | 6 +
.../dataregion/DataRegionStateMachine.java | 15 +-
.../schemaregion/SchemaExecutionVisitor.java | 44 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../agent/task/connection/PipeEventCollector.java | 4 +-
.../subtask/processor/PipeProcessorSubtask.java | 7 +
.../agent/task/subtask/sink/PipeSinkSubtask.java | 11 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 73 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../parser/TsFileInsertionEventParserProvider.java | 6 +-
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 29 +-
.../visitor/PipeStatementExceptionVisitor.java | 8 +-
.../visitor/PipeStatementTSStatusVisitor.java | 43 +-
.../PipeStatementTreePatternParseVisitor.java | 22 +-
...leStatementDataTypeConvertExecutionVisitor.java | 4 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 4 +-
.../resource/memory/InsertNodeMemoryEstimator.java | 55 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 62 +-
.../airgap/IoTDBSchemaRegionAirGapSink.java | 6 +-
.../handler/PipeConsensusDeleteEventHandler.java | 2 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 18 +-
.../handler/PipeTransferTrackableHandler.java | 16 +-
.../async/handler/PipeTransferTsFileHandler.java | 15 +-
.../thrift/sync/IoTDBDataRegionSyncSink.java | 3 +-
.../thrift/sync/IoTDBSchemaRegionSink.java | 6 +-
.../sink/util/sorter/PipeTabletEventSorter.java | 5 +
.../source/dataregion/IoTDBDataRegionSource.java | 6 +-
.../realtime/assigner/DisruptorQueue.java | 4 +-
.../PipePlanTreePatternParseVisitor.java | 41 +-
.../db/protocol/client/AINodeClientFactory.java | 133 ++
.../iotdb/db/protocol/client/ConfigNodeClient.java | 51 +-
.../db/protocol}/client/ainode/AINodeClient.java | 168 +-
.../client/ainode/AINodeClientManager.java | 75 +
.../client/ainode/AsyncAINodeServiceClient.java | 2 +-
.../iotdb/db/protocol/session/IClientSession.java | 16 +
.../iotdb/db/protocol/session/SessionManager.java | 14 +
.../db/queryengine/common/ConnectionInfo.java | 64 +
.../common/header/DatasetHeaderFactory.java | 4 +
.../execution/executor/RegionWriteExecutor.java | 4 +-
.../fragment/FragmentInstanceContext.java | 2 +-
.../fragment/FragmentInstanceExecution.java | 2 +-
.../operator/process/ai/InferenceOperator.java | 4 +-
.../process/window/TableWindowOperator.java | 2 +
.../InformationSchemaContentSupplierFactory.java | 64 +-
.../relational/ColumnTransformerBuilder.java | 8 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 19 +-
.../analyze/cache/partition/PartitionCache.java | 2 +-
.../dualkeycache/impl/CacheEntryGroupImpl.java | 6 +
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 61 +-
.../schema/dualkeycache/impl/ICacheEntryGroup.java | 3 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 14 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 4 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 51 +-
.../execution/config/TableConfigTaskVisitor.java | 24 +-
.../execution/config/TreeConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 142 +-
.../config/executor/IConfigTaskExecutor.java | 2 +
...AINodesTask.java => ShowAvailableUrlsTask.java} | 30 +-
.../config/metadata/ai/ShowAIDevicesTask.java | 2 +-
.../config/metadata/ai/ShowLoadedModelsTask.java | 4 +-
.../config/metadata/ai/ShowModelsTask.java | 4 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 18 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/node/load/LoadSingleTsFileNode.java | 6 +-
.../relational/analyzer/StatementAnalyzer.java | 64 +-
.../analyzer/StatementAnalyzerFactory.java | 17 +-
.../function/tvf/ForecastTableFunction.java | 8 +-
.../plan/relational/metadata/Metadata.java | 10 +
.../relational/metadata/TableMetadataImpl.java | 24 +-
.../fetcher/TableHeaderSchemaValidator.java | 378 ++++
.../fetcher/cache/TableDeviceCacheEntry.java | 8 +-
.../fetcher/cache/TableDeviceLastCache.java | 56 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 8 +-
.../cache/TableDeviceSchemaCacheMetrics.java | 9 +-
.../fetcher/cache/TreeDeviceNormalSchema.java | 6 +-
.../plan/relational/planner/RelationPlanner.java | 24 +-
.../plan/relational/planner/TableModelPlanner.java | 8 +-
...rceColumns.java => EvaluateEmptyIntersect.java} | 41 +-
...ntIntersectAll.java => ImplementExceptAll.java} | 47 +-
...on.java => ImplementExceptDistinctAsUnion.java} | 52 +-
.../rule/ImplementIntersectDistinctAsUnion.java | 3 +-
.../rule/{MergeUnion.java => MergeExcept.java} | 15 +-
.../rule/{MergeUnion.java => MergeIntersect.java} | 13 +-
.../iterative/rule/PruneDistinctAggregation.java | 27 +-
...eColumns.java => PruneExceptSourceColumns.java} | 14 +-
...lumns.java => PruneIntersectSourceColumns.java} | 15 +-
.../iterative/rule/RemoveEmptyExceptBranches.java | 139 ++
.../planner/iterative/rule/SetOperationMerge.java | 123 +-
.../iterative/rule/SetOperationNodeTranslator.java | 4 +-
.../node/{IntersectNode.java => ExceptNode.java} | 21 +-
.../plan/relational/planner/node/Patterns.java | 20 +-
.../DataNodeLocationSupplierFactory.java | 1 +
.../optimizations/LogicalOptimizeFactory.java | 43 +-
.../optimizations/UnaliasSymbolReferences.java | 31 +
.../security/TreeAccessCheckVisitor.java | 26 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/ast/InsertRows.java | 19 +-
.../plan/relational/sql/ast/RenameColumn.java | 5 +-
.../plan/relational/sql/ast/RenameTable.java | 5 +-
.../{ShowAIDevices.java => ShowAvailableUrls.java} | 12 +-
.../relational/sql/ast/WrappedInsertStatement.java | 414 +++-
.../plan/relational/sql/parser/AstBuilder.java | 7 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 12 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 6 +-
.../plan/statement/StatementVisitor.java | 6 +
.../plan/statement/crud/InsertBaseStatement.java | 147 +-
.../crud/InsertMultiTabletsStatement.java | 6 +
.../plan/statement/crud/InsertRowStatement.java | 42 +
.../crud/InsertRowsOfOneDeviceStatement.java | 6 +
.../plan/statement/crud/InsertRowsStatement.java | 6 +
.../plan/statement/crud/InsertTabletStatement.java | 68 +-
.../plan/statement/crud/LoadTsFileStatement.java | 18 +-
...tement.java => ShowAvailableUrlsStatement.java} | 18 +-
.../db/queryengine/plan/udf/UDTFForecast.java | 9 +-
...ormer.java => BlobLengthColumnTransformer.java} | 23 +-
.../rescon/MemSchemaEngineStatistics.java | 3 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 5 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 16 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 16 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 18 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 21 +-
.../schemaengine/schemaregion/utils/MetaUtils.java | 6 +-
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 10 +
.../write/req/impl/CreateTimeSeriesPlanImpl.java | 10 +
.../db/schemaengine/table/DataNodeTableCache.java | 17 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 3 +-
.../iotdb/db/storageengine/StorageEngine.java | 13 +-
.../db/storageengine/dataregion/DataRegion.java | 289 ++-
.../dataregion/IDataRegionForQuery.java | 2 +-
.../dataregion/VirtualDataRegion.java | 2 +-
.../execute/task/AbstractCompactionTask.java | 3 +-
.../execute/task/InnerSpaceCompactionTask.java | 17 +-
.../execute/task/SettleCompactionTask.java | 5 +
.../compaction/repair/RepairTimePartition.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 18 +-
.../dataregion/snapshot/SnapshotTaker.java | 14 +-
.../dataregion/tsfile/TsFileResource.java | 43 +-
.../file/UnsealedTsFileRecoverPerformer.java | 6 +-
.../db/storageengine/load/LoadTsFileManager.java | 40 +-
.../load/active/ActiveLoadDirScanner.java | 43 +-
.../load/active/ActiveLoadPathHelper.java | 282 +++
.../load/active/ActiveLoadPendingQueue.java | 17 +-
.../load/active/ActiveLoadTsFileLoader.java | 42 +-
.../load/config/LoadTsFileConfigurator.java | 18 +
...leStatementDataTypeConvertExecutionVisitor.java | 10 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 10 +-
.../db/storageengine/load/disk/MinIOSelector.java | 10 +-
.../ActiveLoadUtil.java => util/LoadUtil.java} | 88 +-
.../rescon/memory/PrimitiveArrayManager.java | 1 +
.../db/utils/datastructure/AlignedTVList.java | 20 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 51 +
.../org/apache/iotdb/db/auth/TreeAccessTest.java | 84 +
.../cache/TreeDeviceSchemaCacheManagerTest.java | 14 +
.../db/metadata/path/MeasurementPathTest.java | 4 +-
.../db/pipe/pattern/TreePatternCoverageTest.java | 133 ++
.../PipeStatementTreePatternParseVisitorTest.java | 202 +-
.../PipePlanTreePatternParseVisitorTest.java | 7 +-
.../process/window/TableWindowOperatorTest.java | 51 +
.../plan/relational/analyzer/AnalyzerTest.java | 40 +-
.../plan/relational/analyzer/AuthTest.java | 10 +-
...zeTest.java => EvaluateEmptyIntersectTest.java} | 27 +-
.../{IntersectTest.java => ExceptTest.java} | 51 +-
.../plan/relational/analyzer/MergeExceptTest.java | 147 ++
...{IntersectTest.java => MergeIntersectTest.java} | 99 +-
...est.java => RemoveEmptyExceptBranchesTest.java} | 106 +-
.../analyzer/RowPatternRecognitionTest.java | 4 +-
.../plan/relational/analyzer/TSBSMetadata.java | 13 +
.../plan/relational/analyzer/TestMetadata.java | 25 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 9 +
.../plan/relational/planner/PlanTester.java | 4 +-
.../plan/statement/InsertStatementTest.java | 97 +-
.../scalar/BlobLengthColumnTransformerTest.java | 148 ++
.../DataNodeInternalRPCServiceImplTest.java | 59 +-
.../iotdb/db/storageengine/StorageEngineTest.java | 4 +-
.../storageengine/dataregion/DataRegionTest.java | 4 +-
.../inner/InnerSpaceCompactionExceptionTest.java | 16 +
.../repair/RepairUnsortedFileSchedulerTest.java | 10 +-
.../compaction/utils/CompactionTestFileWriter.java | 6 +-
.../memtable/AlignedTVListIteratorTest.java | 57 +
.../dataregion/snapshot/IoTDBSnapshotTest.java | 2 +-
.../apache/iotdb/db/utils/TSDataTypeTestUtils.java | 111 +
.../datastructure/PrimitiveArrayManagerTest.java | 12 +-
iotdb-core/node-commons/pom.xml | 8 +-
.../apache/iotdb/commons/client/ClientManager.java | 25 +
.../iotdb/commons/client/ClientPoolFactory.java | 52 -
.../commons/client/ainode/AINodeClientManager.java | 40 -
.../async/AsyncPipeDataTransferServiceClient.java | 21 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 165 +-
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../apache/iotdb/commons/path/MeasurementPath.java | 26 -
.../org/apache/iotdb/commons/path/PartialPath.java | 26 +
.../task/subtask/PipeAbstractSinkSubtask.java | 13 +
.../iotdb/commons/pipe/config/PipeConfig.java | 61 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 42 +-
.../pipe/config/constant/PipeSourceConstant.java | 5 +
.../datastructure/pattern/IoTDBTreePattern.java | 68 +-
.../pattern/IoTDBTreePatternOperations.java | 52 +
.../datastructure/pattern/PrefixTreePattern.java | 70 +-
.../datastructure/pattern/SingleTreePattern.java | 59 -
.../pipe/datastructure/pattern/TreePattern.java | 369 +++-
.../pattern/UnionIoTDBTreePattern.java | 115 +-
.../datastructure/pattern/UnionTreePattern.java | 17 +-
.../pattern/WithExclusionIoTDBTreePattern.java | 213 ++
.../pattern/WithExclusionTreePattern.java | 119 ++
.../pipe/receiver/PipeReceiverStatusHandler.java | 181 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 14 +-
.../schema/column/ColumnHeaderConstant.java | 13 +
.../commons/schema/table/InformationSchema.java | 17 +
.../schema/table/InsertNodeMeasurementInfo.java | 244 +++
.../schema/table/TsFileTableSchemaUtil.java | 207 ++
.../apache/iotdb/commons/schema/table/TsTable.java | 226 +-
.../schema/table/column/FieldColumnSchema.java | 1 +
.../schema/table/column/TsTableColumnSchema.java | 6 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 92 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 7 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 59 +-
.../PipeReceiverStatusHandlerTest.java | 302 +++
.../commons/pipe/task/PipeSleepIntervalTest.java | 83 +
.../schema/table/TsFileTableSchemaUtilTest.java | 748 +++++++
.../apache/iotdb/commons/utils/FileUtilsTest.java | 79 +
.../db/relational/grammar/sql/RelationalSql.g4 | 11 +-
.../src/main/thrift/confignode.thrift | 83 +-
pom.xml | 34 +-
scripts/conf/ainode-env.sh | 138 --
scripts/conf/windows/ainode-env.bat | 129 --
scripts/sbin/start-ainode.sh | 56 +-
scripts/sbin/windows/start-ainode.bat | 62 +-
322 files changed, 11125 insertions(+), 5766 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/utils/TSDataTypeTestUtils.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBIntersectTableIT.java
=> IoTDBExceptTableIT.java} (63%)
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{scalar/IoTDBFromBase64ColumnFunctionIT.java
=> IoTDBLengthFunctionIT.java} (51%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/session/it/IoTDBConnectionsIT.java
create mode 100644 iotdb-core/ainode/ainode.spec
create mode 100644 iotdb-core/ainode/build_binary.py
delete mode 100644 iotdb-core/ainode/poetry.lock
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/AINodeClientFactory.java
rename iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons =>
datanode/src/main/java/org/apache/iotdb/db/protocol}/client/ainode/AINodeClient.java
(74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/ainode/AINodeClientManager.java
rename iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons =>
datanode/src/main/java/org/apache/iotdb/db/protocol}/client/ainode/AsyncAINodeServiceClient.java
(98%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/common/ConnectionInfo.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{relational/ShowAINodesTask.java
=> ShowAvailableUrlsTask.java} (75%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneUnionSourceColumns.java
=> EvaluateEmptyIntersect.java} (53%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{ImplementIntersectAll.java
=> ImplementExceptAll.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{ImplementIntersectDistinctAsUnion.java
=> ImplementExceptDistinctAsUnion.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{MergeUnion.java
=> MergeExcept.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{MergeUnion.java
=> MergeIntersect.java} (81%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneUnionSourceColumns.java
=> PruneExceptSourceColumns.java} (85%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{PruneUnionSourceColumns.java
=> PruneIntersectSourceColumns.java} (84%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/RemoveEmptyExceptBranches.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{IntersectNode.java
=> ExceptNode.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowAIDevices.java
=> ShowAvailableUrls.java} (84%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{ShowClusterStatement.java
=> ShowAvailableUrlsStatement.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/{CRC32Transformer.java
=> BlobLengthColumnTransformer.java} (72%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadPathHelper.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/{active/ActiveLoadUtil.java
=> util/LoadUtil.java} (61%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/AuthorityCheckerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/auth/TreeAccessTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/TreePatternCoverageTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/{ExplainAnalyzeTest.java
=> EvaluateEmptyIntersectTest.java} (64%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/{IntersectTest.java
=> ExceptTest.java} (70%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/MergeExceptTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/{IntersectTest.java
=> MergeIntersectTest.java} (58%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/{IntersectTest.java
=> RemoveEmptyExceptBranchesTest.java} (50%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/BlobLengthColumnTransformerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/utils/TSDataTypeTestUtils.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClientManager.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/IoTDBTreePatternOperations.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/SingleTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionIoTDBTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/InsertNodeMeasurementInfo.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/table/TsFileTableSchemaUtil.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/datastructure/PipeReceiverStatusHandlerTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/task/PipeSleepIntervalTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/schema/table/TsFileTableSchemaUtilTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/utils/FileUtilsTest.java
delete mode 100644 scripts/conf/ainode-env.sh
delete mode 100644 scripts/conf/windows/ainode-env.bat
