This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch fix_count_1
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 380fe29d60c optimize count(constant) to count(*)
add df9dc4900fb Add exchange node for every children of
MultiChildProcessNode
add 1dcf94262f8 fix: memory cost for aligned tvlist (#15079)
add 8aaaf8ea0c1 [feat](query) Implement column name match when query in
TableModel (#14928)
add 591fc141534 Try fix error inconsistent bug
add 6a0815577c2 Modify the error message for when parameters do not match
add 06c0911adca [RTO/RPO] Phi logging/concurrency Improvement (#15092)
add 69fca073930 Pipe: Fix pipe executor stuck by unlimited file event
memory allocation retries & Pipe: Fix IO triggered in disruptor & Pipe: Fix
forceAllocateIfSufficient & Load: Remove RM detect logic during the second
phase (#15085) (#15091)
add 2d0ba711075 Int + Date and Long + Date do not check if the date
exceeds the range
add bcb18d24a01 IoTConsensusV2: Retry with power-increasing interval when
follower is read-only (#15075)
add 98f397c4c49 Optimize the logic of get ReplicaSets for devices
add 8f15cceca31 Refactor DeviceEntry's attributeValues from List<Binary>
to Binary[] to reduce the cost of ramBytesUsed()
add a8e5080fc9c Remove useless metrics in AggTableScan and make the
TimeseriesMetadataCache get time as FI level
add 79a6e12b486 Close Session In ImportDataTable (#15065)
add d3bd5c7bec3 Omitted the useless distinct logic for device when
determined predicate does not contain "OR"
add 07e0d21478a [opt](query) Improve the logic to calculate
TRegionReplicaSets for devices (#15102)
add 98acf8e5090 Optimized the query logic to make schema or weak data
query read from local first & random if without local (#15106)
add a637327f31d fix create region group (#15108)
add 19067243d0c Subscription IT: fix
IoTDBConsumer2With1TopicShareProcessTsfileIT (#15110)
add 010843f8933 Optimized the show/query devices logic to only return
required attributes & Reduced unnecessary CPU usage in schema tsBlock building
(#15109)
add ec06abee8fc Fix template extension with null value (#15103)
add 35377c69004 Make error msg be semantic when the functionality is not
supported
add 385d0df5f9f Enhance remove unexisted confignode error message #15117
add c09bb166883 Optimize query execution in easy count(*) cases
add 5ab0c1adbfd Try to compatiable with 1.3.X view
add c6d1f493b0d Fix the wrong time index type check in
CrossSpaceCompaction (#15095)
add 93197a426ea fix mods file metrics (#15107)
add 93ec99d7ad0 Make removed confignode can rejoin cluster without
deleting data dir (#15118)
add 411f45f99a2 feat: move costTime to execute finished
add 8e650cbb1e1 Pipe: Reduced the log of epoch switching & Optimized the
memory calculation of insertion event & Refactor & Optimized the memory
reservation logic of tsFile parser provider & Added the missing parsing logic +
Fixed the wrong listening types to table meta sync & Skipped the file parsing
in privilege for empty file and root user & Subscription IT: assertGte for
received tsfile count (#15068)
add 0e395feb01c Pipe: Added memory control for receiver insert statements
(#15046)
add ab784fbfabb Revert "Optimized the query logic to make schema or weak
data query read from local first & random if without local (#15106)" (#15127)
add 50a48ce42b3 Load & Region Migrate: Notify all DNs before and after RM
(#15032)
add db614fb8eda IoTConsensusV2: Fix concurrency bug when client traffic is
extremely high (#15129)
add c792db04207 Trim port in stop scripts & data dir (#15134)
add f76c2c98251 Enhance remove unexisted datanode error message #15138
add f4e6660f06d Fix duplicate recovery of RelationalInsertTabletNode
(#15105)
add da246d7ae06 perf: various types of iterator for multiple tvlists in
memchunk (#15114)
add 262605e7657 RegionMigrateProcedure and RegionReconstructProcedure no
longer acquire lock #15122
add d072d6f066d Load: Support converting mini TsFile into Tablets & Adjust
the way to extract metrics & Fix file not delete when analysis cast happens &
Pipe IT: Ignore IoTDBPipeProcessorIT.testTumblingTimeSamplingProcessor (#14784)
add 346af31db5e Rewrite the permission & Fixed the bug of show/desc tables
details for Information schema
add cfec4998ae9 Pipe: iotdb-thrift-connector async retry mechanism (#14916)
add 421ed660bf6 Fix privilege bug in JDBC (#15141)
add 4adabfd32b6 fix: MemoryNotEnough exception when flushing try to
release tvlist (#15143)
add 52d1df65382 Fix bug that the partition table auto cleaner cannot be
activated (#15158)
add ecce8e93d2e Fixed table dead lock problem & Separate the lock of tree
/ table & Added lock for CreateOrUpdateDevice for pipe transfer (#15152)
add 69715dff132 Fix optimizers doesn't work when execute Explain Analyze
query
add 7cef068e674 Pipe: Fixed the NPE for last table node in snapshot parser
& Added judging logic when table is also device in snapshot parser & Refactor &
Fixed the missing trimming logic for tsFile & Enhanced the table idempotency
logic & Fixed the ttl + table database privilege logic at receiver side & Fixed
the bug that the table write auto-create-db does not check privilege (#15135)
add cd5cd233d68 Updated moquette version to fix MQTT write direct memory
leak issue (#15144)
add f16cee80e50 Pipe: Fixed the bug that OPC DA sink may free a string
multiple times (#15165)
add b4e0b0278f5 Fix broken file genaterated after insert null to aligned
timeseries (#15163)
add c215fef2acc Fix table model UDF can be invoked after dropped.
add 3ec698db88c Clean databaseName when setSqlDialect
add af03c1692b4 [RTO/RPO] Topology awareness for query plan (#15014)
add f855c5b47d2 IoTConsensusV2: Fix some remain concurrent risks for
stronger robustness. #15172
add af7ae01d1b5 Directly throw DateTimeParseException instead of wrapping
RuntimeException (#15096)
add d34f1c53c59 Restore rollback for UnsetTemplateProcedure
add 82793c22585 Revert "Clean databaseName when setSqlDialect"
add a2f49dce98e Revert "Fix optimizers doesn't work when execute Explain
Analyze query"
add f56e06b32c7 Make null comment display "null" instead of "" in details
queries & Updated tsFile version
add 45e3900a111 Fix null timestamp (#15177)
add ee779e2b499 Fix database hint of CLI when change sql_dialect back to
table
add bc078fccc89 Pipe: Fixed Async Connector Repeatedly Putting Events into
RetryQueue (#15179)
add 149756e3a25 Subscription: intro SubscriptionLogManager for global
uniform downsampling of prefetched logs (#15175)
add 598080b47f7 Fixed the show regions with specified database & grant /
revoke with ""
add 33d5b195fb0 Support Training Module of AINode
add 242db7672c7 Update Cli -help information (#15159)
add c520c39ff2f use getter for_encryptParam and change tsfile version
(#15185)
add 5f635bf464e DAL: Remove dal file after drop databases or remove
dataRegions (#15191)
add 299c3df372c Improve ConfigNode removing #15189
add a5c1d117ea5 Load: Added the missing permission check for auto-create
database in loading tsFile (#15190)
add 0f0aaf410da Pipe: Fixed the authority for table model insertion
(#15186)
add 77b7541eb7e Fix incorrect os dirs creation (#15196)
add 91fb32a5c3a Pipe: Added default logic for username / password in tree
sql-dialect pipes & Fixed the NPE for configNode table schema snapshot parsing
need (#15200)
add e86ec17bc95 Pipe: Add metrics for tsfile to tablets invocation call
count and time (#15202)
add c986324b0e6 Pipe: Enable showing WRITE_BACK_SINK (#15207)
add 3805b47e58b remove export tsfile script (#15206)
add e62bbf52833 Pipe: Enable showing WRITE_BACK_SINK (Fix IoTDBDatabaseIT)
(#15209)
add a81c5c6ac70 Load: Support multi-disks awareness for IoTV2 and Pipe
(#15181)
add 7fe614c7cc2 Pipe: Added close for tree session in WriteBackConnector
(#15211)
add 7bfcb4965c1 fix: clone & delete issues (#15153)
add 4678776f5c1 Pipe Plugin: Fix ClassLoader and Visibility not
initialized from CN snapshot after reboot (#15212)
add f66fcd91642 Pipe: Fixed the NPE of OPC UA Sink in table model when
there are null values & Deleted the extra folder of opc ua sink in table model
(#15215)
add ebb1bcf8910 Load: Add default value for multi disks awareness (#15216)
add 3d1cd0ea7f6 Pipe: Fix the problem of missing points in TsFile of
parsing table model (#15217)
add 0ee458e991f Added retry for insertion when fetch table schema failed
due to connection error & Improved the retry mechanism of client rpc
add a6088a28a07 [RTO/RPO] Chore: Fix remaining issues in PR 15014 (#15171)
add c5d0c397d98 Pipe: Added userName / password logic for alter pipe
replace statement (#15219)
add 630a3d255d9 Set safeDeletedSearchIndex for iotv2 to accelerate wal
deletion #15221
add 680026eefea Pipe: Prevent Duplicate Time Usage Reporting on Close in
PipeTsFileToTabletsMetrics (#15220)
add a8c80ecb140 Load: Batched tablet insertion during conversion (#15125)
add 08c29635d38 Pipe Plugin: Only Allow Create Model Compatible Plugins
(#15227)
add c746da2faec Deleted the useless read lock in getDeviceAttribute
add 8889255c0c4 Load: Implement region operations cache for load × region
migration detection (#15210)
add 7e4e01cc632 Load & Pipe: Support Active Load Table Model TsFiles &
Support Async Load in SQL & Support Async Load Strategy in Pipe (#15208)
add bf2eee9ad1e Fix: Null value settings not applying correctly in tablet.
(#15228)
add c9ec0fda2d1 Subscription: distinguish between reference count of ack
and clean in tsfile batch to avoid cleaning before ack (#15229)
add 4256ea48ad1 Fix BigArray NPE of some aggregation functions (first,
last, sum, extreme) when groups are more than 1024 in aggregation query
add 9b406e15353 update description when file_type is csv, sql_dialect is
table and table is not required (#15232)
add 3746f8cbae8 Merge branch 'master' of github.com:apache/iotdb
add 1697f545307 Fixed the NullPointerException caused by non-current table
procedures #15238
add b6fea634d61 Add some supplementary logs during partition allocation
(#15234)
add 4350a56c237 Description add the file name when importing file
exception (#15237)
add 46fc1e0a6fa Pipe: Fixed the tsFile parsing & write-back-sink auto
create db bug (#15240)
add e237f723974 [Python-Client] Use executeV2 interface to query
add 304fbab00bd Unifying Exception Messages for Aggregation Functions
(#15231)
add b1d4fedb33c Pipe IT: Fixed the issue that the Pipe IT test error log
could not be printed (#15242)
add 5f28e331d29 Pipe: Optimized the error log when source/sink's username
is without password in alter (#15241)
add c0a642892f7 Pipe: Added memory control for aligned chunk reader in
TsFileInsertionEventScanParser & TsFileInsertionEventTableParserTabletIterator
(#15222)
add 7c301137057 Add GroupNode and parallelize TableFunctionProcessorNode
add 91d067b161e Pipe: Fix stuck caused by async connector client not
returned after transferring tsfiles & Fix validateTsFile and
shouldMarkAsPipeRequest may not be effective (#15245) (#15249)
add 5ddd4234666 using correct encoding in read chunk compaction (#15250)
add 7caaf2671a1 Merge branch 'master' of github.com:apache/iotdb
add efd22d53c9c Merge branch 'master' into fix_count_1
add 177f13d9954 add ut
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 10 +-
.github/workflows/pipe-it.yml | 54 +-
dependencies.json | 10 +-
.../it/cluster/IoTDBClusterNodeGetterIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 3 +-
.../it/schema/IoTDBDeleteAlignedTimeseriesIT.java | 42 +
.../iotdb/db/it/schema/IoTDBExtendTemplateIT.java | 7 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 8 +
.../pipe/it/dual/tablemodel/TableModelUtils.java | 8 +-
.../manual/basic/IoTDBPipePermissionIT.java | 90 +-
.../treemodel/auto/basic/IoTDBPipeProcessorIT.java | 2 +
.../pipe/it/single/IoTDBPipePermissionIT.java | 43 +
.../it/db/it/IoTDBAuthenticationTableIT.java | 90 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 39 +
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 16 +-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 229 +++++
.../udf/IoTDBUserDefinedAggregateFunctionIT.java | 10 +-
.../scalar/IoTDBFormatFunctionTableIT.java | 2 +-
.../it/query/old/query/IoTDBArithmeticTableIT.java | 12 +
.../it/query/recent/IoTDBColumnsMatchTableIT.java | 354 ++++++++
.../it/query/recent/IoTDBMaintainAuthIT.java | 3 -
.../it/query/recent/IoTDBTableAggregationIT.java | 2 +-
.../IoTDBCorrelatedExistsSubqueryIT.java | 24 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 49 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 94 ++-
.../it/session/IoTDBSessionRelationalIT.java | 53 ++
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 28 +
.../IoTDBDefaultPullConsumerDataSetIT.java | 28 +-
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 14 +-
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 10 +-
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 10 +-
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +-
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 8 +-
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 22 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 4 +-
...ensusRetryWithIncreasingIntervalException.java} | 4 +-
.../relational/table/TableFunctionAnalysis.java | 28 +-
.../cli/src/assembly/resources/sbin/start-cli.sh | 4 -
.../src/assembly/resources/tools/export-tsfile.bat | 62 --
.../src/assembly/resources/tools/export-tsfile.sh | 59 --
.../java/org/apache/iotdb/cli/AbstractCli.java | 35 +-
.../org/apache/iotdb/tool/common/Constants.java | 3 +-
.../org/apache/iotdb/tool/common/OptionsUtil.java | 3 -
.../apache/iotdb/tool/data/AbstractImportData.java | 10 +-
.../org/apache/iotdb/tool/data/ExportData.java | 11 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 192 +++--
.../org/apache/iotdb/tool/data/ExportDataTree.java | 185 ++--
.../org/apache/iotdb/tool/data/ImportData.java | 8 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 23 +-
iotdb-client/client-cpp/src/main/Session.cpp | 12 +-
iotdb-client/client-py/iotdb/Session.py | 324 ++++---
.../client-py/iotdb/template/MeasurementNode.py | 2 +-
iotdb-client/client-py/iotdb/template/Template.py | 6 +-
.../{TsFileConstant.py => tsfile_constant.py} | 0
.../tsfile/utils/{DateUtils.py => date_utils.py} | 0
.../iotdb/tsfile/utils/{Pair.py => pair.py} | 0
...{ReadWriteIOUtils.py => read_write_io_utils.py} | 0
.../client-py/iotdb/tsfile/utils/tsblock_serde.py | 266 ++++++
iotdb-client/client-py/iotdb/utils/Field.py | 6 +-
.../client-py/iotdb/utils/IoTDBRpcDataSet.py | 463 ----------
iotdb-client/client-py/iotdb/utils/NumpyTablet.py | 2 +-
.../client-py/iotdb/utils/SessionDataSet.py | 48 +-
iotdb-client/client-py/iotdb/utils/Tablet.py | 2 +-
.../{IoTDBConnectionException.py => exception.py} | 20 +
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 396 +++++++++
iotdb-client/client-py/iotdb/utils/rpc_utils.py | 69 ++
iotdb-client/client-py/resources/pyproject.toml | 5 +-
.../tests/integration/test_tablemodel_query.py | 456 ++++++++++
.../iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 5 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 7 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 5 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 2 +-
.../IoTDBRelationalDatabaseMetadata.java | 99 ++-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
iotdb-core/ainode/.gitignore | 4 +-
iotdb-core/ainode/{iotdb => ainode}/__init__.py | 0
.../{iotdb/ainode => ainode/core}/__init__.py | 0
.../ainode/{iotdb/ainode => ainode/core}/client.py | 42 +-
.../ainode/{iotdb/ainode => ainode/core}/config.py | 22 +-
.../{iotdb/ainode => ainode/core}/constant.py | 0
.../{iotdb/ainode => ainode/core}/exception.py | 2 +-
.../{iotdb/ainode => ainode/core}/handler.py | 19 +-
.../ainode/{iotdb/ainode => ainode/core}/log.py | 4 +-
.../ainode => ainode/core}/manager/__init__.py | 0
.../core}/manager/cluster_manager.py | 4 +-
.../core}/manager/inference_manager.py | 14 +-
.../core}/manager/model_manager.py | 16 +-
.../ainode => ainode/core}/model/__init__.py | 0
.../core}/model/built_in_model_factory.py | 8 +-
.../ainode => ainode/core}/model/model_factory.py | 10 +-
.../ainode => ainode/core}/model/model_storage.py | 15 +-
.../ainode/{iotdb/ainode => ainode/core}/script.py | 16 +-
.../{iotdb/ainode => ainode/core}/service.py | 8 +-
.../{iotdb/ainode => ainode/core}/util/__init__.py | 0
.../ainode => ainode/core}/util/decorator.py | 0
.../{iotdb/ainode => ainode/core}/util/lock.py | 0
.../{iotdb/ainode => ainode/core}/util/serde.py | 6 +-
.../{iotdb/ainode => ainode/core}/util/status.py | 6 +-
iotdb-core/ainode/pom.xml | 8 +-
iotdb-core/ainode/pyproject.toml | 21 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 13 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../assembly/resources/sbin/stop-confignode.bat | 25 +-
.../src/assembly/resources/sbin/stop-confignode.sh | 4 +
.../confignode/client/CnToCnNodeRequestType.java | 2 +-
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 11 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 2 +
.../client/sync/SyncConfigNodeClientPool.java | 6 +-
.../iotdb/confignode/conf/ConfigNodeConfig.java | 13 +-
.../request/write/model/UpdateModelInfoPlan.java | 4 +
.../write/pipe/payload/PipeDeleteDevicesPlan.java | 44 +-
.../request/write/table/AbstractTablePlan.java | 15 +-
.../iotdb/confignode/manager/ClusterManager.java | 12 +-
.../iotdb/confignode/manager/ConfigManager.java | 121 ++-
.../iotdb/confignode/manager/ModelManager.java | 51 +-
.../confignode/manager/PermissionManager.java | 2 +
.../iotdb/confignode/manager/ProcedureManager.java | 56 +-
.../iotdb/confignode/manager/load/LoadManager.java | 10 +-
.../manager/load/cache/AbstractLoadCache.java | 2 +-
.../manager/load/cache/IFailureDetector.java | 5 +-
.../confignode/manager/load/cache/LoadCache.java | 29 +-
.../manager/load/cache/detector/FixedDetector.java | 2 +-
.../load/cache/detector/PhiAccrualDetector.java | 17 +-
.../load/cache/node/AINodeHeartbeatCache.java | 35 +-
.../load/cache/node/ConfigNodeHeartbeatCache.java | 24 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 37 +-
.../manager/load/cache/region/RegionCache.java | 31 +-
.../load/cache/region/RegionGroupCache.java | 15 +-
.../manager/load/service/EventService.java | 11 +-
.../manager/load/service/HeartbeatService.java | 20 +
.../manager/load/service/StatisticsService.java | 4 +-
.../manager/load/service/TopologyService.java | 319 +++++++
.../load/subscriber/IClusterStatusSubscriber.java | 6 +-
.../load/subscriber/NodeStatisticsChangeEvent.java | 3 +-
.../iotdb/confignode/manager/node/NodeManager.java | 27 +-
.../manager/partition/PartitionManager.java | 67 +-
.../runtime/PipeLeaderChangeHandler.java | 12 -
.../runtime/PipeRuntimeCoordinator.java | 12 -
.../extractor/ConfigRegionListeningFilter.java | 3 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 11 +-
...ConfigPhysicalPlanTablePatternParseVisitor.java | 62 +-
...nfigPhysicalPlanTablePrivilegeParseVisitor.java | 82 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 98 ++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 20 +-
.../persistence/executor/ConfigPlanExecutor.java | 10 +-
.../confignode/persistence/node/NodeInfo.java | 7 +
.../persistence/pipe/PipePluginInfo.java | 51 +-
.../procedure/PartitionTableAutoCleaner.java | 3 +
.../procedure/TimeoutExecutorThread.java | 2 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 33 +-
.../procedure/env/RegionMaintainHandler.java | 8 -
.../impl/node/RemoveConfigNodeProcedure.java | 8 +-
.../impl/region/CreateRegionGroupsProcedure.java | 35 +-
.../region/NotifyRegionMigrationProcedure.java | 137 +++
.../impl/region/ReconstructRegionProcedure.java | 33 -
.../impl/region/RegionMigrateProcedure.java | 43 +-
.../impl/schema/DeleteDatabaseProcedure.java | 4 +-
.../impl/schema/UnsetTemplateProcedure.java | 74 +-
...eState.java => NotifyRegionMigrationState.java} | 5 +-
.../procedure/state/RemoveConfigNodeState.java | 2 +-
.../procedure/store/ProcedureFactory.java | 7 +
.../confignode/procedure/store/ProcedureType.java | 1 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 27 +-
.../manager/load/cache/RegionGroupCacheTest.java | 19 +-
.../manager/load/cache/detector/DetectorTest.java | 21 +-
...igPhysicalPlanTablePatternParseVisitorTest.java | 9 +
.../consensus/iot/client/DispatchLogHandler.java | 27 +-
iotdb-core/datanode/pom.xml | 2 +-
.../src/assembly/resources/conf/datanode-env.sh | 3 +
.../src/assembly/resources/sbin/stop-datanode.bat | 23 +-
.../src/assembly/resources/sbin/stop-datanode.sh | 4 +
.../ArithmeticBinaryColumnTransformer.ftl | 11 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 45 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 31 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 11 +-
.../agent/task/connection/PipeEventCollector.java | 15 +-
.../subtask/processor/PipeProcessorSubtask.java | 15 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 6 +-
.../evolvable/batch/PipeTabletEventBatch.java | 12 +-
.../batch/PipeTransferBatchReqBuilder.java | 4 +-
.../protocol/opcda/OpcDaServerHandle.java | 9 +-
.../connector/protocol/opcua/OpcUaNameSpace.java | 15 +-
.../async/IoTDBDataRegionAsyncConnector.java | 239 ++++--
.../async/handler/PipeTransferTsFileHandler.java | 71 +-
.../protocol/writeback/WriteBackConnector.java | 13 +
.../util/builder/PipeTableModeTsFileBuilder.java | 5 +-
.../sorter/PipeTableModelTabletEventSorter.java | 12 +-
.../ReplicateProgressDataNodeManager.java | 3 +-
.../deletion/DeletionResourceManager.java | 6 +
.../deletion/persist/PageCacheDeletionBuffer.java | 4 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 13 -
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 9 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 4 +-
.../tablet/parser/TabletInsertionEventParser.java | 15 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 85 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 23 +
.../parser/TsFileInsertionEventParserProvider.java | 78 +-
.../query/TsFileInsertionEventQueryParser.java | 19 +-
.../scan/TsFileInsertionEventScanParser.java | 25 +-
.../table/TsFileInsertionEventTableParser.java | 16 +-
...ileInsertionEventTableParserTabletIterator.java | 164 ++--
.../dataregion/IoTDBDataRegionExtractor.java | 2 +
.../PipeRealtimeDataRegionHybridExtractor.java | 12 +-
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 3 +
.../overview/PipeTsFileToTabletsMetrics.java | 170 ++++
.../pipeconsensus/PipeConsensusReceiver.java | 21 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 128 ++-
.../visitor/PipeStatementExceptionVisitor.java | 5 +
.../resource/memory/InsertNodeMemoryEstimator.java | 319 ++-----
.../db/pipe/resource/memory/PipeMemoryManager.java | 31 +-
.../pipe/resource/tsfile/PipeTsFileResource.java | 6 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 18 +-
.../client/dn/AsyncTSStatusRPCHandler.java | 25 +-
.../client/dn/DataNodeAsyncRequestRPCHandler.java | 20 +-
...ger.java => DataNodeIntraHeartbeatManager.java} | 30 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 111 +--
.../impl/DataNodeInternalRPCServiceImpl.java | 145 ++--
.../db/queryengine/execution/driver/Driver.java | 15 +-
.../execution/exchange/SharedTsBlockQueue.java | 11 +
.../execution/exchange/sink/ISinkChannel.java | 2 +
.../execution/exchange/sink/LocalSinkChannel.java | 21 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 3 +
.../execution/exchange/sink/SinkChannel.java | 3 +-
.../exchange/source/LocalSourceHandle.java | 12 +-
.../fragment/FragmentInstanceContext.java | 112 ++-
.../fragment/FragmentInstanceExecution.java | 18 +-
.../fragment/FragmentInstanceManager.java | 24 +-
.../execution/fragment/QueryStatistics.java | 10 +
.../operator/process/CollectOperator.java | 7 +
.../process/function/PartitionRecognizer.java | 66 +-
.../process/function/TableFunctionOperator.java | 94 ++-
.../{SliceCache.java => PartitionCache.java} | 14 +-
.../operator/process/function/partition/Slice.java | 61 +-
.../schema/source/DeviceAttributeUpdater.java | 10 +-
.../schema/source/DeviceBlackListConstructor.java | 11 +-
.../schema/source/DevicePredicateFilter.java | 13 +-
.../schema/source/DevicePredicateHandler.java | 22 +-
.../operator/schema/source/DeviceUpdater.java | 13 +-
.../schema/source/SchemaSourceFactory.java | 4 +-
.../schema/source/TableDeviceQuerySource.java | 21 +-
.../relational/AbstractAggTableScanOperator.java | 17 +-
.../relational/AbstractMergeSortJoinOperator.java | 4 +-
.../relational/AbstractTableScanOperator.java | 2 +-
.../relational/LastQueryAggTableScanOperator.java | 6 +-
.../aggregation/CountAllAccumulator.java | 2 +-
.../relational/aggregation/FirstByAccumulator.java | 11 +-
.../relational/aggregation/LastByAccumulator.java | 6 +-
.../relational/aggregation/MaxAccumulator.java | 6 +-
.../relational/aggregation/MinAccumulator.java | 4 +-
.../relational/aggregation/SumAccumulator.java | 4 +-
.../relational/aggregation/TableAggregator.java | 9 +-
.../aggregation/TableVarianceAccumulator.java | 4 +-
.../aggregation/grouped/GroupedAvgAccumulator.java | 2 +-
.../grouped/GroupedExtremeAccumulator.java | 17 +-
.../grouped/GroupedFirstAccumulator.java | 17 +-
.../grouped/GroupedFirstByAccumulator.java | 18 +-
.../grouped/GroupedLastAccumulator.java | 37 +-
.../grouped/GroupedLastByAccumulator.java | 18 +-
.../aggregation/grouped/GroupedMaxAccumulator.java | 16 +-
.../grouped/GroupedMaxMinByBaseAccumulator.java | 30 +-
.../aggregation/grouped/GroupedMinAccumulator.java | 16 +-
.../aggregation/grouped/GroupedSumAccumulator.java | 3 +-
.../grouped/GroupedVarianceAccumulator.java | 2 +-
.../grouped/StreamingAggregationOperator.java | 32 +-
.../grouped/StreamingHashAggregationOperator.java | 32 +-
.../execution/schedule/AbstractDriverThread.java | 27 +-
.../execution/schedule/DriverScheduler.java | 2 +-
.../metric/SeriesScanCostMetricSet.java | 40 +-
.../iotdb/db/queryengine/plan/ClusterTopology.java | 175 ++++
.../iotdb/db/queryengine/plan/Coordinator.java | 4 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 2 -
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 -
.../plan/analyze/ClusterPartitionFetcher.java | 5 -
.../plan/analyze/IPartitionFetcher.java | 4 -
.../plan/analyze/load/LoadTsFileAnalyzer.java | 288 +++++--
.../analyze/load/LoadTsFileTableSchemaCache.java | 6 +-
.../analyze/load/LoadTsFileTreeSchemaCache.java | 6 +-
.../analyze/lock/DataNodeSchemaLockManager.java | 1 +
.../plan/analyze/lock/SchemaLockType.java | 14 +-
.../plan/analyze/schema/ClusterSchemaFetcher.java | 6 +-
.../plan/analyze/schema/SchemaValidator.java | 2 +-
.../plan/analyze/schema/TemplateSchemaFetcher.java | 11 +-
.../queryengine/plan/execution/QueryExecution.java | 5 +
.../execution/config/TableConfigTaskVisitor.java | 125 ++-
.../execution/config/TreeConfigTaskVisitor.java | 73 +-
.../config/executor/ClusterConfigTaskExecutor.java | 158 +++-
.../config/executor/IConfigTaskExecutor.java | 27 +-
.../config/metadata/CreatePipePluginTask.java | 2 +
.../metadata/{model => ai}/CreateModelTask.java | 2 +-
.../config/metadata/ai/CreateTrainingTask.java | 108 +++
.../metadata/{model => ai}/DropModelTask.java | 2 +-
.../metadata/{model => ai}/ShowModelsTask.java | 2 +-
.../relational/DescribeTableDetailsTask.java | 16 +-
.../metadata/relational/ShowTablesDetailsTask.java | 13 +-
.../execution/config/sys/pipe/AlterPipeTask.java | 3 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 66 +-
.../plan/planner/TableOperatorGenerator.java | 43 +-
.../SimpleFragmentParallelPlanner.java | 119 +--
.../distribution/WriteFragmentParallelPlanner.java | 7 +-
.../ReplicaSetUnreachableException.java} | 19 +-
.../exceptions/RootFIPlacementException.java} | 32 +-
.../plan/AbstractFragmentParallelPlanner.java | 168 ++++
.../plan/planner/plan/FragmentInstance.java | 2 +-
.../plan/planner/plan/PlanFragment.java | 22 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 20 +
.../plan/planner/plan/node/PlanNodeType.java | 4 +
.../plan/planner/plan/node/PlanVisitor.java | 5 +
.../plan/relational/analyzer/Analysis.java | 17 -
.../relational/analyzer/ExpressionAnalyzer.java | 6 +
.../relational/analyzer/StatementAnalyzer.java | 940 ++++++++++++++++++++-
.../TableFunctionInvocationAnalysis.java | 9 +-
.../relational/metadata/AlignedDeviceEntry.java | 20 +-
.../plan/relational/metadata/DeviceEntry.java | 26 +-
.../metadata/NonAlignedAlignedDeviceEntry.java | 20 +-
.../relational/metadata/TableMetadataImpl.java | 2 +-
.../fetcher/DeviceInCacheFilterVisitor.java | 4 +-
.../metadata/fetcher/SchemaPredicateUtil.java | 10 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 28 +-
.../fetcher/TableHeaderSchemaValidator.java | 16 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 11 +-
.../plan/relational/planner/RelationPlanner.java | 3 +-
.../relational/planner/TableLogicalPlanner.java | 15 +-
.../planner/distribute/AddExchangeNodes.java | 23 +-
.../distribute/TableDistributedPlanGenerator.java | 337 +++++++-
.../distribute/TableDistributedPlanner.java | 12 +-
.../distribute/TableModelQueryFragmentPlanner.java | 170 +---
.../TableModelTypeProviderExtractor.java | 7 +
.../plan/relational/planner/ir/IrUtils.java | 13 +-
.../rule/ImplementTableFunctionSource.java | 78 +-
.../rule/PruneTableFunctionProcessorColumns.java | 4 +-
.../PruneTableFunctionProcessorSourceColumns.java | 4 +-
.../plan/relational/planner/node/ExchangeNode.java | 6 +-
.../node/{StreamSortNode.java => GroupNode.java} | 86 +-
.../plan/relational/planner/node/OutputNode.java | 2 +
.../relational/planner/node/TableFunctionNode.java | 20 +-
.../planner/node/TableFunctionProcessorNode.java | 42 +-
.../optimizations/LogicalOptimizeFactory.java | 5 +-
.../planner/optimizations/ParallelizeGrouping.java | 266 ++++++
.../PushLimitOffsetIntoTableScan.java | 6 +
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../TransformAggregationToStreamable.java | 22 +
.../optimizations/TransformSortToStreamSort.java | 6 +
.../optimizations/UnaliasSymbolReferences.java | 29 +-
.../relational/security/AccessControlImpl.java | 32 +
.../sql/ast/AbstractQueryDeviceWithCache.java | 33 +-
.../relational/sql/ast/AbstractTraverseDevice.java | 11 +-
.../plan/relational/sql/ast/AstVisitor.java | 12 +
.../sql/ast/{NotExpression.java => Columns.java} | 51 +-
.../plan/relational/sql/ast/CreateTraining.java | 156 ++++
.../plan/relational/sql/ast/DeleteDevice.java | 19 +-
.../plan/relational/sql/ast/LoadTsFile.java | 87 +-
.../plan/relational/sql/ast/ShowDevice.java | 10 +-
.../ast/{ShowConfigNodes.java => ShowModels.java} | 34 +-
.../plan/relational/sql/ast/ShowRegions.java | 43 +-
.../plan/relational/sql/ast/SingleColumn.java | 21 +
.../queryengine/plan/relational/sql/ast/Trim.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 160 +++-
.../plan/relational/sql/util/AstUtil.java | 22 +
.../relational/sql/util/ExpressionFormatter.java | 6 +
.../plan/scheduler/AsyncSendPlanNodeHandler.java | 2 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 5 +
.../scheduler/load/LoadTsFileDispatcherImpl.java | 27 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 46 +-
.../plan/statement/StatementVisitor.java | 5 +
.../plan/statement/crud/InsertBaseStatement.java | 46 +-
.../crud/InsertMultiTabletsStatement.java | 16 +
.../plan/statement/crud/InsertRowStatement.java | 13 +
.../crud/InsertRowsOfOneDeviceStatement.java | 16 +
.../plan/statement/crud/InsertRowsStatement.java | 16 +
.../plan/statement/crud/InsertTabletStatement.java | 18 +
.../plan/statement/crud/LoadTsFileStatement.java | 90 +-
.../statement/metadata/ShowRegionStatement.java | 29 +-
.../metadata/model/CreateTrainingStatement.java | 140 +++
.../metadata/pipe/AlterPipeStatement.java | 9 +
.../metadata/pipe/CreatePipePluginStatement.java | 10 +
.../attribute/update/UpdateDetailContainer.java | 2 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 29 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 2 +-
.../read/resp/info/impl/ShowDevicesResult.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 12 +-
.../schemaengine/table/InformationSchemaUtils.java | 2 +
.../template/TemplateInternalRPCUpdateType.java | 1 -
.../iotdb/db/service/RegionMigrateService.java | 67 ++
.../iotdb/db/storageengine/StorageEngine.java | 1 +
.../buffer/TimeSeriesMetadataCache.java | 23 +-
.../db/storageengine/dataregion/DataRegion.java | 90 +-
.../dataregion/VirtualDataRegion.java | 2 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 5 +-
.../writer/AbstractCrossCompactionWriter.java | 25 +-
.../utils/writer/FastCrossCompactionWriter.java | 12 +
.../dataregion/memtable/AbstractMemTable.java | 5 +-
.../memtable/AbstractWritableMemChunk.java | 217 +++++
.../memtable/AlignedReadOnlyMemChunk.java | 248 +++---
.../memtable/AlignedWritableMemChunk.java | 275 +++---
.../dataregion/memtable/IWritableMemChunk.java | 31 -
.../dataregion/memtable/ReadOnlyMemChunk.java | 160 ++--
.../dataregion/memtable/WritableMemChunk.java | 338 +++-----
.../read/reader/chunk/MemAlignedChunkReader.java | 154 +---
.../read/reader/chunk/MemAlignedPageReader.java | 22 +-
.../read/reader/chunk/MemChunkReader.java | 111 +--
.../read/reader/chunk/MemPageReader.java | 23 +-
.../dataregion/tsfile/TsFileResource.java | 50 +-
.../tsfile/timeindex/ArrayDeviceTimeIndex.java | 12 +-
.../wal/recover/file/TsFilePlanRedoer.java | 27 +-
.../dataregion/wal/utils/WALEntryHandler.java | 4 +-
.../dataregion/wal/utils/WALInsertNodeCache.java | 10 +-
.../load/active/ActiveLoadTsFileLoader.java | 102 ++-
.../load/config/LoadTsFileConfigurator.java | 34 +
...ertedInsertTabletStatementExceptionVisitor.java | 5 +
...vertedInsertTabletStatementTSStatusVisitor.java | 7 +
...leStatementDataTypeConvertExecutionVisitor.java | 15 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 200 +++--
.../storageengine/load/disk/ILoadDiskSelector.java | 66 ++
.../InheritSystemMultiDisksStrategySelector.java | 58 ++
.../db/storageengine/load/disk/MinIOSelector.java | 112 +++
...MemoryBlock.java => LoadTsFileMemoryBlock.java} | 13 +-
.../load/memory/LoadTsFileMemoryManager.java | 19 +-
.../load/metrics/LoadTsFileCostMetricsSet.java | 31 +-
.../load/metrics/LoadTsFileMemMetricSet.java | 6 +-
.../db/storageengine/rescon/disk/TierManager.java | 2 +-
.../agent/SubscriptionBrokerAgent.java | 10 +-
.../db/subscription/broker/SubscriptionBroker.java | 25 +-
.../broker/SubscriptionPrefetchingQueue.java | 11 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 5 +-
.../pipe/SubscriptionPipeTsFileBatchEvents.java | 16 +-
.../SubscriptionDataNodeResourceManager.java} | 42 +-
.../resource/log/SubscriptionLogManager.java} | 16 +-
.../resource/log/SubscriptionLogStatus.java | 82 ++
.../db/tools/schema/SRStatementGenerator.java | 8 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 35 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 9 +-
.../db/utils/datastructure/AlignedTVList.java | 479 ++++++++---
.../iotdb/db/utils/datastructure/BinaryTVList.java | 2 +-
.../db/utils/datastructure/BooleanTVList.java | 2 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 2 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 2 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 2 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 2 +-
.../{SortKey.java => MemPointIterator.java} | 12 +-
.../datastructure/MemPointIteratorFactory.java | 381 +++++++++
.../MergeSortAlignedTVListIterator.java | 194 -----
.../MergeSortMultiAlignedTVListIterator.java | 176 ++++
.../MergeSortMultiTVListIterator.java | 83 ++
.../datastructure/MergeSortTVListIterator.java | 180 ----
.../datastructure/MultiAlignedTVListIterator.java | 236 ++++++
.../utils/datastructure/MultiTVListIterator.java | 179 ++++
.../OrderedMultiAlignedTVListIterator.java | 116 +++
...TVList.java => OrderedMultiTVListIterator.java} | 43 +-
.../iotdb/db/utils/datastructure/TVList.java | 236 ++++--
.../process/tvf/TableFunctionOperatorTest.java | 6 +-
.../plan/analyze/FakePartitionFetcherImpl.java | 5 -
.../plan/planner/distribution/Util.java | 5 -
.../plan/planner/distribution/Util2.java | 5 -
.../analyzer/AggregationCornerCaseTest.java | 179 ++++
.../plan/relational/analyzer/AggregationTest.java | 350 ++++----
.../plan/relational/analyzer/AnalyzerTest.java | 152 ++--
.../plan/relational/analyzer/DistinctTest.java | 48 +-
.../plan/relational/analyzer/JoinTest.java | 94 ++-
.../analyzer/LimitOffsetPushDownTest.java | 183 ++--
.../analyzer/MockTableModelDataPartition.java | 63 +-
.../plan/relational/analyzer/SortTest.java | 288 +++----
.../plan/relational/analyzer/SubQueryTest.java | 44 +-
.../plan/relational/analyzer/TSBSMetadata.java | 29 +-
.../relational/analyzer/TableFunctionTest.java | 100 ++-
.../plan/relational/analyzer/TestMatadata.java | 19 +-
.../plan/relational/analyzer/TestUtils.java | 26 +
.../plan/relational/analyzer/TreeViewTest.java | 72 +-
.../plan/relational/planner/ExampleTest.java | 34 +-
.../planner/UncorrelatedSubqueryTest.java | 164 ++--
.../planner/assertions/ExchangeNodeMatcher.java | 8 +-
.../planner/assertions/PlanMatchPattern.java | 9 +-
.../planner/assertions/PlanMatchingVisitor.java | 12 +-
.../FastCrossCompactionPerformerTest.java | 78 ++
...atchedAlignedSeriesReadChunkCompactionTest.java | 2 +-
.../dataregion/memtable/PrimitiveMemTableTest.java | 88 ++
.../dataregion/memtable/TsFileProcessorTest.java | 28 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 8 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 12 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 58 +-
.../read/reader/chunk/MemPageReaderTest.java | 4 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 69 ++
.../apache/iotdb/metrics/utils/FileStoreUtils.java | 2 +-
.../conf/iotdb-system.properties.template | 21 +
.../iotdb/commons/client/ClientPoolFactory.java | 1 +
.../iotdb/commons/client/ainode/AINodeClient.java | 13 +
.../client/request/AsyncRequestManager.java | 10 +-
...a => DataNodeIntraHeartbeatRequestManager.java} | 5 +-
.../client/request/TestConnectionUtils.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 73 +-
.../iotdb/commons/conf/CommonDescriptor.java | 50 ++
.../consensus/index/impl/HybridProgressIndex.java | 4 +-
.../iotdb/commons/model/ModelInformation.java | 20 +
.../apache/iotdb/commons/model/ModelStatus.java | 1 +
.../iotdb/commons/partition/ExecutorType.java | 8 +-
.../iotdb/commons/partition/QueryExecutor.java | 8 +-
.../iotdb/commons/partition/StorageExecutor.java | 10 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 1 -
.../task/subtask/PipeAbstractConnectorSubtask.java | 4 +-
.../agent/task/subtask/PipeReportableSubtask.java | 13 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 33 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 2 +-
.../pipe/receiver/PipeReceiverStatusHandler.java | 8 +
.../commons/schema/view/LogicalViewSchema.java | 13 +-
.../multi/FunctionViewExpression.java | 14 +
.../viewExpression/unary/LikeViewExpression.java | 39 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +
.../subscription/config/SubscriptionConfig.java | 12 +
.../relational/TableBuiltinTableFunction.java | 17 +-
.../relational/tvf/CapacityTableFunction.java | 89 +-
.../builtin/relational/tvf/HOPTableFunction.java | 29 +-
...ableFunction.java => SessionTableFunction.java} | 88 +-
...leFunction.java => VariationTableFunction.java} | 111 ++-
.../udf/builtin/relational/tvf/WindowTVFUtils.java | 55 ++
.../commons/udf/service/UDFManagementService.java | 5 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 49 ++
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 2 +-
.../org/apache/iotdb/commons/utils/RetryUtils.java | 8 +
.../apache/iotdb/commons/utils/StatusUtils.java | 5 +
.../iotdb/commons/utils/TimePartitionUtils.java | 7 +-
.../schema/LikeViewExpreesionSerDeTest.java | 48 ++
.../db/relational/grammar/sql/RelationalSql.g4 | 61 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 16 +
.../thrift-commons/src/main/thrift/common.thrift | 1 +
.../src/main/thrift/confignode.thrift | 39 +-
.../src/main/thrift/datanode.thrift | 20 +-
pom.xml | 13 +-
528 files changed, 15857 insertions(+), 7021 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBWindowTVFIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBColumnsMatchTableIT.java
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/exception/{PipeStrategyNotValidException.java
=> PipeConsensusRetryWithIncreasingIntervalException.java} (84%)
delete mode 100644
iotdb-client/cli/src/assembly/resources/tools/export-tsfile.bat
delete mode 100644
iotdb-client/cli/src/assembly/resources/tools/export-tsfile.sh
rename iotdb-client/client-py/iotdb/tsfile/common/constant/{TsFileConstant.py
=> tsfile_constant.py} (100%)
rename iotdb-client/client-py/iotdb/tsfile/utils/{DateUtils.py =>
date_utils.py} (100%)
rename iotdb-client/client-py/iotdb/tsfile/utils/{Pair.py => pair.py} (100%)
rename iotdb-client/client-py/iotdb/tsfile/utils/{ReadWriteIOUtils.py =>
read_write_io_utils.py} (100%)
create mode 100644 iotdb-client/client-py/iotdb/tsfile/utils/tsblock_serde.py
delete mode 100644 iotdb-client/client-py/iotdb/utils/IoTDBRpcDataSet.py
rename iotdb-client/client-py/iotdb/utils/{IoTDBConnectionException.py =>
exception.py} (64%)
create mode 100644 iotdb-client/client-py/iotdb/utils/iotdb_rpc_dataset.py
create mode 100644 iotdb-client/client-py/iotdb/utils/rpc_utils.py
create mode 100644
iotdb-client/client-py/tests/integration/test_tablemodel_query.py
rename iotdb-core/ainode/{iotdb => ainode}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/client.py (81%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/config.py (91%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/constant.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/exception.py (98%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/handler.py (69%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/log.py (97%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/manager/__init__.py
(100%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/manager/cluster_manager.py (93%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/manager/inference_manager.py (95%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/manager/model_manager.py (86%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/model/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode =>
ainode/core}/model/built_in_model_factory.py (99%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/model/model_factory.py
(96%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/model/model_storage.py
(92%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/script.py (93%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/service.py (91%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/__init__.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/decorator.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/lock.py (100%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/serde.py (98%)
rename iotdb-core/ainode/{iotdb/ainode => ainode/core}/util/status.py (90%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/service/TopologyService.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/region/NotifyRegionMigrationProcedure.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RemoveAINodeState.java
=> NotifyRegionMigrationState.java} (93%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/PipeTsFileToTabletsMetrics.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/client/dn/{DnToDnInternalServiceAsyncRequestManager.java
=> DataNodeIntraHeartbeatManager.java} (60%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/function/partition/{SliceCache.java
=> PartitionCache.java} (86%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/ClusterTopology.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{model
=> ai}/CreateModelTask.java (99%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/ai/CreateTrainingTask.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{model
=> ai}/DropModelTask.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{model
=> ai}/ShowModelsTask.java (99%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/exception/auth/AccessDeniedException.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/exceptions/ReplicaSetUnreachableException.java}
(58%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{exception/query/QueryProcessException.java
=> queryengine/plan/planner/exceptions/RootFIPlacementException.java} (55%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/AbstractFragmentParallelPlanner.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{StreamSortNode.java
=> GroupNode.java} (51%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/optimizations/ParallelizeGrouping.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{NotExpression.java
=> Columns.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/CreateTraining.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowConfigNodes.java
=> ShowModels.java} (72%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/CreateTrainingStatement.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/AbstractWritableMemChunk.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/ILoadDiskSelector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/InheritSystemMultiDisksStrategySelector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/disk/MinIOSelector.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/memory/{LoadTsFileAnalyzeSchemaMemoryBlock.java
=> LoadTsFileMemoryBlock.java} (88%)
copy
iotdb-core/{metrics/interface/src/main/java/org/apache/iotdb/metrics/utils/SystemType.java
=>
datanode/src/main/java/org/apache/iotdb/db/subscription/resource/SubscriptionDataNodeResourceManager.java}
(55%)
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/pipe/resource/log/PipeLogManager.java
=>
datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogManager.java}
(71%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/resource/log/SubscriptionLogStatus.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/{SortKey.java
=> MemPointIterator.java} (82%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MemPointIteratorFactory.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortAlignedTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortMultiAlignedTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortMultiTVListIterator.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MultiAlignedTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MultiTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/OrderedMultiAlignedTVListIterator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/{TimAlignedTVList.java
=> OrderedMultiTVListIterator.java} (50%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/request/{DataNodeInternalServiceRequestManager.java
=> DataNodeIntraHeartbeatRequestManager.java} (90%)
copy
integration-test/src/main/java/org/apache/iotdb/db/query/udf/example/relational/MyRepeatWithIndex.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/CapacityTableFunction.java
(55%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/{HOPTableFunction.java
=> SessionTableFunction.java} (61%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/{HOPTableFunction.java
=> VariationTableFunction.java} (54%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/WindowTVFUtils.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/schema/LikeViewExpreesionSerDeTest.java
