This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch fix_wal_create_error
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard ca51b0d2ae7 fix
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 5f0ad8c069c fix
add cd69d063e45 finish
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ca51b0d2ae7)
\
N -- N -- N refs/heads/fix_wal_create_error (cd69d063e45)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
dependencies.json | 14 +-
.../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 +
.../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 +
.../pipe/it/single/IoTDBPipePermissionIT.java | 27 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 6 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 6 +
.../scalar/IoTDBScalarFunctionTableIT.java | 23 +-
...tersectTableIT.java => IoTDBExceptTableIT.java} | 72 +-
...nFunctionIT.java => IoTDBLengthFunctionIT.java} | 80 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 8 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 44 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 16 +
.../it/session/IoTDBSessionRelationalIT.java | 12 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 5 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 -
.../org/apache/iotdb/session/NodesSupplier.java | 49 +-
iotdb-core/ainode/.gitignore | 3 +
iotdb-core/ainode/build_binary.py | 18 +-
iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 10 +-
.../iotdb/ainode/core/inference/pool_controller.py | 2 +-
.../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/poetry.lock | 2331 --------------------
.../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 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 6 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 6 +-
.../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 +-
iotdb-core/consensus/pom.xml | 14 +-
iotdb-core/datanode/pom.xml | 2 +-
.../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 +-
.../subtask/processor/PipeProcessorSubtask.java | 7 +
.../agent/task/subtask/sink/PipeSinkSubtask.java | 11 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 73 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 2 +-
.../protocol/airgap/IoTDBAirGapReceiverAgent.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 18 +-
.../visitor/PipeStatementExceptionVisitor.java | 8 +-
.../visitor/PipeStatementTSStatusVisitor.java | 8 +-
...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 +
.../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 +-
.../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 | 25 +-
.../relational/ColumnTransformerBuilder.java | 8 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 2 +
.../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 | 14 +-
.../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 | 55 +-
.../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 +-
...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 +-
.../optimizations/LogicalOptimizeFactory.java | 43 +-
.../optimizations/UnaliasSymbolReferences.java | 31 +
.../security/TreeAccessCheckVisitor.java | 24 +-
.../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 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 10 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 10 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 18 +-
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 21 +-
.../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 +-
.../allocation/AbstractNodeAllocationStrategy.java | 21 +-
.../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 +-
.../process/window/TableWindowOperatorTest.java | 51 +
.../plan/relational/analyzer/AnalyzerTest.java | 33 +-
...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 +-
.../plan/relational/analyzer/TSBSMetadata.java | 13 +
.../plan/relational/analyzer/TestMetadata.java | 25 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 9 +
.../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 | 105 +-
.../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 | 28 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 27 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 163 +-
.../schema/column/ColumnHeaderConstant.java | 5 +
.../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 | 18 +-
scripts/sbin/start-ainode.sh | 17 +-
scripts/sbin/windows/start-ainode.bat | 22 +-
260 files changed, 7628 insertions(+), 4482 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%)
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%)
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
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/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
