This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/join
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 36755a3e1a6 perfect join of TableDistributedPlanGenerator and
PushPredicateIntoTableScan
add 85524b0e832 Support where condition in show / count devices
add b93348d3ccb Support alter table add column / set properties if exists
& default string type for id / attribute columns
add 8a1657c7548 Split IT for Table model
add b5faa3c71ce Optimize action
add ea4ecc31a89 Bump milo.version from 0.6.10 to 0.6.14 (#13203)
add b5688551711 Bump org.apache.maven.plugins:maven-jar-plugin from 3.2.0
to 3.2.2 (#13202)
add 13e0d764661 Bump org.apache.maven.plugins:maven-shade-plugin from
3.5.0 to 3.5.3 (#13204)
add 9d8b7b078d4 Bump org.cyclonedx:cyclonedx-maven-plugin from 2.7.9 to
2.7.11 (#13205)
add c5a40cc26b3 Do not check column names for table model non-sql
add a95b9f37c27 Revert "Bump org.apache.maven.plugins:maven-shade-plugin
from 3.5.0 to 3.5.3 …" (#13209)
add 019b565cc0b Fix table insertion sql WAL & enable restart tests (#13197)
add ef3cf9f08af Bump swagger version (#13211)
add deb17201b39 fix action name (#13212)
add 246ab58b05f Add string and math function
add 32df6dfc2e3 Eventually consistent heartbeat samples #13210
add 95378c9b89f Pipe: Reduced the recover time in cleaning tsFile
hardlinks (#13216)
add ad675479751 [region migration] Snapshot source file not exists problem
debugging #13214
add b9aeda95a64 Subscription IT: intro extensive regression tests from
test group (#13065)
add cd8a4610fb3 Pipe: The DataRegion migration process checks whether the
user pipe has released all related resources (#13183)
add b88c82b5ced Avoid the brain split phenomenon in the symmetric network
partition scenario #13221
add e4f10fe89fb [region migration] Do RatisConsensus resetPeerList even if
myself not in peer list #13223
add 45ab21bf8e3 RegionMigrate: Fix migrating region with ratisConsensus
cause the region is unavailable. (#13178)
add 61622d9804c Fixed the bug of device attribute update
add 69c010c88d6 Pipe: Update TsFileInsertionScanDataContainer to support
partially sequential aligned chunks (#13168)
add aac66ce5708 Modify 'set configuration' in relational grammar (#13186)
add dd3d516a739 Pipe: Fix InternalCreateMultiTimeSeries plan's members may
be altered in SchemaRegionListeningQueue & Alter timeseries for logical view is
not parsed in snapshot transferring (#13123)
add e1861849160 Reduce aligned series compaction memory usage (#12744)
add 8888377619e [region migration] Fix regionRWLock NPE when migrating
region concurrently (#13217)
add 00a5c40b088 Pipe IT: Reduce FT runner cost by removing some
manual-create-schema test cases (#13242)
add 1ee4744718f Pipe: Convert tsfile to tablets on data sync receiver when
data type / aligned type mismatch detected (#13239)
add a54f7f7be51 Make DN wait when CN cluster's leader is not ready or
down. (#13236)
add 2ee04519aba fix scalar function args and return type problem
add 1107bf70e1d Subscription IT: migrate regression tests of parameter and
permission from test group (#13231)
add b158e60cafc Fix insert statement creation when there is only one column
add 5c5c9226081 Fixed the granularity of table procedure lock
add 1489c8480ef Pipe: discard batched events before restarting pipes
(#13238)
add a32eef95678 Fix database and tablename case sensitivity in tablet model
add 4c0d4f5e771 Compare in double and fix error message
add 3e11b7bd7ab Fix status code of category or data type mismatch
add efd3420674e Load: Add metrics for active load (#13224)
add c0ad8400ce9 Opt type mismatch error msg & fix Blob and date compare bug
add 60d5a7e60af PipeConsensus: build separate dir for each receiver
thread. (#13234)
add 1f08730d384 Pipe: Support async tsfile load when data syncing between
clusters (#13176)
add d883b100094 Fix the error that columns in sort is not appear in
projection
add 7ab36b57436 Inner space compaction splits large target file (#13097)
add a1e6fab0cdf [region migration] Enable SchemaRegion write retry when
migrating region concurrently (#13261)
add e5b87219c08 [region migration] Ratis delete local peer when
resetPeerList is called and myself not in correct peer list #13282
add 124a25e0efe Support update attribute on standalone version & Enable
cache update / mlog writing of createOrUpdate device & Improved the performance
/ semantic of schema device query & Introduce limit/offset of show device
add de28b7ef466 date_bin scalar function
add 87f765b426f [Fix] Add another retryPolicy for RatisClient (#13286)
add b28374ea69a Enable cpp client CI on Windows-2019 with visual studio
2019 (#13289)
add dc55eb06d32 Update DataNodeSpaceQuotaManager.java
add bc3b4d32c11 Introduce AINode to IoTDB (#13254)
new 733a542ba04 Merge branch 'master' into beyyes/join
add 7a2a0b4bb2c Fixed the NPE of failed internal create timeseries (#13253)
add e94c2c1ff71 Add subquery UT and IT, Remove some wrong implementation
code
new cb76021647e merge with master
new bda7dc1b167 fix typeprovider
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 2 -
.github/workflows/cluster-it-1c3d.yml | 4 +-
.github/workflows/{unit-test.yml => daily-ut.yml} | 30 +-
.github/workflows/multi-language-client.yml | 12 +-
.github/workflows/pipe-it-2cluster.yml | 96 +-
...uster-it-1c1d.yml => table-cluster-it-1c1d.yml} | 8 +-
...uster-it-1c3d.yml => table-cluster-it-1c3d.yml} | 10 +-
.github/workflows/unit-test.yml | 11 +-
example/pipe-count-point-processor/pom.xml | 2 +-
integration-test/README.md | 24 +-
integration-test/pom.xml | 62 +-
.../java/org/apache/iotdb/it/env/EnvFactory.java | 2 +
.../main/java/org/apache/iotdb/it/env/EnvType.java | 3 +-
.../it/env/cluster/config/MppCommonConfig.java | 6 +-
.../env/cluster/config/MppSharedCommonConfig.java | 7 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 5 +-
.../it/env/remote/config/RemoteCommonConfig.java | 3 +-
...ltiClusterIT2SubscriptionArchVerification.java} | 2 +-
...iClusterIT2SubscriptionRegressionConsumer.java} | 2 +-
...MultiClusterIT2SubscriptionRegressionMisc.java} | 2 +-
...terIT2Subscription.java => TableClusterIT.java} | 2 +-
...bscription.java => TableLocalStandaloneIT.java} | 2 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../apache/iotdb/db/it/IoTDBInsertMultiRowIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 54 +-
.../org/apache/iotdb/db/it/utils/TestUtils.java | 25 +-
.../pipe/it/autocreate/IoTDBPipeDataSinkIT.java | 97 +
.../it/db/it/IoTDBExecuteBatchTableIT.java | 7 +-
.../it/db/it/IoTDBFlushQueryTableIT.java | 6 +-
.../it/db/it/IoTDBInsertAlignedValuesTableIT.java | 6 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 391 ++-
.../it/db/it/IoTDBMultiDeviceTableIT.java | 6 +-
.../it}/IoTDBMultiIDsWithAttributesTableIT.java | 139 +-
.../relational/it/db/it/IoTDBRecoverTableIT.java | 6 +-
.../it/db/it/IoTDBRecoverUnclosedTableIT.java | 6 +-
.../relational/it/db/it/IoTDBRestartTableIT.java | 90 +-
.../it/db/it/IoTDBSetConfigurationTableIT.java | 25 +-
.../it/query/old/IoTDBDatetimeFormatTableIT.java | 6 +-
.../it/query/old/IoTDBFilterBetweenTableIT.java | 6 +-
.../it/query/old/IoTDBFilterNullTableIT.java | 6 +-
.../it/query/old/IoTDBFilterTableIT.java | 5 +-
.../it/query/old/IoTDBNestedQueryTableIT.java | 25 +-
.../it/query/old/IoTDBSimpleQueryTableIT.java | 6 +-
.../alignbydevice/IoTDBAlignByDeviceTable2IT.java | 6 +-
.../alignbydevice/IoTDBAlignByDeviceTable3IT.java | 6 +-
.../alignbydevice/IoTDBAlignByDeviceTableIT.java | 6 +-
.../IoTDBAlignByDeviceWithTemplateTable2IT.java | 6 +-
.../IoTDBAlignByDeviceWithTemplateTableIT.java | 6 +-
...TDBOrderByLimitOffsetAlignByDeviceTable2IT.java | 6 +-
...oTDBOrderByLimitOffsetAlignByDeviceTableIT.java | 6 +-
.../IoTDBOrderByWithAlignByDeviceTable2IT.java | 6 +-
.../IoTDBOrderByWithAlignByDeviceTable3IT.java | 6 +-
.../IoTDBOrderByWithAlignByDeviceTableIT.java | 6 +-
.../IoTDBAlignedOffsetLimitPushDownTableIT.java | 6 +-
.../aligned/IoTDBAlignedSeriesQueryTable2IT.java | 6 +-
.../aligned/IoTDBAlignedSeriesQueryTable3IT.java | 6 +-
.../aligned/IoTDBAlignedSeriesQueryTable4IT.java | 6 +-
.../aligned/IoTDBAlignedSeriesQueryTable5IT.java | 6 +-
.../aligned/IoTDBAlignedSeriesQueryTableIT.java | 6 +-
.../aligned/IoTDBPredicatePushDownTable2IT.java | 6 +-
.../aligned/IoTDBPredicatePushDownTable3IT.java | 6 +-
.../aligned/IoTDBPredicatePushDownTable4IT.java | 6 +-
.../old/aligned/IoTDBPredicatePushDownTableIT.java | 6 +-
.../scalar/IoTDBCastFunctionTableIT.java | 6 +-
.../scalar/IoTDBDiffFunctionTable2IT.java | 6 +-
.../scalar/IoTDBDiffFunctionTable3IT.java | 6 +-
.../scalar/IoTDBDiffFunctionTableIT.java | 6 +-
.../scalar/IoTDBReplaceFunctionTableIT.java | 6 +-
.../scalar/IoTDBRoundFunctionTableIT.java | 6 +-
.../scalar/IoTDBScalarFunctionTableIT.java | 2723 ++++++++++++++++++++
.../scalar/IoTDBSubStringFunctionTableIT.java | 6 +-
.../it/query/old/orderBy/IoTDBOrderByTableIT.java | 6 +-
.../it/query/old/query/IoTDBArithmeticTableIT.java | 6 +-
.../query/old/query/IoTDBCaseWhenThenTableIT.java | 6 +-
.../it/query/old/query/IoTDBFuzzyQueryTableIT.java | 6 +-
.../it/query/old/query/IoTDBInTableIT.java | 6 +-
...oTDBNoSelectExpressionAfterAnalyzedTableIT.java | 6 +-
.../query/old/query/IoTDBNullOperandTableIT.java | 6 +-
.../query/old/query/IoTDBNullValueFillTableIT.java | 6 +-
.../it/query/old/query/IoTDBPaginationTableIT.java | 6 +-
.../it/query/old/query/IoTDBQueryDemoTableIT.java | 6 +-
.../IoTDBQueryWithComplexValueFilterTableIT.java | 20 +-
.../it/query/old/query/IoTDBResultSetTableIT.java | 6 +-
.../query/IoTDBSelectCompareExpressionTableIT.java | 6 +-
.../query/old/query/IoTDBSelectSchemaTableIT.java | 6 +-
.../it/query/recent/IoTDBNullIdQueryIT.java | 6 +-
.../relational/it/schema/IoTDBDatabaseIT.java | 6 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 220 ++
.../relational/it/schema/IoTDBDeviceQueryIT.java | 109 -
.../iotdb/relational/it/schema/IoTDBTableIT.java | 74 +-
.../it/session/IoTDBTableModelSessionIT.java | 6 +-
.../session/pool/IoTDBTableModelSessionPoolIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionRelationalIT.java | 87 +-
.../subscription/it/AbstractSubscriptionIT.java | 13 +-
.../apache/iotdb/subscription/it/DisplayName.java | 21 +-
.../it/SkipOnSetUpAndTearDownFailure.java | 114 +
.../iotdb/subscription/it/SkipOnSetUpFailure.java | 82 -
.../it/cluster/IoTDBSubscriptionRestartIT.java | 98 +-
.../it/dual/AbstractSubscriptionDualIT.java | 10 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 10 +-
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 6 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 18 +-
.../it/local/AbstractSubscriptionLocalIT.java | 10 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 4 +-
.../it/local/IoTDBSubscriptionDataTypeIT.java | 2 +-
.../it/triple/AbstractSubscriptionTripleIT.java | 10 +-
.../it/triple/IoTDBSubscriptionSharingIT.java | 18 +-
.../AbstractSubscriptionRegressionIT.java | 475 ++++
.../IoTDBDefaultPullConsumerDataSetIT.java | 142 +
.../IoTDBDefaultTsfilePushConsumerIT.java | 224 ++
.../IoTDBRootDatasetPushConsumerIT.java | 186 ++
.../IoTDBRootPullConsumeTsfileIT.java | 147 ++
...merPullConsumerWith1TopicShareProcessMixIT.java | 196 ++
.../param/IoTDBTestParamPullConsumerIT.java | 534 ++++
.../param/IoTDBTestParamPushConsumerIT.java | 349 +++
.../param/IoTDBTestParamSubscriptionSessionIT.java | 70 +
.../regression/param/IoTDBTestParamTopicIT.java | 248 ++
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 191 ++
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 175 ++
.../format/IoTDBDBDataSetPullConsumerIT.java | 154 ++
.../format/IoTDBDBTsfilePullConsumerIT.java | 155 ++
.../IoTDBAllTsDatasetPullConsumerIT.java | 208 ++
.../IoTDBAllTsTsfilePullConsumerIT.java | 199 ++
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 201 ++
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 170 ++
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 189 ++
.../IoTDBTimeTsDatasetPullConsumerIT.java | 212 ++
.../IoTDBTimeTsTsfilePullConsumerIT.java | 203 ++
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 152 ++
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 182 ++
...DBConsumer2With1TopicShareProcessDataSetIT.java | 145 ++
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 198 ++
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 215 ++
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 183 ++
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 319 +++
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 177 ++
.../IoTDBDBPatternPullConsumerDataSetIT.java | 150 ++
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 145 ++
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 176 ++
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 156 ++
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 174 ++
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 177 ++
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 184 ++
.../IoTDBRootPatternPullConsumeTsfileIT.java | 152 ++
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 182 ++
.../IoTDBTSPatternPullConsumerDataSetIT.java | 132 +
.../time/IoTDBAllPullConsumerDataSetIT.java | 131 +
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 139 +
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 138 +
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 136 +
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 140 +
.../format/IoTDBTestPushConsumeDataSetIT.java | 179 ++
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 181 ++
.../format/IoTDBTestPushConsumeTsfileIT.java | 181 ++
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 228 ++
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 227 ++
.../IoTDBLooseAllTsfilePushConsumerIT.java | 257 ++
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 254 ++
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 255 ++
.../IoTDBPathLooseTsfilePushConsumerIT.java | 224 ++
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 209 ++
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 220 ++
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 277 ++
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 237 ++
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 219 ++
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 196 ++
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 246 ++
...DBConsumer2With1TopicShareProcessDataSetIT.java | 216 ++
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 223 ++
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 604 +++++
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 202 ++
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 239 ++
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 211 ++
.../IoTDBDBPatternDatasetPushConsumerIT.java | 191 ++
.../IoTDBDBPatternTsfilePushConsumerIT.java | 221 ++
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 220 ++
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 190 ++
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 233 ++
.../IoTDBRootPatternDatasetPushConsumerIT.java | 191 ++
.../IoTDBTSPatternDatasetPushConsumerIT.java | 190 ++
.../IoTDBTSPatternTsfilePushConsumerIT.java | 227 ++
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 175 ++
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 178 ++
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 164 ++
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 180 ++
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 180 ++
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 181 ++
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 199 ++
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 142 +
.../regression/topic/IoTDBTestTopicNameIT.java | 139 +
.../regression/user/IoTDBOtherUserConsumerIT.java | 143 +
iotdb-client/client-cpp/README.md | 17 +-
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 15 +-
iotdb-core/ainode/.gitignore | 11 +
.../pom.xml => iotdb-core/ainode/README.md | 21 +-
.../pom.xml => iotdb-core/ainode/README_ZH.md | 21 +-
iotdb-core/ainode/ainode.xml | 62 +
.../ainode}/iotdb/__init__.py | 0
.../ainode/iotdb/ainode}/__init__.py | 0
iotdb-core/ainode/iotdb/ainode/attribute.py | 669 +++++
iotdb-core/ainode/iotdb/ainode/client.py | 285 ++
iotdb-core/ainode/iotdb/ainode/config.py | 276 ++
iotdb-core/ainode/iotdb/ainode/constant.py | 247 ++
.../ainode/iotdb/ainode/encryption.py | 0
iotdb-core/ainode/iotdb/ainode/exception.py | 123 +
iotdb-core/ainode/iotdb/ainode/factory.py | 272 ++
iotdb-core/ainode/iotdb/ainode/handler.py | 118 +
iotdb-core/ainode/iotdb/ainode/inference.py | 165 ++
iotdb-core/ainode/iotdb/ainode/log.py | 134 +
iotdb-core/ainode/iotdb/ainode/parser.py | 191 ++
iotdb-core/ainode/iotdb/ainode/script.py | 102 +
iotdb-core/ainode/iotdb/ainode/serde.py | 564 ++++
iotdb-core/ainode/iotdb/ainode/service.py | 139 +
iotdb-core/ainode/iotdb/ainode/storage.py | 318 +++
iotdb-core/ainode/iotdb/ainode/util.py | 79 +
iotdb-core/ainode/pom.xml | 347 +++
iotdb-core/ainode/pyproject.toml | 66 +
iotdb-core/ainode/resources/conf/ainode-env.bat | 128 +
iotdb-core/ainode/resources/conf/ainode-env.sh | 138 +
.../ainode/resources/conf/iotdb-ainode.properties | 60 +
iotdb-core/ainode/resources/sbin/remove-ainode.bat | 107 +
iotdb-core/ainode/resources/sbin/remove-ainode.sh | 112 +
iotdb-core/ainode/resources/sbin/start-ainode.bat | 77 +
iotdb-core/ainode/resources/sbin/start-ainode.sh | 78 +
iotdb-core/ainode/resources/sbin/stop-ainode.bat | 61 +
iotdb-core/ainode/resources/sbin/stop-ainode.sh | 73 +
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 7 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 43 +
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 28 +
iotdb-core/confignode/pom.xml | 5 +
.../async/AsyncAINodeHeartbeatClientPool.java | 62 +
.../handlers/heartbeat/AINodeHeartbeatHandler.java | 57 +
.../iotdb/confignode/conf/ConfigNodeConstant.java | 1 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 16 +-
.../read/ainode/GetAINodeConfigurationPlan.java | 74 +
.../request/read/model/GetModelInfoPlan.java | 80 +
.../request/read/model/ShowModelPlan.java | 90 +
.../request/write/ainode/RegisterAINodePlan.java | 76 +
.../request/write/ainode/RemoveAINodePlan.java | 79 +
.../request/write/ainode/UpdateAINodePlan.java | 79 +
.../request/write/model/CreateModelPlan.java | 79 +
.../request/write/model/DropModelInNodePlan.java | 70 +
.../request/write/model/DropModelPlan.java | 79 +
.../request/write/model/UpdateModelInfoPlan.java | 118 +
.../write/table/SetTablePropertiesPlan.java | 79 +
.../response/ainode/AINodeConfigurationResp.java} | 45 +-
.../response/ainode/AINodeRegisterResp.java} | 51 +-
.../consensus/response/model/GetModelInfoResp.java | 71 +
.../consensus/response/model/ModelTableResp.java | 55 +
.../statemachine/ConfigRegionStateMachine.java | 65 +-
.../iotdb/confignode/manager/ConfigManager.java | 142 +-
.../apache/iotdb/confignode/manager/IManager.java | 67 +
.../iotdb/confignode/manager/ModelManager.java | 126 +
.../iotdb/confignode/manager/ProcedureManager.java | 311 ++-
.../iotdb/confignode/manager/load/LoadManager.java | 6 +-
.../manager/load/cache/AbstractLoadCache.java | 2 +-
.../confignode/manager/load/cache/LoadCache.java | 18 +-
...artbeatCache.java => AINodeHeartbeatCache.java} | 49 +-
.../load/cache/node/DataNodeHeartbeatCache.java | 2 +-
.../load/cache/node/NodeHeartbeatSample.java | 15 +-
.../manager/load/service/HeartbeatService.java | 35 +
.../manager/node/ClusterNodeStartUtils.java | 49 +
.../iotdb/confignode/manager/node/NodeManager.java | 154 ++
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../protocol/IoTDBConfigRegionAirGapConnector.java | 2 +
.../protocol/IoTDBConfigRegionConnector.java | 6 +-
.../manager/schema/ClusterSchemaManager.java | 91 +-
.../iotdb/confignode/persistence/ModelInfo.java | 382 +++
.../persistence/executor/ConfigPlanExecutor.java | 48 +-
.../confignode/persistence/node/NodeInfo.java | 178 ++
.../persistence/schema/ClusterSchemaInfo.java | 30 +-
.../confignode/persistence/schema/ConfigMTree.java | 71 +-
.../procedure/env/RegionMaintainHandler.java | 49 +-
.../procedure/impl/model/CreateModelProcedure.java | 250 ++
.../procedure/impl/model/DropModelProcedure.java | 196 ++
.../procedure/impl/node/RemoveAINodeProcedure.java | 160 ++
.../impl/region/RemoveRegionPeerProcedure.java | 23 +-
.../procedure/impl/schema/SchemaUtils.java | 70 +
.../impl/schema/table/AddTableColumnProcedure.java | 145 +-
.../impl/schema/table/CreateTableProcedure.java | 130 +-
.../schema/table/SetTablePropertiesProcedure.java | 325 +++
.../procedure/state/RemoveAINodeState.java | 7 +-
.../procedure/state/model/CreateModelState.java | 7 +-
.../procedure/state/model/DropModelState.java | 7 +-
.../state/schema/SetTablePropertiesState.java | 9 +-
.../procedure/store/ProcedureFactory.java | 24 +
.../confignode/procedure/store/ProcedureType.java | 6 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 78 +
.../request/ConfigPhysicalPlanSerDeTest.java | 16 +
.../table/SetTablePropertiesProcedureTest.java | 63 +
.../org/apache/iotdb/consensus/IConsensus.java | 4 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 7 +-
.../apache/iotdb/consensus/iot/IoTConsensus.java | 3 +-
.../consensus/iot/IoTConsensusServerImpl.java | 5 +-
.../service/IoTConsensusRPCServiceProcessor.java | 3 +-
.../ratis/ApplicationStateMachineProxy.java | 6 +
.../apache/iotdb/consensus/ratis/RatisClient.java | 82 +
.../iotdb/consensus/ratis/RatisConsensus.java | 68 +-
.../iotdb/consensus/simple/SimpleConsensus.java | 3 +-
iotdb-core/datanode/pom.xml | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 89 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 127 +-
.../dataregion/DataRegionStateMachine.java | 11 +-
.../schemaregion/SchemaExecutionVisitor.java | 26 +-
.../schemaregion/SchemaRegionStateMachine.java | 29 +-
.../db/exception/ainode/GetModelInfoException.java | 15 +-
.../iotdb/db/exception/ainode/ModelException.java | 22 +-
.../exception/ainode/ModelNotFoundException.java | 15 +-
.../table/TableAlreadyExistsException.java | 2 +-
.../metadata/table/TableNotExistsException.java | 2 +-
.../runtime/ModelInferenceProcessException.java | 9 +-
.../iotdb/db/exception/sql/SemanticException.java | 8 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 15 +
.../client/IoTDBDataNodeAsyncClientManager.java | 32 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../evolvable/batch/PipeTabletEventBatch.java | 19 +-
.../batch/PipeTransferBatchReqBuilder.java | 5 +
.../request/PipeTransferTabletRawReq.java | 1 +
.../airgap/IoTDBDataNodeAirGapConnector.java | 2 +
.../async/IoTDBDataRegionAsyncConnector.java | 9 +-
.../thrift/sync/IoTDBDataNodeSyncConnector.java | 6 +-
.../thrift/sync/IoTDBDataRegionSyncConnector.java | 5 +
.../scan/TsFileInsertionScanDataContainer.java | 134 +-
.../pipeconsensus/PipeConsensusReceiver.java | 61 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 32 +-
...peStatementDataTypeConvertExecutionVisitor.java | 54 +-
.../visitor/PipeStatementExceptionVisitor.java | 2 +-
.../visitor/PipeStatementPatternParseVisitor.java | 12 +
.../visitor/PipeStatementTSStatusVisitor.java | 4 +-
.../visitor/PipeStatementToBatchVisitor.java | 28 +-
...aNodeHardlinkOrCopiedFileDirStartupCleaner.java | 21 +-
.../subtask/connector/PipeConnectorSubtask.java | 5 +-
.../connector/PipeConnectorSubtaskLifeCycle.java | 2 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 89 +-
.../v1/handler/StatementConstructionHandler.java | 1 +
.../v2/handler/StatementConstructionHandler.java | 2 +
.../iotdb/db/protocol/session/IClientSession.java | 8 +-
.../handler/AINodeRPCServiceThriftHandler.java | 60 +
.../protocol/thrift/impl/AINodeRPCServiceImpl.java | 187 ++
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 13 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../thrift/impl/IAINodeRPCServiceWithHandler.java | 8 +-
.../iotdb/db/queryengine/common/SessionInfo.java | 27 +-
.../common/header/ColumnHeaderConstant.java | 22 +
.../common/header/DatasetHeaderFactory.java | 8 +
.../execution/exchange/source/SourceHandle.java | 12 +
.../execution/executor/RegionExecutionResult.java | 21 +-
.../execution/executor/RegionReadExecutor.java | 42 +-
.../execution/executor/RegionWriteExecutor.java | 137 +-
.../fragment/FragmentInstanceContext.java | 10 +-
.../fragment/FragmentInstanceManager.java | 11 +
.../operator/process/AI/InferenceOperator.java | 337 +++
.../operator/process/FilterAndProjectOperator.java | 6 +-
.../operator/schema/SchemaCountOperator.java | 4 +-
.../operator/schema/SchemaQueryScanOperator.java | 73 +-
.../schema/source/DeviceAttributeUpdater.java | 158 ++
.../schema/source/DevicePredicateFilter.java | 69 +
.../schema/source/DevicePredicateHandler.java | 132 +
.../schema/source/SchemaSourceFactory.java | 21 +-
.../schema/source/TableDeviceQuerySource.java | 100 +-
.../execution/operator/source/FileLoaderUtils.java | 18 +
.../execution/operator/source/SeriesScanUtil.java | 16 +-
.../ainode/BottomInferenceWindowParameter.java | 72 +
.../window/ainode/CountInferenceWindow.java} | 27 +-
.../ainode/CountInferenceWindowParameter.java | 82 +
.../window/ainode/HeadInferenceWindow.java | 20 +-
.../operator/window/ainode/InferenceWindow.java | 19 +-
.../window/ainode/InferenceWindowParameter.java | 63 +
.../window/ainode/InferenceWindowType.java | 9 +-
.../window/ainode/TailInferenceWindow.java | 21 +-
.../relational/ColumnTransformerBuilder.java | 310 ++-
.../execution/schedule/AbstractDriverThread.java | 10 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 4 +
.../db/queryengine/plan/analyze/Analysis.java | 19 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 9 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 184 +-
.../db/queryengine/plan/analyze/IModelFetcher.java | 9 +-
.../plan/analyze/LoadTsFileAnalyzer.java | 4 +-
.../db/queryengine/plan/analyze/ModelFetcher.java | 81 +
.../analyze/schema/AutoCreateSchemaExecutor.java | 20 +-
.../plan/analyze/schema/SchemaValidator.java | 2 +-
.../queryengine/plan/execution/QueryExecution.java | 12 +
.../execution/config/TableConfigTaskVisitor.java | 119 +-
.../execution/config/TreeConfigTaskVisitor.java | 35 +-
.../config/executor/ClusterConfigTaskExecutor.java | 162 +-
.../config/executor/IConfigTaskExecutor.java | 42 +-
.../config/metadata/ShowClusterDetailsTask.java | 62 +
.../execution/config/metadata/ShowClusterTask.java | 15 +
.../CreateModelTask.java} | 25 +-
.../DropModelTask.java} | 21 +-
.../config/metadata/model/ShowAINodesTask.java | 80 +
.../config/metadata/model/ShowModelsTask.java | 112 +
.../relational/AlterTableAddColumnTask.java | 70 +-
...eTask.java => AlterTableSetPropertiesTask.java} | 31 +-
.../metadata/relational/CreateTableTask.java | 4 +-
.../TableModelStatementMemorySourceVisitor.java | 34 +-
.../multi/builtin/helper/CastFunctionHelper.java | 6 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 101 +
.../plan/parser/StatementGenerator.java | 5 +
.../plan/planner/LogicalPlanBuilder.java | 14 +
.../plan/planner/LogicalPlanVisitor.java | 8 +-
.../plan/planner/OperatorTreeGenerator.java | 47 +
.../plan/planner/TableOperatorGenerator.java | 100 +-
.../plan/planner/plan/node/PlanNodeType.java | 17 +-
.../plan/planner/plan/node/PlanVisitor.java | 21 +-
.../plan/node/load/LoadTsFilePieceNode.java | 2 +-
.../read/AbstractTableDeviceQueryNode.java | 7 +-
.../read/TableDeviceAttributeUpdateNode.java | 355 +++
.../node/metadata/read/TableDeviceFetchNode.java | 6 -
.../metadata/read/TableDeviceQueryCountNode.java | 8 +
.../metadata/read/TableDeviceQueryScanNode.java | 40 +-
.../node/metadata/write/CreateTimeSeriesNode.java | 4 +-
.../plan/node/metadata/write/MeasurementGroup.java | 8 +-
.../plan/node/process/AI/InferenceNode.java | 133 +
.../planner/plan/node/write/InsertRowsNode.java | 4 +
.../plan/node/write/RelationalInsertRowsNode.java | 4 +
.../parameter/model/ModelInferenceDescriptor.java | 204 ++
.../plan/relational/analyzer/Analysis.java | 4 +-
.../relational/analyzer/StatementAnalyzer.java | 209 +-
.../schema/CheckSchemaPredicateVisitor.java | 28 +-
.../schema/ExtractPredicateColumnNameVisitor.java | 31 +-
.../plan/relational/metadata/MetadataUtil.java | 8 +-
.../relational/metadata/TableMetadataImpl.java | 310 ++-
.../metadata/fetcher/SchemaPredicateUtil.java | 5 +-
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 146 +-
.../fetcher/TableDeviceSchemaValidator.java | 133 +-
.../fetcher/TableHeaderSchemaValidator.java | 115 +-
.../fetcher/cache/TableDeviceCacheEntry.java | 19 +-
.../fetcher/cache/TableDeviceSchemaCache.java | 39 +-
.../plan/relational/planner/LogicalPlanner.java | 111 +-
.../plan/relational/planner/TranslationMap.java | 19 +
.../distribute/TableDistributedPlanGenerator.java | 18 +-
.../distribute/TableModelQueryFragmentPlanner.java | 5 +-
.../TableModelTypeProviderExtractor.java | 32 +
.../relational/planner/ir/ExpressionRewriter.java | 5 +
.../planner/ir/ExpressionTreeRewriter.java | 23 +
.../plan/relational/planner/ir/IrVisitor.java | 5 +
.../relational/planner/ir/RewritingVisitor.java | 19 +
.../rule/MergeLimitOverProjectWithMergeSort.java | 4 +-
.../rule/MergeLimitOverProjectWithSort.java | 16 +-
.../iterative/rule/MergeLimitWithMergeSort.java | 8 +-
.../planner/iterative/rule/MergeLimitWithSort.java | 13 +-
.../iterative/rule/PushLimitThroughProject.java | 9 +
...ode.java => CreateOrUpdateTableDeviceNode.java} | 38 +-
.../plan/relational/planner/node/JoinNode.java | 3 +
.../PushLimitOffsetIntoTableScan.java | 189 +-
.../optimizations/PushPredicateIntoTableScan.java | 38 +-
.../planner/optimizations/SortElimination.java | 7 +-
.../optimizations/TransformSortToStreamSort.java | 18 +
.../sql/ast/AbstractQueryDeviceWithCache.java | 91 +
...ueryDevice.java => AbstractTraverseDevice.java} | 130 +-
.../plan/relational/sql/ast/AddColumn.java | 59 +-
.../plan/relational/sql/ast/AstVisitor.java | 2 +-
.../plan/relational/sql/ast/ColumnDefinition.java | 30 +-
.../plan/relational/sql/ast/CountDevice.java | 36 +-
...CreateDevice.java => CreateOrUpdateDevice.java} | 6 +-
.../plan/relational/sql/ast/CreateTable.java | 28 +-
.../sql/ast/DefaultTraversalVisitor.java | 10 +-
.../plan/relational/sql/ast/SetProperties.java | 29 +-
.../plan/relational/sql/ast/ShowDevice.java | 90 +-
.../plan/relational/sql/ast/Update.java | 62 +-
.../plan/relational/sql/ast/UpdateAssignment.java | 32 +-
.../relational/sql/ast/WrappedInsertStatement.java | 25 +-
.../plan/relational/sql/parser/AstBuilder.java | 188 +-
.../plan/relational/sql/util/SqlFormatter.java | 26 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 2 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 12 +-
.../plan/statement/StatementVisitor.java | 29 +-
.../plan/statement/crud/InsertBaseStatement.java | 14 +-
.../crud/InsertMultiTabletsStatement.java | 4 +-
.../plan/statement/crud/InsertRowStatement.java | 6 +-
.../crud/InsertRowsOfOneDeviceStatement.java | 4 +-
.../plan/statement/crud/InsertRowsStatement.java | 4 +-
.../plan/statement/crud/InsertTabletStatement.java | 2 +-
.../plan/statement/crud/QueryStatement.java | 64 +
.../metadata/AlterTimeSeriesStatement.java | 26 +-
.../metadata/CreateMultiTimeSeriesStatement.java | 2 +-
.../metadata/DeleteTimeSeriesStatement.java | 2 +-
.../CreateModelStatement.java} | 61 +-
.../DropModelStatement.java} | 47 +-
.../metadata/model/ShowAINodesStatement.java | 27 +-
.../ShowModelsStatement.java} | 55 +-
.../binary/CompareBinaryColumnTransformer.java | 3 +-
.../column/unary/scalar/AbsColumnTransformer.java | 56 +
.../column/unary/scalar/AcosColumnTransformer.java | 53 +
.../column/unary/scalar/AsinColumnTransformer.java | 53 +
.../column/unary/scalar/AtanColumnTransformer.java | 53 +
.../scalar/CastFunctionColumnTransformer.java | 149 +-
.../column/unary/scalar/CeilColumnTransformer.java | 53 +
.../unary/scalar/Concat2ColumnTransformer.java | 61 +
.../unary/scalar/ConcatColumnTransformer.java | 66 +
.../unary/scalar/ConcatMultiColumnTransformer.java | 74 +
.../column/unary/scalar/CosColumnTransformer.java | 53 +
.../column/unary/scalar/CoshColumnTransformer.java | 53 +
.../scalar/DateBinFunctionColumnTransformer.java | 158 ++
.../unary/scalar/DegreesColumnTransformer.java | 53 +
.../unary/scalar/EndsWith2ColumnTransformer.java | 56 +
.../unary/scalar/EndsWithColumnTransformer.java | 52 +
.../column/unary/scalar/ExpColumnTransformer.java | 53 +
.../unary/scalar/FloorColumnTransformer.java | 53 +
.../unary/scalar/LTrim2ColumnTransformer.java | 56 +
.../unary/scalar/LTrimColumnTransformer.java | 70 +
.../unary/scalar/LengthColumnTransformer.java | 47 +
.../column/unary/scalar/LnColumnTransformer.java | 53 +
.../unary/scalar/Log10ColumnTransformer.java | 53 +
.../unary/scalar/LowerColumnTransformer.java | 47 +
.../unary/scalar/RTrim2ColumnTransformer.java | 56 +
.../unary/scalar/RTrimColumnTransformer.java | 70 +
.../unary/scalar/RadiansColumnTransformer.java | 53 +
.../unary/scalar/RegexpLike2ColumnTransformer.java | 54 +
.../unary/scalar/RegexpLikeColumnTransformer.java | 52 +
.../column/unary/scalar/SignColumnTransformer.java | 53 +
.../column/unary/scalar/SinColumnTransformer.java | 53 +
.../column/unary/scalar/SinhColumnTransformer.java | 53 +
.../column/unary/scalar/SqrtColumnTransformer.java | 53 +
.../unary/scalar/StartsWith2ColumnTransformer.java | 55 +
.../unary/scalar/StartsWithColumnTransformer.java | 61 +
.../unary/scalar/Strcmp2ColumnTransformer.java | 54 +
.../unary/scalar/StrcmpColumnTransformer.java | 50 +
.../unary/scalar/Strpos2ColumnTransformer.java | 54 +
.../unary/scalar/StrposColumnTransformer.java | 50 +
.../unary/scalar/TableBuiltinScalarFunction.java | 71 +
.../column/unary/scalar/TanColumnTransformer.java | 53 +
.../column/unary/scalar/TanhColumnTransformer.java | 53 +
.../unary/scalar/Trim2ColumnTransformer.java | 56 +
.../column/unary/scalar/TrimColumnTransformer.java | 82 +
.../unary/scalar/UpperColumnTransformer.java | 48 +
.../schemaengine/schemaregion/ISchemaRegion.java | 16 +-
.../schemaregion/SchemaRegionPlanType.java | 4 +
.../schemaregion/SchemaRegionPlanVisitor.java | 55 +-
.../attribute/DeviceAttributeStore.java | 43 +-
.../attribute/IDeviceAttributeStore.java | 13 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 567 ++--
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 26 +-
.../visitor/SchemaRegionPlanDeserializer.java | 109 +-
.../visitor/SchemaRegionPlanSerializer.java | 182 +-
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 55 +-
.../read/resp/info/impl/ShowDevicesResult.java | 18 +
.../write/req/SchemaRegionWritePlanFactory.java | 6 +
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 16 +
.../apache/iotdb/db/service/AINodeRPCService.java | 94 +
.../iotdb/db/service/AINodeRPCServiceMBean.java | 4 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../db/service/metrics/DataNodeMetricsHelper.java | 6 +-
.../iotdb/db/storageengine/StorageEngine.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 4 +-
.../BatchCompactionCannotAlignedException.java | 55 +
.../performer/impl/FastCompactionPerformer.java | 5 +-
.../impl/ReadChunkCompactionPerformer.java | 124 +-
.../impl/ReadPointCompactionPerformer.java | 11 +-
.../execute/task/CompactionTaskSummary.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 571 ++--
.../task/RepairUnsortedFileCompactionTask.java | 65 +-
.../execute/task/SettleCompactionTask.java | 105 +-
.../subtask/FastCompactionPerformerSubTask.java | 50 +-
.../task/subtask/ReadPointPerformerSubTask.java | 4 +-
.../execute/utils/CompactionPathUtils.java | 2 +-
.../utils/CompactionTableSchemaCollector.java | 13 +-
.../compaction/execute/utils/CompactionUtils.java | 19 +
...BatchedFastAlignedSeriesCompactionExecutor.java | 387 +++
...edReadChunkAlignedSeriesCompactionExecutor.java | 426 +++
.../utils/AlignedSeriesBatchCompactionUtils.java | 176 ++
.../executor/batch/utils/BatchCompactionPlan.java | 68 +
.../BatchedCompactionAlignedPagePointReader.java | 95 +
.../batch/utils/ChunkWriterFlushCallback.java | 9 +-
.../executor/batch/utils/CompactChunkPlan.java | 70 +
.../utils/CompactPagePlan.java} | 33 +-
.../FirstBatchCompactionAlignedChunkWriter.java | 187 ++
...FollowingBatchCompactionAlignedChunkWriter.java | 266 ++
...va => FastAlignedSeriesCompactionExecutor.java} | 241 +-
...=> FastNonAlignedSeriesCompactionExecutor.java} | 38 +-
.../executor/fast/SeriesCompactionExecutor.java | 71 +-
.../executor/fast/element/AlignedPageElement.java | 22 +-
.../fast/element/ChunkMetadataElement.java | 19 +-
.../utils/executor/fast/element/FileElement.java | 10 +
.../fast/element/NonAlignedPageElement.java | 5 +-
.../utils/executor/fast/element/PageElement.java | 18 +-
.../utils/executor/fast/element/PointElement.java | 8 +-
.../fast/reader/CompactionAlignedChunkReader.java | 29 +-
.../ReadChunkAlignedSeriesCompactionExecutor.java | 109 +-
.../executor/readchunk/loader/ChunkLoader.java | 8 +-
.../readchunk/loader/InstantChunkLoader.java | 7 +-
.../readchunk/loader/InstantPageLoader.java | 8 +-
.../executor/readchunk/loader/PageLoader.java | 18 +-
.../execute/utils/reader/PointPriorityReader.java | 12 +-
.../utils/writer/AbstractCompactionWriter.java | 65 +-
.../writer/AbstractCrossCompactionWriter.java | 13 +-
.../writer/AbstractInnerCompactionWriter.java | 99 +-
.../utils/writer/FastCrossCompactionWriter.java | 105 +-
.../utils/writer/FastInnerCompactionWriter.java | 103 +-
.../writer/ReadPointCrossCompactionWriter.java | 48 +-
.../writer/ReadPointInnerCompactionWriter.java | 42 +-
.../writer/RepairUnsortedFileCompactionWriter.java | 7 +-
.../AbstractCompactionFlushController.java} | 45 +-
.../FollowedBatchedCompactionFlushController.java | 68 +
.../compaction/io/CompactionTsFileWriter.java | 3 +-
.../schedule/CompactionScheduleTaskManager.java | 1 +
.../DefaultCompactionTaskComparatorImpl.java | 16 +-
.../constant/InnerSequenceCompactionSelector.java | 16 +-
.../InnerUnsequenceCompactionSelector.java | 16 +-
.../estimator/AbstractCrossSpaceEstimator.java | 3 +
.../estimator/AbstractInnerSpaceEstimator.java | 3 +
.../estimator/CompactionEstimateUtils.java | 9 +
.../FastCompactionInnerCompactionEstimator.java | 23 +-
.../FastCrossSpaceCompactionEstimator.java | 27 +-
.../ReadChunkInnerCompactionEstimator.java | 21 +-
.../RepairUnsortedFileCompactionEstimator.java | 10 +
.../impl/NewSizeTieredCompactionSelector.java | 295 +++
.../impl/RewriteCrossSpaceCompactionSelector.java | 14 +-
.../selector/impl/SettleSelectorImpl.java | 2 +-
.../impl/SizeTieredCompactionSelector.java | 12 +-
.../utils/CrossSpaceCompactionCandidate.java | 2 +-
.../selector/utils/TsFileResourceCandidate.java | 11 +-
.../compaction/settle/SettleRequestHandler.java | 2 +-
.../read/reader/chunk/DiskAlignedChunkLoader.java | 5 +
.../read/reader/chunk/DiskChunkLoader.java | 5 +
.../dataregion/read/reader/common/Element.java | 9 +-
.../read/reader/common/MergeReaderPriority.java | 73 +
.../read/reader/common/PriorityMergeReader.java | 49 +-
.../dataregion/snapshot/SnapshotTaker.java | 34 +-
.../storageengine/dataregion/tsfile/TsFileID.java | 34 +-
.../dataregion/tsfile/TsFileResource.java | 6 +-
.../tsfile/generator/TsFileNameGenerator.java | 34 +
.../dataregion/utils/TsFileResourceUtils.java | 22 +-
.../load/LoadTsFileManager.java | 22 +-
.../storageengine/load/active/ActiveLoadAgent.java | 51 +
.../load/active/ActiveLoadDirScanner.java | 77 +-
.../load/active/ActiveLoadMetricsCollector.java | 96 +
.../load/active/ActiveLoadPendingQueue.java | 11 +-
.../active/ActiveLoadScheduledExecutorService.java | 107 +
.../load/active/ActiveLoadTsFileLoader.java | 79 +-
.../load/limiter/LoadTsFileRateLimiter.java | 4 +-
.../memory}/LoadTsFileAbstractMemoryBlock.java | 2 +-
.../LoadTsFileAnalyzeSchemaMemoryBlock.java | 4 +-
.../memory}/LoadTsFileDataCacheMemoryBlock.java | 2 +-
.../load/memory}/LoadTsFileMemoryManager.java | 2 +-
.../load/metrics/ActiveLoadingFilesMetricsSet.java | 113 +
.../load/metrics}/LoadTsFileCostMetricsSet.java | 2 +-
.../load/metrics}/LoadTsFileMemMetricSet.java | 4 +-
.../load/splitter/AlignedChunkData.java | 74 +-
.../splitter/BatchedAlignedValueChunkData.java | 237 ++
.../load/splitter/ChunkData.java | 2 +-
.../load/splitter/DeletionData.java | 2 +-
.../load/splitter/NonAlignedChunkData.java | 2 +-
.../load/splitter/TsFileData.java | 2 +-
.../load/splitter/TsFileSplitter.java | 469 ++--
.../rescon/quotas/DataNodeSpaceQuotaManager.java | 89 +-
.../apache/iotdb/db/tools/schema/MLogParser.java | 1 +
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 40 +-
.../SchemaRegionSimpleRecoverTest.java | 81 +
.../schemaRegion/SchemaRegionTableDeviceTest.java | 74 +-
.../schemaRegion/SchemaRegionTestUtil.java | 36 +-
.../PipeStatementPatternParseVisitorTest.java | 54 +-
.../event/TsFileInsertionDataContainerTest.java | 553 +---
.../extractor/PipePlanPatternParseVisitorTest.java | 104 +-
.../analyzer/LimitOffsetPushDownTest.java | 16 +
.../plan/relational/analyzer/SortTest.java | 229 +-
.../plan/relational/analyzer/SubQueryTest.java | 477 ++++
.../fetcher/cache/TableDeviceSchemaCacheTest.java | 40 +-
.../planner/assertions/OffsetMatcher.java | 6 +
.../relational/planner/assertions/PlanAssert.java | 3 +-
.../planner/assertions/PlanMatchPattern.java | 5 +
.../column/unary/scalar/DateBinFunctionTest.java | 101 +
.../storageengine/dataregion/DataRegionTest.java | 22 +-
.../compaction/AbstractCompactionTest.java | 101 +
.../BatchedCompactionWithTsFileSplitterTest.java | 350 +++
.../compaction/CompactionSchedulerTest.java | 96 +-
.../CompactionSchedulerWithFastPerformerTest.java | 96 +-
.../FastCompactionPerformerWithEmptyPageTest.java | 8 +
...InconsistentCompressionTypeAndEncodingTest.java | 13 +-
...tchedAlignedSeriesCrossSpaceCompactionTest.java | 510 ++++
...eCompactionWithFastPerformerValidationTest.java | 18 +-
...actionWithReadPointPerformerValidationTest.java | 16 +-
.../cross/RewriteCompactionFileSelectorTest.java | 6 +
...atchedAlignedSeriesFastInnerCompactionTest.java | 415 +++
...tchedAlignedSeriesReadChunkCompactionTest.java} | 503 ++--
.../inner/FastCompactionPerformerAlignedTest.java | 64 +-
.../FastCompactionPerformerNoAlignedTest.java | 36 +-
.../inner/InnerCompactionSchedulerTest.java | 10 +-
.../inner/InnerSequenceCompactionSpeedTest.java | 4 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 2 +-
...nkCompactionPerformerWithAlignedSeriesTest.java | 456 ++--
.../ReadChunkCompactionPerformerAlignedTest.java | 64 +-
.../ReadChunkCompactionPerformerNoAlignedTest.java | 48 +-
.../NewSizeTieredCompactionSelectorTest.java | 644 +++++
.../repair/RepairUnsortedFileCompactionTest.java | 306 ---
.../repair/RepairUnsortedFileSchedulerTest.java | 384 +++
.../settle/SettleCompactionSelectorTest.java | 32 +-
.../settle/SettleCompactionTaskTest.java | 4 +-
.../settle/SettleRequestHandlerTest.java | 6 +-
.../compaction/utils/BatchCompactionUtilsTest.java | 293 +++
.../compaction/utils/CompactionCheckerUtils.java | 130 +-
.../compaction/utils/CompactionConfigRestorer.java | 4 +-
.../compaction/utils/CompactionTestFileWriter.java | 39 +-
.../compaction/utils/MergeReaderPriorityTest.java | 96 +
iotdb-core/node-commons/pom.xml | 6 +
.../conf/iotdb-system.properties.template | 39 +-
.../iotdb/commons/client/ClientPoolFactory.java | 52 +
.../iotdb/commons/client/ainode/AINodeClient.java | 237 ++
.../ainode/AINodeClientManager.java} | 30 +-
.../iotdb/commons/client/ainode/AINodeInfo.java | 18 +-
.../client/ainode/AsyncAINodeServiceClient.java | 143 +
.../org/apache/iotdb/commons/cluster/NodeType.java | 3 +-
.../iotdb/commons/concurrent/ThreadName.java | 4 +
.../apache/iotdb/commons/conf/CommonConfig.java | 26 +
.../exception/ainode/LoadModelException.java | 15 +-
.../iotdb/commons/model/ModelHyperparameter.java | 81 +
.../iotdb/commons/model/ModelInformation.java | 364 +++
.../apache/iotdb/commons/model/ModelStatus.java | 10 +-
.../org/apache/iotdb/commons/model/ModelTable.java | 94 +
.../org/apache/iotdb/commons/model/ModelType.java | 8 +-
.../model/exception/ModelManagementException.java | 8 +-
.../iotdb/commons/partition/SchemaPartition.java | 1 +
.../org/apache/iotdb/commons/path/PartialPath.java | 9 +
.../config/constant/PipeConnectorConstant.java | 11 +
.../connector/client/IoTDBSyncClientManager.java | 8 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../pipe/connector/protocol/IoTDBConnector.java | 28 +
.../connector/protocol/IoTDBSslSyncConnector.java | 6 +-
.../AbstractSerializableListeningQueue.java | 4 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 14 +
.../iotdb/commons/pipe/task/PipeTaskManager.java | 13 +
.../iotdb/commons/schema/SchemaConstant.java | 1 +
.../schema/table/AlterTableOperationType.java | 9 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 20 +-
.../schema/table/column/TsTableColumnSchema.java | 4 +
.../apache/iotdb/commons/service/ServiceType.java | 1 +
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../org/apache/iotdb/commons/utils/FileUtils.java | 53 +
.../commons/utils/ThriftCommonsSerDeUtils.java | 59 +
iotdb-core/pom.xml | 8 +
.../db/relational/grammar/sql/RelationalSql.g4 | 15 +-
iotdb-protocol/pom.xml | 1 +
.../thrift-ainode}/pom.xml | 51 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 91 +
.../thrift-commons/src/main/thrift/common.thrift | 30 +
.../src/main/thrift/confignode.thrift | 128 +-
.../src/main/thrift/datanode.thrift | 58 +-
pom.xml | 10 +-
741 files changed, 52380 insertions(+), 6676 deletions(-)
copy .github/workflows/{unit-test.yml => daily-ut.yml} (74%)
copy .github/workflows/{cluster-it-1c1d.yml => table-cluster-it-1c1d.yml} (94%)
copy .github/workflows/{cluster-it-1c3d.yml => table-cluster-it-1c3d.yml} (89%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> MultiClusterIT2SubscriptionArchVerification.java} (93%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> MultiClusterIT2SubscriptionRegressionConsumer.java} (92%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> MultiClusterIT2SubscriptionRegressionMisc.java} (93%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> TableClusterIT.java} (94%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/{MultiClusterIT2Subscription.java
=> TableLocalStandaloneIT.java} (94%)
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/{query/old/orderBy
=> db/it}/IoTDBMultiIDsWithAttributesTableIT.java (82%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/old/builtinfunction/scalar/IoTDBScalarFunctionTableIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDeviceIT.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBDeviceQueryIT.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/element/FileElement.java
=>
integration-test/src/test/java/org/apache/iotdb/subscription/it/DisplayName.java
(68%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/SkipOnSetUpAndTearDownFailure.java
delete mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/SkipOnSetUpFailure.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/AbstractSubscriptionRegressionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBDefaultTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/auto_create_db/IoTDBRootPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/mix/IoTDBPushConsumerPullConsumerWith1TopicShareProcessMixIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamSubscriptionSessionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/param/IoTDBTestParamTopicIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitFalseDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/autocommit/IoTDBTestAutoCommitTrueDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/format/IoTDBDBTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsDatasetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBAllTsfilePullConsumerSnapshotIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceDataSetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBPathDeviceTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsDatasetPullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/loose_range/IoTDBTimeTsTsfilePullConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/mode/IoTDBSnapshotDevicePullConsumerTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDBPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDefaultPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBDevicePatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatch2PatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBMiddleMatchPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBRootPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/pattern/IoTDBTSPatternPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBAllPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBHistoryPullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBRealTimePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangeAccuratePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pullconsumer/time/IoTDBTimeRangePullConsumerDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeNoTargetDirTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/format/IoTDBTestPushConsumeTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsDatasetPushConsumerSnapshotIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBLooseAllTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseDeviceTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathLooseTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBPathTsLooseDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeLooseTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/loose_range/IoTDBTimeTsLooseDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/mode/IoTDBSnapshotTSPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessDataSetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBConsumer2With1TopicShareProcessTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBMultiGroupVsMultiConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsDatasetIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsMixIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/multi/IoTDBOneConsumerMultiTopicsTsfileIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDBPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDefaultPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBDevicePatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBRootPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/pattern/IoTDBTSPatternTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBHistoryRootTsFilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBDatasetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBRealTimeDBTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeAccurateDBDataSetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBDataSetPushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/pushconsumer/time/IoTDBTimeRangeDBTsfilePushConsumerIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBDataSet1TopicConsumerSpecialIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/topic/IoTDBTestTopicNameIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/triple/regression/user/IoTDBOtherUserConsumerIT.java
create mode 100644 iotdb-core/ainode/.gitignore
copy iotdb-protocol/pom.xml => iotdb-core/ainode/README.md (51%)
copy iotdb-protocol/pom.xml => iotdb-core/ainode/README_ZH.md (51%)
create mode 100644 iotdb-core/ainode/ainode.xml
copy {iotdb-client/client-py => iotdb-core/ainode}/iotdb/__init__.py (100%)
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode}/__init__.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/attribute.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/client.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/config.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/constant.py
copy iotdb-client/client-py/iotdb/__init__.py =>
iotdb-core/ainode/iotdb/ainode/encryption.py (100%)
create mode 100644 iotdb-core/ainode/iotdb/ainode/exception.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/factory.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/handler.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/inference.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/log.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/parser.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/script.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/serde.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/service.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/storage.py
create mode 100644 iotdb-core/ainode/iotdb/ainode/util.py
create mode 100644 iotdb-core/ainode/pom.xml
create mode 100644 iotdb-core/ainode/pyproject.toml
create mode 100644 iotdb-core/ainode/resources/conf/ainode-env.bat
create mode 100644 iotdb-core/ainode/resources/conf/ainode-env.sh
create mode 100644 iotdb-core/ainode/resources/conf/iotdb-ainode.properties
create mode 100644 iotdb-core/ainode/resources/sbin/remove-ainode.bat
create mode 100755 iotdb-core/ainode/resources/sbin/remove-ainode.sh
create mode 100644 iotdb-core/ainode/resources/sbin/start-ainode.bat
create mode 100644 iotdb-core/ainode/resources/sbin/start-ainode.sh
create mode 100644 iotdb-core/ainode/resources/sbin/stop-ainode.bat
create mode 100644 iotdb-core/ainode/resources/sbin/stop-ainode.sh
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/AsyncAINodeHeartbeatClientPool.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/heartbeat/AINodeHeartbeatHandler.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/ainode/GetAINodeConfigurationPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/model/GetModelInfoPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/model/ShowModelPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ainode/RegisterAINodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ainode/RemoveAINodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/ainode/UpdateAINodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/CreateModelPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/DropModelInNodePlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/DropModelPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/model/UpdateModelInfoPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/table/SetTablePropertiesPlan.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionExecutionResult.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ainode/AINodeConfigurationResp.java}
(53%)
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionExecutionResult.java
=>
confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/ainode/AINodeRegisterResp.java}
(50%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/model/GetModelInfoResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/model/ModelTableResp.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/ModelManager.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/cache/node/{DataNodeHeartbeatCache.java
=> AINodeHeartbeatCache.java} (60%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/ModelInfo.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/CreateModelProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/model/DropModelProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/node/RemoveAINodeProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedure.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/RemoveAINodeState.java
(87%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/CreateModelState.java
(87%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/model/DropModelState.java
(86%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/SetTablePropertiesState.java
(82%)
create mode 100644
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/table/SetTablePropertiesProcedureTest.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/GetModelInfoException.java
(76%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/ModelException.java
(70%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/ainode/ModelNotFoundException.java
(76%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/exception/runtime/ModelInferenceProcessException.java
(80%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/handler/AINodeRPCServiceThriftHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/AINodeRPCServiceImpl.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/IAINodeRPCServiceWithHandler.java
(78%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/process/AI/InferenceOperator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DeviceAttributeUpdater.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DevicePredicateFilter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/schema/source/DevicePredicateHandler.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/BottomInferenceWindowParameter.java
copy
iotdb-core/{node-commons/src/main/java/org/apache/iotdb/commons/schema/table/AlterTableOperationType.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/CountInferenceWindow.java}
(65%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/CountInferenceWindowParameter.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/HeadInferenceWindow.java
(70%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/InferenceWindow.java
(74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/InferenceWindowParameter.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/InferenceWindowType.java
(85%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/window/ainode/TailInferenceWindow.java
(70%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/IModelFetcher.java
(75%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/ModelFetcher.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{relational/CreateTableTask.java
=> model/CreateModelTask.java} (69%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{relational/CreateTableTask.java
=> model/DropModelTask.java} (69%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/ShowAINodesTask.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/model/ShowModelsTask.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/relational/{CreateTableTask.java
=> AlterTableSetPropertiesTask.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/read/TableDeviceAttributeUpdateNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/process/AI/InferenceNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/parameter/model/ModelInferenceDescriptor.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{CreateTableDeviceNode.java
=> CreateOrUpdateTableDeviceNode.java} (88%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/AbstractQueryDeviceWithCache.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{AbstractQueryDevice.java
=> AbstractTraverseDevice.java} (51%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{CreateDevice.java
=> CreateOrUpdateDevice.java} (95%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{DeleteTimeSeriesStatement.java
=> model/CreateModelStatement.java} (65%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{DeleteTimeSeriesStatement.java
=> model/DropModelStatement.java} (64%)
copy
integration-test/src/test/java/org/apache/iotdb/subscription/it/local/AbstractSubscriptionLocalIT.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/model/ShowAINodesStatement.java
(56%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/{DeleteTimeSeriesStatement.java
=> model/ShowModelsStatement.java} (64%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AbsColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AcosColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AsinColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/AtanColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CeilColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Concat2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ConcatColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ConcatMultiColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CosColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/CoshColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DateBinFunctionColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DegreesColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/EndsWith2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/EndsWithColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/ExpColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/FloorColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LTrim2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LTrimColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LengthColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LnColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Log10ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/LowerColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RTrim2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RTrimColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RadiansColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RegexpLike2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/RegexpLikeColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SignColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SinhColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/SqrtColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StartsWith2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StartsWithColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Strcmp2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StrcmpColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Strpos2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/StrposColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TableBuiltinScalarFunction.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TanhColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/Trim2ColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/TrimColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/UpperColumnTransformer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCService.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/AINodeRPCServiceMBean.java
(90%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/BatchCompactionCannotAlignedException.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/BatchedFastAlignedSeriesCompactionExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/BatchedReadChunkAlignedSeriesCompactionExecutor.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/AlignedSeriesBatchCompactionUtils.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/BatchCompactionPlan.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/BatchedCompactionAlignedPagePointReader.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/ChunkWriterFlushCallback.java
(75%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/CompactChunkPlan.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/{fast/element/FileElement.java
=> batch/utils/CompactPagePlan.java} (52%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/FirstBatchCompactionAlignedChunkWriter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/batch/utils/FollowingBatchCompactionAlignedChunkWriter.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/{AlignedSeriesCompactionExecutor.java
=> FastAlignedSeriesCompactionExecutor.java} (70%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/executor/fast/{NonAlignedSeriesCompactionExecutor.java
=> FastNonAlignedSeriesCompactionExecutor.java} (88%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/{executor/fast/element/ChunkMetadataElement.java
=> writer/flushcontroller/AbstractCompactionFlushController.java} (50%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/utils/writer/flushcontroller/FollowedBatchedCompactionFlushController.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/impl/NewSizeTieredCompactionSelector.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/common/MergeReaderPriority.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/LoadTsFileManager.java (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadAgent.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/active/ActiveLoadDirScanner.java (74%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadMetricsCollector.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/active/ActiveLoadPendingQueue.java (81%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadScheduledExecutorService.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/active/ActiveLoadTsFileLoader.java (79%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/limiter/LoadTsFileRateLimiter.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileAbstractMemoryBlock.java (97%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileAnalyzeSchemaMemoryBlock.java (96%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileDataCacheMemoryBlock.java (98%)
rename iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/load
=> storageengine/load/memory}/LoadTsFileMemoryManager.java (99%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/metrics/ActiveLoadingFilesMetricsSet.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/metric/load
=> storageengine/load/metrics}/LoadTsFileCostMetricsSet.java (98%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/metric/load
=> storageengine/load/metrics}/LoadTsFileMemMetricSet.java (96%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/AlignedChunkData.java (89%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/load/splitter/BatchedAlignedValueChunkData.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/ChunkData.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/DeletionData.java (97%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/NonAlignedChunkData.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/TsFileData.java (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{queryengine/execution =>
storageengine}/load/splitter/TsFileSplitter.java (50%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/SubQueryTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/DateBinFunctionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/BatchedCompactionWithTsFileSplitterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/cross/BatchedAlignedSeriesCrossSpaceCompactionTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/BatchedAlignedSeriesFastInnerCompactionTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/{NewReadChunkCompactionPerformerWithAlignedSeriesTest.java
=> BatchedAlignedSeriesReadChunkCompactionTest.java} (59%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/inner/sizetiered/NewSizeTieredCompactionSelectorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/repair/RepairUnsortedFileSchedulerTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/BatchCompactionUtilsTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/MergeReaderPriorityTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeClient.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/{cluster/NodeType.java
=> client/ainode/AINodeClientManager.java} (54%)
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AINodeInfo.java
(70%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/ainode/AsyncAINodeServiceClient.java
copy integration-test/src/main/java/org/apache/iotdb/it/env/EnvType.java =>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/exception/ainode/LoadModelException.java
(76%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelHyperparameter.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelInformation.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelStatus.java
(86%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelTable.java
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/ModelType.java
(86%)
rename
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2Subscription.java
=>
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/model/exception/ModelManagementException.java
(80%)
copy {example/pipe-count-point-processor =>
iotdb-protocol/thrift-ainode}/pom.xml (55%)
create mode 100644 iotdb-protocol/thrift-ainode/src/main/thrift/ainode.thrift
