This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch ssl_between_nodes
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 314467e90ac Fix cndn heart beat
new 4d4284c19eb deving
add 24209d50ace IoTV2: Remove events that do not retry in leader's
transfer buffer & fix concurrency bug of retryQueue & fix retry interval &
refine log (#15684)
add 3e6aaa3a4cc fix cpp client processing null value (#15700)
add e315e44bf94 User password encryption upgraded from MD5 to SHA256.
(#15680)
add 6cee5f4fbee Fix arrary index out-of-bounds in agg query with align by
device when cross region
add 921d9e24804 Subscription IT: intro retry rule for flaky tests (#15698)
add be0b921ea88 Pipe: Add retry for tablet batch req to avoid
retransmission when memory is insufficient (#15715)
add 99ada4fbe40 Load: Convert to tablets when node is read-only (#15693)
add 18b10bc2d3b Pipe: Fix the inconsistency between schema and values
columns in the process of building tsfile (#15625)
add c5b8d9c8c25 use environment variable and PBKDF to generate main
encrypt key (#15711)
add 855ea12c523 Put last query IT only in 1c1d
add 83ebf5b1a9c Support order by time for Agg align by device query with
cross region data
add b3d0ad72e31 Skip update-cache logic when loading TsFile in
IoTV2Consensus (#15729)
add 369971c8164 fix datanode check (#15730)
add 9d474682cf5 Enhance "remove region" sql to handle the case of DataNode
not exist (#15728)
add 346ee720e7a [remove datanode] Fix ArrayIndexOutOfBoundsException in
computeInitialDbLoad (#15718)
add a2432d2fc2f Fixed the bug that the characters surrounded by "" cannot
be parsed in tree view path
add 7b5a2b39416 Using join to query views of non-aligned series may throw
NullPointerException
add 882c4b7898c Fixed the bug that the old view's cache is not cleared
when altering its name
add 232e0c9054f Fix timeout didn't pass to client bug
add 726d0935320 Subscription: fix drop subscription from session under
table model (#15725)
add cc3c442a1e2 Return empty result set for non aligned series when no
filed columns can be obtained from view
add b34e05e5da4 fix exception msg in RPR
add 58927a19d3a Fixed the potential failure for table view query with
pattern beyond databases
add ca2ad11712f Conf Template: Fix wrong symbol (#15742)
add 5d5e0478bc1 Pipe: Set WAL to uncompressed when using real-time sync
(#15733)
add f7992dd37fb Pipe: Fixed the insert node EMA logic for degrading
(#15741)
add 8763d57e8bb Fix RPROperator blocking behavior
add 55232d021e9 fix tsfile checker leak (#15710)
add 8a8a7bedb5b Avoiding error log by removing ThreadLocal for Mqtt Client
add 1fc3eae29b4 Fix TypeProvider and AggregationDescriptor serde in
Templated Query
add 0c35003d41e Reset global time filter for each device in table view scan
add f55dfe07e5e Add more tests for removing datanode (#15749)
add 3ff855e98d0 Fix stuck when stopping a DataNode with large unremovable
WAL files (#15727)
add ecdf0d77bc1 Fixed the device NPE for table view in view device & Added
semantic check to prohibit the last data query for prefix paths with "*" &
Refactored metric log of tag number
add 1b9a446ecea Pipe: Delete the extra tags created by the
PipeWALInsertNodeCacheMetrics (#15761)
add 02febc0506e Optimize group by query in ClientRPCServiceImpl to reduce
cpu usage
add bbe031aaebe Fix thread leak in session while connected DN is down
add e1b6e890dbc Pipe: Fixed the NPE when closing sync connector (#15772)
add c603b990c75 Subscription: return immediately when unsubscribe empty
complete topics (#15770)
add a3920b0fd55 Pipe: Fixed the NPE caused by the compression timer
(#15782)
add e227a53a726 Pipe/IoTV2: Persist progress index locally before shutdown
to accurate recovery after restart (#15779)
add f7373707336 Opt error msg while time column is empty string
add 84b56d27b6b Improve argument validation for approx_most_frequent
function
add b7bd5526b3f [Remove DataNode] Increase the waiting time for removing
DN test (#15769)
add f706aacccaf Fix multiple bugs in window function
add 2b60aa5eecc [AINode] Unify .safetensors model loading through
huggingface interfaces (#15756)
add cb24cb7f936 update go:package_prefix to v2 (#15795)
add 0505dfb9cb2 Fix the returning state of NotifyRegionMigrationProcedure
(#15797)
add fb2684a8249 Export TsFile: manual commit instead of auto commit
(#15798)
add f207084f03c Pipe: Add upper bound check for Pipe request decompression
buffer (#15699)
add e1bd11b9d6e Fixed the issue with deeply nested Or Filter in
NonAlignedTreeViewScan
add 89649f1d67d Prevent the contents of log_datanode_sample_query.log and
log_explain_ananlyze.log from being output to log_datanode_all.log (#15800)
add 817150d29d9 Avoid NPE in fetch FI Info
add 71ef45d9e1c Add new parameter [ignoreNull] and supported data type for
VARIATION Function (#15628)
add 5cb388190ae Parallel disptach read fragment instance
new 2ac954004d5 Merge branch 'master' of github.com:apache/iotdb into
ssl_between_nodes
new 23dc90a4543 deving
add 5054ff6fbbc Throw CANNOT_FETCH_FI_STATE(722) instead of 301/305 while
DN restarting
add 037ef649ad6 Fix sort elimination when table join self in TableModel
add b3435b79f42 Pause remove DN tests
add 35f2ff6fc5a Clarify the exception message when using a closed session
(#15811)
add 7a7dbecb0b7 Avoid 301/305 code about fetch schema failed
add 71563ed372f Make timecol be case-insensitive
add 7afc2b65b41 [AINode] Update the class fields of IoTDB dataset (#15799)
add 1dc47d48e07 Rest Service add FastLastQuery method
add 88abd3e3097 Enhance it for cluster-restart tests (#15794)
add b8fd08984cb IoTV2: Refactor replicate index so that it is shared at
the pipe task level & Add some log for delete local peer (#15815)
add 46c9827d846 Fix elimination rule of TopK when generate DistributionPlan
add 0ffa4b67deb Correct status code from 301 to 719 while memory not
enough & Record release resource blocked too long by driver (#15828)
add 3016bb54e48 [AINode] Add TimerXL to the built-in list (#15832)
add 5c4c297e63d [AINode] Modify dataset module for table-model training
(#15816)
add 30f69c61182 Add WAL entry number for one TsFile metric (#15818)
add 2b6400f275f [AINode] Support customize session config in AINode
(#15834)
add 719c504d410 [AINode] Refactor the result columns of "show models" SQL
(#15831)
add ccba945c67e [AINode] Simplify the CREATE MODEL SQL for model training
(#15840)
add 354d6b5c732 [AINode] Quick bug fix patch (#15841)
add 2482a71b100 Fixed the issue that columns may not be pruned when
querying non-field columns in tree view scan
add 1642f674103 Subscription: add config to enable or disable subscription
(#15820)
add 16ad6c1a686 Resolve IndexOutOfPartitionBound and symbol not found in
window functions.
add a0a4700b932 [AINode] Distinguish uppder and lower case of model id
(#15847)
add 0927009a779 [AINode] Fix the seed when inference (#15850)
add 71df4956ef0 Subscription: intro poll and prefetch v2 for tsfile topic
(#15790)
add be7a1de2b45 [AINode] Fix bug that AINode cannot register and invoke
user_defined model (#15849)
add b1429293894 Fix the issue that symbol name is not found in tree view
scan & Querying a time range with no data may throw an exception
add c30af2c6b53 Add size control of result for
SimpleNestedLoopCrossJoinOperator
add e69fc997803 Pipe: Fixed the class cast exception of the table view
meta sync (#15855)
add 5cda97b25d5 Support aggregation functions in RPR
add d86b86e87c4 Merge LastQueryScanNode of same device
add 03e701860ad [AINode] Add window_step options for dataset (#15857)
add 65b18ff9e3e Pipe: prevent historical extractor from forwarding TsFiles
generated by pipe when isForwardingPipeRequests is false (#15845)
add f8e24dc71eb Feature/retry on disk failure (#15676)
add 5ef583cfe67 Disable the parameter
'ALLOW_ZERO-BYTE_CITE_SIDED_PROPERTY1 NAME' and fix null pointer exception
(#15866)
add b04cd468c5a [AINode] Fix built-in model inference & support user
parameters (#15868)
add baa9e1ac005 [AINode] IoTDBTreeModelDataset bug fix (#15869)
add d2a040003f3 Don't print exception stack for 719
add b4045de6eb2 Bump ratis to 3.2.0 (#15825)
add f2f00501a5e Pipe: Added rate limiter for tsFile sending (#15765)
add 1a035c4b8de Print measurement for putting buffer exceptions (#15873)
add ad8bedc1d50 Bump ratis to 3.2.1 (#15871)
add a184469ada3 When querying the lastest point of alias view and normal
series at the same time, points may be lost due to overwriting
add 7800de6ad0d Correct the memroy calculation of BinaryColumnBuilder
add c5009f3ad61 Fix dead lock when take snapshot for Trigger and UDF
add 4cc6085e35c Pipe: Fix the error of Client object returning to object
pool after file transfer is completed (#15883)
add acaa72d703b Try delete sort tmp after driver is closed
add 57f22e770b1 [AINode] Fix the bug that the built-in model be deleted
(#15888)
add a10e2132d80 Fixed the NPE caused by view permission check
add 0a0ec3fb176 [AINode] Fix model management bugs (#15890)
add 966cfc73348 Change ErrorCode from 305 to 701 if there is no from clause
add 0fce0ccfdb0 Update tsfile version & add table view query it
add 309f205859d Update Release info after 2.0.4 released (#15898)
add 1ad56c78138 Pipe: Enabled waiting for pipes to finish & progress index
persist to config node in shutdown hook (#15896)
add 14b4382ff44 [AINode]Fix the parameter "predict_length" (#15900)
add 4be53debee7 Fix potential memory leak of Memory Pool
add 9042a0d2c43 Pipe: Reduced the progress index report interval & Added
some logs (#15905)
add e6bc39f4da5 Add more checkpoints in series scan
add bf8329b1517 Pipe: Fix connection leak caused by clients not closed
after task dropped (2 situations) (#15910)
add f8e03f987f3 Fix the issue that the DeviceIteratorScanOperator.next()
method throws NoSuchElementException
add eb1e786fa15 Revert Pipe/IoTV2: Try to persist progressIndex in local
for resend event more efficently (#15924)
add ba6eed15d29 [AINode] Support model management for Table (#15923)
add 03385938f74 Bump org.apache.commons:commons-lang3 from 3.13.0 to
3.18.0 (#15922)
add ccfd563960b Correct Memory Allocation for SinkHandle in Table model
add ac44d8b8594 Make div and mod return long type if types of two inputs
are all int64 or int32
add 1f24444a868 Fix timestamp type data conversion issue in exported data
of table model (#15918)
add b2cdbe03f77 Fix display of Blob type in last query
add 59eb9bbb0a9 Fix explicit time query process in TreeModel
add d7844931a87 Fixed the issue that non aligned tree view query used too
much memory
add 77a91e0f60a Remove CI on windows-2022 (#15938)
add 8472c71bcdc Fixed the issue where devices in the cache may be
repeatedly fetched
add e139623037e [AINode] Remove AINode through SQL (#15937)
add f69347580e8 Avoid NPE while stop DN (#15939)
new 64761e2a963 Merge branch 'master' of github.com:apache/iotdb into
ssl_between_nodes
new 9f77e329a87 dev
new 1ce4494eccf Grok4 is powerful
new 808e46b586e recover some code
The 7 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/multi-language-client.yml | 10 +-
RELEASE_NOTES.md | 22 +
dependencies.json | 14 +-
.../org/apache/iotdb/it/env/cluster/EnvUtils.java | 77 ++-
.../it/env/cluster/config/MppCommonConfig.java | 23 +
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../env/cluster/config/MppSharedCommonConfig.java | 26 +
.../iotdb/it/env/cluster/env/AbstractEnv.java | 266 +++++++++--
.../it/env/cluster/node/AbstractNodeWrapper.java | 13 +-
.../it/env/remote/config/RemoteCommonConfig.java | 16 +
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 8 +
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 270 -----------
.../iotdb/ainode/it/AINodeClusterConfigIT.java | 113 +++++
.../iotdb/ainode/it/AINodeInferenceSQLIT.java | 292 +++++++++++
.../iotdb/ainode/it/AINodeModelManageIT.java | 215 +++++++++
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 126 +++++
...reamIT.java => IoTDBConfigNodeSnapshot2IT.java} | 29 +-
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 5 +-
.../IoTDBRemoveConfigNodeITFramework.java | 2 +-
.../IoTDBRemoveDataNodeNormalIT.java | 366 +++++++++++++-
.../removedatanode/IoTDBRemoveDataNodeUtils.java | 178 +++++++
...work.java => IoTDBRemoveUnknownDataNodeIT.java} | 324 ++++++-------
.../confignode/it/utils/ConfigNodeTestUtils.java | 12 +
.../iotdb/db/it/IoTDBCustomizedClusterIT.java | 271 +++++++++++
.../org/apache/iotdb/db/it/IoTDBNestedQueryIT.java | 4 +-
.../maxby/IoTDBMaxByAlignedSeriesIT.java | 20 +
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 21 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 5 +-
.../db/it/last/IoTDBLastQueryLastCacheIT.java | 15 +-
.../IoTDBArithmeticDivAndModWithoutDoubleIT.java} | 34 +-
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 48 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 48 +-
.../db/it/IoTDBMultiTAGsWithAttributesTableIT.java | 8 +-
.../it/db/it/IoTDBPatternAggregationIT.java | 492 +++++++++++++++++++
.../relational/it/db/it/IoTDBWindowFunctionIT.java | 233 ++++++++-
.../relational/it/db/it/IoTDBWindowTVFIT.java | 175 +++++++
.../it/query/recent/IoTDBTableAggregationIT.java | 181 +++++--
.../view/recent/IoTDBNullValueTableViewIT.java | 14 +-
.../query/view/recent/IoTDBTableViewQueryIT.java | 29 ++
.../IoTDBTableViewQueryWithCachedDeviceIT.java | 127 +++++
.../recent/IoTDBTableViewWithTreeTTLQueryIT.java | 38 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 36 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 72 ++-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 16 +
.../org/apache/iotdb/session/it/SessionIT.java | 133 +++++-
.../org/apache/iotdb/subscription/it/Retry.java | 10 +-
.../apache/iotdb/subscription/it/RetryRule.java | 69 +++
.../it/cluster/IoTDBSubscriptionRestartIT.java | 4 +
.../it/dual/AbstractSubscriptionDualIT.java | 4 +
.../it/local/AbstractSubscriptionLocalIT.java | 2 +
.../it/triple/AbstractSubscriptionTripleIT.java | 12 +
.../AbstractSubscriptionTreeRegressionIT.java | 71 ++-
.../IoTDBRootPullConsumeTsfileIT.java | 15 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 18 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 16 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 14 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 17 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 17 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 16 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 33 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 39 +-
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 15 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 14 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 12 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 15 +-
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 8 +
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 8 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 8 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 18 +
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 4 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 3 +
.../src/test/resources/ainode-example/config.yaml | 8 +-
...eption.java => UDFColumnNotFoundException.java} | 7 +-
...xception.java => UDFTypeMismatchException.java} | 7 +-
.../table/argument/ScalarArgumentChecker.java | 8 +
.../java/org/apache/iotdb/udf/api/type/Type.java | 10 +
.../org/apache/iotdb/tool/common/Constants.java | 3 +-
.../apache/iotdb/tool/data/ExportDataTable.java | 5 +-
.../subscription/SubscriptionTableTsFile.java | 2 +-
.../subscription/SubscriptionTreeTsFile.java | 2 +-
iotdb-client/client-cpp/src/main/Common.h | 15 +-
.../client-cpp/src/main/IoTDBRpcDataSet.cpp | 68 +--
iotdb-client/client-cpp/src/main/IoTDBRpcDataSet.h | 42 +-
iotdb-client/client-cpp/src/main/NodesSupplier.cpp | 16 +-
.../client-cpp/src/main/SessionDataSet.cpp | 78 ++-
iotdb-client/client-cpp/src/main/SessionDataSet.h | 32 +-
iotdb-client/client-cpp/src/test/cpp/sessionIT.cpp | 66 ++-
.../src/test/cpp/sessionRelationalIT.cpp | 81 +++-
.../java/org/apache/iotdb/isession/ISession.java | 6 +-
iotdb-client/service-rpc/pom.xml | 8 +
.../iotdb/rpc/NettyTNonBlockingTransport.java | 531 +++++++++++++++++++++
.../iotdb/rpc/TNonblockingSocketWrapper.java | 18 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 4 +
.../java/org/apache/iotdb/session/Session.java | 267 ++++++-----
.../apache/iotdb/session/SessionConnection.java | 6 +-
.../apache/iotdb/session/TableSessionBuilder.java | 7 +-
.../subscription/AbstractSubscriptionSession.java | 2 +-
.../subscription/SubscriptionSessionWrapper.java | 4 +-
.../base/AbstractSubscriptionProvider.java | 31 +-
.../apache/iotdb/session/util/SessionUtils.java | 103 ++--
.../iotdb/session/util/SessionUtilsTest.java | 26 +-
iotdb-core/ainode/ainode/core/ainode.py | 167 +++++++
iotdb-core/ainode/ainode/core/config.py | 87 +++-
iotdb-core/ainode/ainode/core/constant.py | 45 +-
iotdb-core/ainode/ainode/core/exception.py | 5 +
iotdb-core/ainode/ainode/core/ingress/dataset.py | 20 +-
iotdb-core/ainode/ainode/core/ingress/iotdb.py | 278 ++++++-----
.../ainode/core/manager/inference_manager.py | 45 +-
.../ainode/ainode/core/manager/model_manager.py | 70 ++-
.../ainode/core/model/built_in_model_factory.py | 132 +++--
iotdb-core/ainode/ainode/core/model/model_info.py | 160 +++++++
.../ainode/ainode/core/model/model_storage.py | 407 ++++++++++++++--
.../ainode/core/model/sundial/modeling_sundial.py | 22 +-
.../core/model/sundial/ts_generation_mixin.py | 5 +
.../ainode/core/model/timerxl/modeling_timer.py | 22 +-
.../ainode/ainode/core/rpc}/__init__.py | 0
iotdb-core/ainode/ainode/core/{ => rpc}/client.py | 2 +-
iotdb-core/ainode/ainode/core/{ => rpc}/handler.py | 14 +-
iotdb-core/ainode/ainode/core/rpc/service.py | 101 ++++
.../ainode/ainode/core/{util => rpc}/status.py | 0
iotdb-core/ainode/ainode/core/script.py | 112 +----
iotdb-core/ainode/ainode/core/service.py | 57 ---
.../ainode/resources/conf/iotdb-ainode.properties | 32 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
iotdb-core/confignode/pom.xml | 2 +-
.../rpc/DataNodeAsyncRequestRPCHandler.java | 2 +-
.../handlers/rpc/PipeHeartbeatRPCHandler.java | 2 +-
.../sync/SyncDataNodeHeartbeatClientPool.java | 70 ---
.../request/write/ainode/RemoveAINodePlan.java | 5 +
.../consensus/response/model/ModelTableResp.java | 13 +-
.../iotdb/confignode/manager/ConfigManager.java | 73 +--
.../apache/iotdb/confignode/manager/IManager.java | 7 +-
.../iotdb/confignode/manager/ModelManager.java | 60 ++-
.../iotdb/confignode/manager/ProcedureManager.java | 44 +-
.../region/GreedyCopySetRegionGroupAllocator.java | 8 +-
.../manager/load/service/HeartbeatService.java | 20 +-
.../manager/load/service/TopologyService.java | 9 +-
.../iotdb/confignode/manager/node/NodeManager.java | 20 +-
.../pipe/agent/task/PipeConfigNodeSubtask.java | 9 +-
.../pipe/agent/task/PipeConfigNodeTaskAgent.java | 22 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 5 +
.../protocol/IoTDBConfigRegionConnector.java | 13 +-
.../runtime/heartbeat/PipeHeartbeatParser.java | 2 -
.../runtime/heartbeat/PipeHeartbeatScheduler.java | 2 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 7 +-
.../subscription/SubscriptionCoordinator.java | 3 +-
.../iotdb/confignode/persistence/ModelInfo.java | 28 +-
.../iotdb/confignode/persistence/TriggerInfo.java | 3 -
.../iotdb/confignode/persistence/UDFInfo.java | 3 -
.../partition/DatabasePartitionTable.java | 10 +-
.../persistence/partition/PartitionInfo.java | 2 +-
.../persistence/partition/RegionGroup.java | 6 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 7 +-
.../procedure/impl/model/DropModelProcedure.java | 57 +--
.../procedure/impl/node/RemoveAINodeProcedure.java | 24 +
.../impl/node/RemoveDataNodesProcedure.java | 5 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 4 +-
.../impl/pipe/task/AlterPipeProcedureV2.java | 16 +-
.../impl/pipe/task/CreatePipeProcedureV2.java | 18 +-
.../region/NotifyRegionMigrationProcedure.java | 2 +-
.../procedure/impl/schema/SchemaUtils.java | 20 +-
.../table/AbstractAlterOrDropTableProcedure.java | 23 +-
.../impl/schema/table/CreateTableProcedure.java | 8 +-
.../impl/schema/table/RenameTableProcedure.java | 6 +-
.../procedure/state/RemoveAINodeState.java | 1 +
.../iotdb/confignode/service/ConfigNode.java | 12 +-
.../confignode/service/ConfigNodeShutdownHook.java | 3 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 15 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 12 +-
.../consensus/response/pipe/PipeTableRespTest.java | 6 +-
.../GreedyCopySetRemoveNodeReplicaSelectTest.java | 11 +-
.../agent/PipeConfigNodeSubtaskExecutorTest.java | 3 +-
.../iotdb/confignode/persistence/PipeInfoTest.java | 4 +-
iotdb-core/consensus/pom.xml | 14 +-
.../iot/client/AsyncIoTConsensusServiceClient.java | 16 +-
.../consensus/iot/logdispatcher/LogDispatcher.java | 2 +-
.../consensus/iot/logdispatcher/SyncStatus.java | 5 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 3 +-
.../consensus/pipe/PipeConsensusServerImpl.java | 19 +-
.../pipe/consensuspipe/ConsensusPipeConnector.java | 4 +-
.../consensuspipe/ReplicateProgressManager.java | 2 +-
.../pipe/metric/PipeConsensusSyncLagManager.java | 12 +-
iotdb-core/datanode/pom.xml | 2 +-
.../assembly/resources/conf/logback-datanode.xml | 6 +-
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 2 +-
.../iotdb/db/auth/ClusterAuthorityFetcher.java | 5 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 -
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 29 +-
.../iotdb/db/exception/load/LoadFileException.java | 4 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 80 ++--
.../task/builder/PipeDataNodeTaskBuilder.java | 68 ++-
.../task/execution/PipeSubtaskExecutorManager.java | 6 +-
.../subtask/connector/PipeConnectorSubtask.java | 5 +
.../connector/PipeConnectorSubtaskManager.java | 4 +
.../subtask/processor/PipeProcessorSubtask.java | 4 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 20 +-
.../airgap/IoTDBDataRegionAirGapConnector.java | 33 +-
.../airgap/IoTDBSchemaRegionAirGapConnector.java | 5 +
.../pipeconsensus/PipeConsensusAsyncConnector.java | 41 +-
.../handler/PipeConsensusDeleteEventHandler.java | 4 +-
.../PipeConsensusTabletInsertionEventHandler.java | 5 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 10 +-
.../async/IoTDBDataRegionAsyncConnector.java | 22 +-
.../handler/PipeTransferTrackableHandler.java | 2 +
.../async/handler/PipeTransferTsFileHandler.java | 28 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 27 +-
.../thrift/sync/IoTDBSchemaRegionConnector.java | 5 +
.../util/builder/PipeTableModelTsFileBuilder.java | 1 +
.../builder/PipeTableModelTsFileBuilderV2.java | 53 +-
.../util/builder/PipeTreeModelTsFileBuilder.java | 1 +
.../util/builder/PipeTreeModelTsFileBuilderV2.java | 42 +-
.../connector/util/builder/PipeTsFileBuilder.java | 40 +-
.../ReplicateProgressDataNodeManager.java | 21 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 6 +-
.../statement/PipeStatementInsertionEvent.java | 6 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 6 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 6 +-
.../event/realtime/PipeRealtimeEventFactory.java | 50 +-
.../dataregion/IoTDBDataRegionExtractor.java | 39 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 39 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 5 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 18 +-
.../listener/PipeInsertionDataNodeListener.java | 11 +-
.../schemaregion/IoTDBSchemaRegionExtractor.java | 4 +-
.../iotdb/db/pipe/metric/PipeDataNodeMetrics.java | 6 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 48 +-
...ics.java => PipeDataNodeSinglePipeMetrics.java} | 15 +-
.../pipe/metric/overview/PipeResourceMetrics.java | 14 +
.../overview/PipeWALInsertNodeCacheMetrics.java | 4 +-
.../pipeconsensus/PipeConsensusReceiver.java | 87 ++--
.../pipeconsensus/PipeConsensusReceiverAgent.java | 138 +++---
.../protocol/thrift/IoTDBDataNodeReceiver.java | 68 ++-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 11 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 8 +-
.../protocol/rest/v2/handler/FastLastHandler.java | 71 +++
.../rest/v2/handler/RequestValidationHandler.java | 8 +
.../protocol/rest/v2/impl/RestApiServiceImpl.java | 230 ++++++---
.../iotdb/db/protocol/session/SessionManager.java | 14 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 81 ++--
.../impl/DataNodeInternalRPCServiceImpl.java | 38 +-
.../db/queryengine/common/MPPQueryContext.java | 29 ++
.../execution/MemoryEstimationHelper.java | 28 ++
.../queryengine/execution/QueryStateMachine.java | 62 +--
.../execution/driver/DriverContext.java | 6 +
.../execution/exchange/SharedTsBlockQueue.java | 2 +-
.../queryengine/execution/exchange/sink/ISink.java | 4 +-
.../execution/exchange/sink/LocalSinkChannel.java | 14 +-
.../execution/exchange/sink/ShuffleSinkHandle.java | 40 +-
.../execution/exchange/sink/SinkChannel.java | 10 +-
.../exchange/source/LocalSourceHandle.java | 13 +-
.../execution/fragment/DataNodeQueryContext.java | 21 +-
.../fragment/FakedFragmentInstanceContext.java | 106 ++++
.../fragment/FragmentInstanceContext.java | 26 +-
.../fragment/FragmentInstanceExecution.java | 44 +-
.../fragment/FragmentInstanceManager.java | 8 +-
.../execution/fragment/QueryContext.java | 2 +-
.../process/PatternRecognitionOperator.java | 14 +
.../operator/process/ProjectOperator.java | 3 +-
.../operator/process/ai/InferenceOperator.java | 3 +-
.../join/SimpleNestedLoopCrossJoinOperator.java | 3 +-
.../last/AbstractUpdateLastCacheOperator.java | 24 +-
.../last/AlignedUpdateLastCacheOperator.java | 14 +-
.../AlignedUpdateViewPathLastCacheOperator.java | 10 +-
.../operator/process/last/LastQueryOperator.java | 1 +
.../process/last/LastQuerySortOperator.java | 10 +-
.../process/last/LastQueryTransformOperator.java | 4 +-
.../operator/process/last/LastQueryUtil.java | 34 ++
.../process/last/UpdateLastCacheOperator.java | 27 +-
.../last/UpdateViewPathLastCacheOperator.java | 4 +-
.../rowpattern/PatternAggregationTracker.java | 156 ++++++
.../process/rowpattern/PatternAggregator.java | 178 +++++++
.../process/rowpattern/PatternAggregators.java | 74 +++
.../rowpattern/PatternPartitionExecutor.java | 13 +
.../rowpattern/PatternVariableRecognizer.java | 8 +-
...cessor.java => PhysicalAggregationPointer.java} | 12 +-
.../rowpattern/expression/ArithmeticOperator.java | 7 +-
.../rowpattern/expression/ComparisonOperator.java | 8 +-
.../process/rowpattern/expression/Computation.java | 24 +-
.../rowpattern/expression/LogicalOperator.java | 4 +-
.../expression/PatternExpressionComputation.java | 21 +-
.../process/rowpattern/matcher/Matcher.java | 29 +-
.../process/window/TableWindowOperator.java | 7 +-
.../window/partition/PartitionExecutor.java | 17 +-
.../process/window/partition/frame/RangeFrame.java | 6 +-
.../process/window/utils/RowComparator.java | 20 +
.../schema/source/TableDeviceQuerySource.java | 23 +-
.../AbstractSeriesAggregationScanOperator.java | 70 ++-
.../source/AbstractSeriesScanOperator.java | 46 +-
.../execution/operator/source/SeriesScanUtil.java | 79 ++-
.../relational/AbstractAggTableScanOperator.java | 75 ++-
.../AbstractDefaultAggTableScanOperator.java | 4 +-
.../relational/AbstractMergeSortJoinOperator.java | 14 +
.../relational/AbstractTableScanOperator.java | 16 +-
.../relational/DeviceIteratorScanOperator.java | 3 +-
.../InformationSchemaContentSupplierFactory.java | 125 +++--
.../relational/LastQueryAggTableScanOperator.java | 4 +-
.../execution/schedule/task/DriverTaskId.java | 3 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 19 +
.../db/queryengine/plan/analyze/Analysis.java | 33 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 99 ++--
.../plan/analyze/ExpressionTypeAnalyzer.java | 29 ++
.../queryengine/plan/analyze/ExpressionUtils.java | 14 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 8 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 1 +
.../plan/analyze/load/LoadTsFileAnalyzer.java | 9 +-
.../queryengine/plan/execution/QueryExecution.java | 8 +-
.../execution/config/TableConfigTaskVisitor.java | 57 ++-
.../execution/config/TreeConfigTaskVisitor.java | 24 +-
.../config/executor/ClusterConfigTaskExecutor.java | 99 +++-
.../config/executor/IConfigTaskExecutor.java | 16 +-
...moveDataNodeTask.java => RemoveAINodeTask.java} | 12 +-
.../config/metadata/ai/CreateModelTask.java | 14 +-
.../config/metadata/ai/CreateTrainingTask.java | 41 +-
.../config/metadata/ai/ShowModelsTask.java | 72 ++-
.../metadata/relational/ShowCreateViewTask.java | 9 +-
.../execution/config/sys/pipe/ShowPipeTask.java | 4 +-
.../memory/StatementMemorySourceVisitor.java | 3 +-
.../visitor/ColumnTransformerVisitor.java | 11 +
.../db/queryengine/plan/parser/ASTVisitor.java | 36 +-
.../plan/planner/LogicalPlanBuilder.java | 152 +++---
.../plan/planner/OperatorTreeGenerator.java | 172 +++----
.../plan/planner/SubPlanTypeExtractor.java | 6 -
.../plan/planner/TableOperatorGenerator.java | 238 +++++++--
.../queryengine/plan/planner/TreeModelPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 15 +-
.../planner/distribution/NodeGroupContext.java | 12 +
.../SimpleFragmentParallelPlanner.java | 13 +-
.../plan/planner/distribution/SourceRewriter.java | 222 +++++++--
.../memory/FakedMemoryReservationManager.java} | 16 +-
.../plan/planner/plan/PlanFragment.java | 9 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 18 +-
.../plan/planner/plan/node/PlanNodeType.java | 14 +-
.../plan/planner/plan/node/PlanVisitor.java | 5 -
.../planner/plan/node/process/AggregationNode.java | 3 +-
.../plan/node/process/MultiChildProcessNode.java | 4 +
.../plan/node/process/RawDataAggregationNode.java | 3 +-
.../plan/node/process/last/LastQueryNode.java | 141 +++++-
.../plan/node/source/AlignedLastQueryScanNode.java | 245 ----------
.../source/AlignedSeriesAggregationScanNode.java | 21 +-
.../plan/node/source/LastQueryScanNode.java | 193 ++++++--
.../node/source/SeriesAggregationScanNode.java | 15 +-
.../planner/plan/parameter/SeriesScanOptions.java | 24 +-
.../relational/analyzer/ExpressionAnalyzer.java | 179 ++++++-
.../relational/analyzer/StatementAnalyzer.java | 18 +-
.../function/tvf/ForecastTableFunction.java | 36 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 65 ++-
.../fetcher/TableDeviceSchemaValidator.java | 6 +-
.../plan/relational/planner/QueryPlanner.java | 44 +-
.../plan/relational/planner/RelationPlanner.java | 57 ++-
.../relational/planner/TableLogicalPlanner.java | 5 +
.../plan/relational/planner/TableModelPlanner.java | 2 +-
.../distribute/TableDistributedPlanGenerator.java | 35 +-
.../distribute/TableModelQueryFragmentPlanner.java | 1 +
.../optimizations/PushPredicateIntoTableScan.java | 3 +-
.../planner/optimizations/SortElimination.java | 60 ++-
.../planner/optimizations/SymbolMapper.java | 49 +-
.../optimizations/TransformSortToStreamSort.java | 33 +-
.../planner/rowpattern/AggregationLabelSet.java | 100 ++++
.../rowpattern/AggregationValuePointer.java | 161 +++++++
.../rowpattern/ExpressionAndValuePointers.java | 16 +
.../planner/rowpattern/IrRowPattern.java | 40 +-
.../plan/relational/sql/ast/AstVisitor.java | 12 +
.../sql/ast/{ShowModels.java => CreateModel.java} | 48 +-
.../plan/relational/sql/ast/CreateTraining.java | 85 +---
.../sql/ast/{ShowModels.java => DropModel.java} | 44 +-
.../plan/relational/sql/ast/Identifier.java | 6 +-
.../ast/{ShowFunctions.java => RemoveAINode.java} | 33 +-
.../plan/relational/sql/parser/AstBuilder.java | 118 ++---
.../plan/scheduler/ClusterScheduler.java | 11 +-
.../scheduler/FixedRateFragInsStateTracker.java | 34 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 108 ++++-
.../plan/scheduler/IFragInstanceDispatcher.java | 6 +-
.../scheduler/load/LoadTsFileDispatcherImpl.java | 4 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 29 +-
.../plan/statement/StatementVisitor.java | 5 +
.../plan/statement/crud/QueryStatement.java | 10 +-
...deStatement.java => RemoveAINodeStatement.java} | 14 +-
.../metadata/model/CreateModelStatement.java | 10 +-
.../metadata/model/CreateTrainingStatement.java | 14 +-
.../metadata/model/DropModelStatement.java | 10 +-
.../metadata/model/ShowModelsStatement.java | 12 +-
.../metadata/view/CreateLogicalViewStatement.java | 13 +-
.../dag/input/QueryDataSetInputLayer.java | 3 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 10 +-
.../db/schemaengine/table/DataNodeTableCache.java | 42 +-
.../iotdb/db/schemaengine/table/ITableCache.java | 10 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 13 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 70 ++-
.../org/apache/iotdb/db/service/MQTTService.java | 2 +-
.../metrics/IoTDBInternalLocalReporter.java | 2 +-
.../iotdb/db/service/metrics/WritingMetrics.java | 13 +
.../db/storageengine/dataregion/DataRegion.java | 3 +-
.../utils/reader/SeriesDataBlockReader.java | 20 +-
.../dataregion/memtable/TsFileProcessor.java | 8 +
.../dataregion/snapshot/SnapshotLoader.java | 67 ++-
.../dataregion/tsfile/TsFileResourceList.java | 2 +-
.../tsfile/generator/TsFileNameGenerator.java | 63 +--
.../dataregion/utils/TsFileResourceUtils.java | 5 +-
.../storageengine/dataregion/wal/WALManager.java | 11 +-
.../allocation/AbstractNodeAllocationStrategy.java | 13 +-
.../file/AbstractTsFileRecoverPerformer.java | 2 +-
.../db/storageengine/load/LoadTsFileManager.java | 12 +-
.../storageengine/load/disk/ILoadDiskSelector.java | 3 +-
.../InheritSystemMultiDisksStrategySelector.java | 42 +-
.../db/storageengine/load/disk/MinIOSelector.java | 3 +-
.../load/limiter/LoadTsFileRateLimiter.java | 64 +--
.../storageengine/rescon/disk/FolderManager.java | 63 +++
.../db/storageengine/rescon/disk/TierManager.java | 4 +
.../rescon/disk/strategy/DirectoryStrategy.java | 34 ++
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 3 +
.../MinFolderOccupiedSpaceFirstStrategy.java | 4 +
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +
.../rescon/disk/strategy/SequenceStrategy.java | 4 +-
.../agent/SubscriptionReceiverAgent.java | 16 +-
.../agent/SubscriptionRuntimeAgent.java | 4 +
.../db/subscription/broker/SubscriptionBroker.java | 35 +-
.../broker/SubscriptionPrefetchingQueue.java | 387 ++++++++++++++-
.../broker/SubscriptionPrefetchingTabletQueue.java | 7 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 6 -
.../SubscriptionPipeEventBatchSegmentLock.java} | 55 +--
.../event/batch/SubscriptionPipeEventBatches.java | 118 ++---
.../batch/SubscriptionPipeTsFileEventBatch.java | 40 +-
.../receiver/SubscriptionReceiverV1.java | 8 +
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 +-
.../iotdb/db/utils/sort/FileSpillerReader.java | 4 +-
.../SchemaRegionSimpleRecoverTest.java | 4 +-
.../queryengine/execution/exchange/StubSink.java | 6 +-
.../execution/operator/LastQueryOperatorTest.java | 6 +-
.../operator/LastQueryTreeSortOperatorTest.java | 6 +-
...nAlignedTreeDeviceViewScanOperatorTreeTest.java | 112 ++++-
.../process/TableStreamSortOperatorTest.java | 11 +-
.../operator/process/rowpattern/MatcherTest.java | 4 +-
.../db/queryengine/plan/analyze/AnalyzeTest.java | 4 +-
.../distribution/AggregationAlignByDeviceTest.java | 57 +++
.../plan/planner/distribution/LastQueryTest.java | 22 +-
.../logical/DataQueryLogicalPlannerTest.java | 86 ++--
...deTest.java => LastQueryScanNodeSerdeTest.java} | 51 +-
.../plan/relational/analyzer/AnalyzerTest.java | 5 +-
.../plan/relational/analyzer/JoinTest.java | 188 ++++++++
.../analyzer/RowPatternRecognitionTest.java | 32 ++
.../plan/relational/analyzer/SubQueryTest.java | 24 +
.../relational/analyzer/TableFunctionTest.java | 82 ++++
.../plan/relational/analyzer/TreeViewTest.java | 4 +-
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 12 +-
.../planner/assertions/PlanMatchPattern.java | 4 +
.../security/encrypt/MessageDigestEncryptTest.java | 12 +-
.../storageengine/dataregion/DataRegionTest.java | 4 +-
.../TableModelCompactionWithTTLTest.java | 4 +-
.../AlignedSeriesScanLimitOffsetPushDownTest.java | 97 ++--
.../AlignedSeriesScanPredicatePushDownTest.java | 47 +-
...gleColumnSeriesScanLimitOffsetPushDownTest.java | 48 +-
.../read/reader/series/SeriesReaderTestUtil.java | 17 +
.../series/SeriesScanLimitOffsetPushDownTest.java | 60 +--
.../series/SeriesScanPredicatePushDownTest.java | 40 +-
.../file/UnsealedTsFileRecoverPerformerTest.java | 4 +-
.../org/apache/iotdb/metrics/utils/MetricInfo.java | 3 +-
iotdb-core/node-commons/pom.xml | 2 +-
.../conf/iotdb-system.properties.template | 2 +-
.../commons/auth/authorizer/BasicAuthorizer.java | 42 +-
.../apache/iotdb/commons/client/ClientManager.java | 27 +-
.../iotdb/commons/client/IClientManager.java | 3 +
.../iotdb/commons/client/ainode/AINodeClient.java | 30 ++
.../AsyncConfigNodeInternalServiceClient.java | 16 +-
.../async/AsyncDataNodeExternalServiceClient.java | 16 +-
.../async/AsyncDataNodeInternalServiceClient.java | 16 +-
.../AsyncDataNodeMPPDataExchangeServiceClient.java | 16 +-
.../async/AsyncPipeDataTransferServiceClient.java | 2 +-
.../commons/concurrent/IoTDBThreadPoolFactory.java | 28 ++
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 173 +++----
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
...meException.java => PortOccupiedException.java} | 14 +-
.../commons/exception/QueryTimeoutException.java | 4 +
.../iotdb/commons/model/ModelInformation.java | 2 +-
.../iotdb/commons/partition/DataPartition.java | 11 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 16 +
.../agent/runtime/PipePeriodicalJobExecutor.java | 33 --
.../commons/pipe/agent/task/PipeTaskAgent.java | 13 +-
.../commons/pipe/agent/task/meta/PipeMeta.java | 6 +-
.../pipe/agent/task/meta/PipeRuntimeMeta.java | 42 +-
.../commons/pipe/agent/task/meta/PipeTaskMeta.java | 145 +-----
.../task/progress/PipeEventCommitManager.java | 11 -
.../iotdb/commons/pipe/config/PipeConfig.java | 54 +--
.../iotdb/commons/pipe/config/PipeDescriptor.java | 50 +-
.../config/constant/PipeConnectorConstant.java | 5 +
.../connector/limiter/GlobalRPCRateLimiter.java} | 15 +-
.../pipe/connector/limiter/GlobalRateLimiter.java | 14 +-
.../connector/limiter/TsFileSendRateLimiter.java} | 31 +-
.../thrift/request/PipeTransferCompressedReq.java | 15 +
.../connector/protocol/IoTDBAirGapConnector.java | 3 +
.../pipe/connector/protocol/IoTDBConnector.java | 4 +-
.../connector/protocol/IoTDBSslSyncConnector.java | 17 +-
.../iotdb/commons/pipe/event/EnrichedEvent.java | 4 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 66 +--
.../commons/pipe/resource/log/PipeLogManager.java | 2 +-
.../commons/pipe/resource/log/PipeLogStatus.java | 4 +-
.../schema/column/ColumnHeaderConstant.java | 5 +-
.../security/encrypt/AsymmetricEncrypt.java | 23 +-
.../security/encrypt/MessageDigestEncrypt.java | 10 +-
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../subscription/config/SubscriptionConfig.java | 6 +
.../relational/tvf/VariationTableFunction.java | 196 ++++++--
.../udf/builtin/relational/tvf/WindowTVFUtils.java | 6 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 22 +-
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 56 ++-
.../apache/iotdb/commons/utils/StatusUtils.java | 15 +-
.../iotdb/commons/pipe/task/PipeMetaDeSerTest.java | 22 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 36 +-
iotdb-doap.rdf | 8 +
.../openapi/src/main/openapi3/iotdb_rest_v2.yaml | 25 +
.../thrift-ainode/src/main/thrift/ainode.thrift | 18 +-
.../thrift-commons/src/main/thrift/common.thrift | 7 +
.../src/main/thrift/confignode.thrift | 23 +-
.../thrift-datanode/src/main/thrift/client.thrift | 1 +
.../src/main/thrift/datanode.thrift | 10 +-
pom.xml | 24 +-
520 files changed, 14197 insertions(+), 5505 deletions(-)
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeBasicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeClusterConfigIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeInferenceSQLIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/it/AINodeModelManageIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/ainode/utils/AINodeTestUtils.java
copy
integration-test/src/test/java/org/apache/iotdb/confignode/it/{regionmigration/pass/commit/stream/IoTDBRegionMigrateNormalForIoTV2StreamIT.java
=> IoTDBConfigNodeSnapshot2IT.java} (63%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/IoTDBRemoveDataNodeUtils.java
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/removedatanode/{IoTDBRemoveDataNodeITFramework.java
=> IoTDBRemoveUnknownDataNodeIT.java} (55%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBCustomizedClusterIT.java
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{groupby/IoTDBLeftORightCIT.java
=> query/IoTDBArithmeticDivAndModWithoutDoubleIT.java} (67%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBPatternAggregationIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/view/recent/IoTDBTableViewQueryWithCachedDeviceIT.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/schemaengine/schemaregion/SchemaRegion.java
=> integration-test/src/test/java/org/apache/iotdb/subscription/it/Retry.java
(77%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/RetryRule.java
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/exception/{UDFException.java
=> UDFColumnNotFoundException.java} (82%)
copy
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/exception/{UDFException.java
=> UDFTypeMismatchException.java} (83%)
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NettyTNonBlockingTransport.java
create mode 100644 iotdb-core/ainode/ainode/core/ainode.py
create mode 100644 iotdb-core/ainode/ainode/core/model/model_info.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/ainode/core/rpc}/__init__.py (100%)
rename iotdb-core/ainode/ainode/core/{ => rpc}/client.py (99%)
rename iotdb-core/ainode/ainode/core/{ => rpc}/handler.py (84%)
create mode 100644 iotdb-core/ainode/ainode/core/rpc/service.py
rename iotdb-core/ainode/ainode/core/{util => rpc}/status.py (100%)
delete mode 100644 iotdb-core/ainode/ainode/core/service.py
delete mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncDataNodeHeartbeatClientPool.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/overview/{PipeDataNodeRemainingEventAndTimeMetrics.java
=> PipeDataNodeSinglePipeMetrics.java} (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v2/handler/FastLastHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/fragment/FakedFragmentInstanceContext.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/PatternAggregationTracker.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/PatternAggregator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/PatternAggregators.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/rowpattern/{PhysicalValueAccessor.java
=> PhysicalAggregationPointer.java} (79%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{RemoveDataNodeTask.java
=> RemoveAINodeTask.java} (82%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/{relational/sql/ast/JoinCriteria.java
=> planner/memory/FakedMemoryReservationManager.java} (70%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/source/AlignedLastQueryScanNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/rowpattern/AggregationLabelSet.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/rowpattern/AggregationValuePointer.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowModels.java
=> CreateModel.java} (66%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowModels.java
=> DropModel.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{ShowFunctions.java
=> RemoveAINode.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{RemoveConfigNodeStatement.java
=> RemoveAINodeStatement.java} (86%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/resource/tsfile/PipeTsFileResourceSegmentLock.java
=> subscription/event/batch/SubscriptionPipeEventBatchSegmentLock.java} (60%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/node/source/{SeriesScanNodeSerdeTest.java
=> LastQueryScanNodeSerdeTest.java} (55%)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/{IoTDBIORuntimeException.java
=> PortOccupiedException.java} (75%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/DataTypeParameter.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/GlobalRPCRateLimiter.java}
(66%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/agent/task/execution/PipeConnectorSubtaskExecutor.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/limiter/TsFileSendRateLimiter.java}
(54%)
