This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cache_non_exist_timeseries_metadata
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 2958bd3fcd5 Merge branch 'master' into
cache_non_exist_timeseries_metadata
add 6952ebf4dc3 Fix Python & Go Client CI (#17081)
add 8e5fcba50ba Fix cross partition write after alter data type (#17082)
add 2e46872766b Support stream DataFrame interface in iotdb python client
(#17035)
add 465170bac57 Adjust error message (#17084)
add d90397dc1ff [AINode] Call inference should only contain 1 input column
(#17087)
add 81f8e7e1fa3 [AINode] Fix the bug that AINode would not stop during
remove process (#17088)
add 0b25ea24c9c Support NULL time in First/Last/FirstBy/LastBy
aggregations (#17064)
add d06bced6c3a Support session with CPP conditional compilation for SSL.
(#17080)
add 82f7ca6dfc5 Pipe: Fixed the OPC UA client connection problem (#17083)
add b40b74b31ea Remove built-in jexl function in tree mode (#17092)
add 5802fa2e0ab Resolve the problem that everyone can alter table column
data type. (#17089)
add 8289238b119 Fix init time logic to ensure that time is not initiated‌
when the last cache will not updated during the execution phase (#17094)
add 52715f18e48 Verify nonexist measurement in an exist device if it
exists. (#17093)
add afcfd7419c1 fix (#17096)
add 11054f94e8c Fix allValueColDeletedMap index out of bound caused by
stale rowCount after TVList sort (#17098)
add d05276e2955 Decouple rest from iotdb-server using ExternalService
framework (#17099)
add dad8ec8824e Remove text involve DataNodeId when assert two results.
(#17107)
add 12b5bc3e9af Fix binary allocator test & querying type-altered chunks
in memory may affect the result of flush (#17105)
add 498197b31e4 Add mqtt IT for json mode. (#17090)
add 5f641b262c3 Fix timeseries alias display in last for TreeModel (#17109)
add 256f2fce84f update chunk metadata after rewrite (#17110)
add ba95e5fd4c0 Set MQTT address to empty string. (#17111)
add 938f8149430 Pipe: add inclusion/exclusion pattern keys for pipe source
filtering (#17091)
add b2e15704661 Support build project by jdk25 (#17118)
add a61e01a5ce1 Use independent test folder for LocalFileRoleAccessorTest
(#17114)
add 743755cba8f Optimized the hint for subscription (#17115)
add 48ac5db7593 TimeFilter.canSkip() use getStatistics() method (#17119)
add 003f9b68d73 Support User Defined time column name (#17102)
add fd9134acc13 Add must override check (#17112)
add 749d5f5e13c Fix delete NPE after insert failed (#17122)
add 30b3de6fcc0 Subscription: Optimized the performance (#17121)
add b6c7300aa0c Load: Fixed the bug that active load may fail for table
model (#17124)
add d703886e2c8 [Bug fix] The partition table is cleaned incorrectly when
set only device TTL for tree mode (#17123)
add 8455b8c4c1f Optimize TsTable with Copy-on-Write pattern for
thread-safe concurrent access (#17069)
add 8488a64cab4 [AINode] Integrate moirai2 as builtin forecasting model
(#17056)
add 2d07d8afc2a Security fix: Bump Jetty to 9.4.58.v20250814
(CVE-2025-5115) (#17136)
add f445132b2ee Fix blob accumulator query can't skip read blobStatistics
caused by isModified don't change to true in the metadata of chunk and
pageReader (#17127)
add 0650a6a3456 Fix value and time chunk misalignment when rewriting with
time deletion (#17142)
add 2146a080230 fix: Fix ShowTimeseries estimated offset without limit
scenario (#17116)
add e4ef4db9a69 fix the problem that cast a float point number to float
type, by adding the floatLiteral (#17143)
add 1b6b4515b5c Merge branch 'master' into
cache_non_exist_timeseries_metadata
add 89e9fc2cb8e Merge branch 'cache_non_exist_timeseries_metadata' of
github.com:apache/iotdb into cache_non_exist_timeseries_metadata
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 2 +-
LICENSE | 12 +-
LICENSE-binary | 12 +-
README.md | 4 +-
README_ZH.md | 4 +-
dependencies.json | 1 -
distribution/pom.xml | 6 +
distribution/src/assembly/all.xml | 4 +
distribution/src/assembly/datanode.xml | 4 +
.../src/assembly/external-service-impl.xml | 4 +
docker/src/main/Dockerfile-1c1d | 4 +-
example/client-cpp-example/src/CMakeLists.txt | 157 ++-
.../org/apache/iotdb/mqtt/MPPPublishHandler.java | 2 +-
external-service-impl/pom.xml | 2 +
.../rest-openapi}/pom.xml | 34 +-
.../src/main/openapi3/iotdb_rest_common.yaml | 0
.../src/main/openapi3/iotdb_rest_table_v1.yaml | 0
.../src/main/openapi3/iotdb_rest_v1.yaml | 0
.../src/main/openapi3/iotdb_rest_v2.yaml | 0
external-service-impl/{mqtt => rest}/pom.xml | 153 ++-
.../java/org/apache/iotdb/rest}/RestService.java | 30 +-
.../rest/protocol}/filter/ApiOriginFilter.java | 2 +-
.../rest/protocol}/filter/AuthorizationFilter.java | 4 +-
.../protocol}/filter/BasicSecurityContext.java | 2 +-
.../apache/iotdb/rest/protocol}/filter/User.java | 2 +-
.../iotdb/rest/protocol}/filter/UserCache.java | 2 +-
.../protocol}/handler/AuthorizationHandler.java | 4 +-
.../rest/protocol}/impl/PingApiServiceImpl.java | 6 +-
.../table/v1/handler/ExceptionHandler.java | 4 +-
.../table/v1/handler/ExecuteStatementHandler.java | 2 +-
.../table/v1/handler/QueryDataSetHandler.java | 6 +-
.../table/v1/handler/RequestValidationHandler.java | 6 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../table/v1/impl/RestApiServiceImpl.java | 26 +-
.../rest/protocol}/utils/InsertRowDataUtils.java | 2 +-
.../protocol}/utils/InsertTabletSortDataUtils.java | 2 +-
.../protocol/v1}/handler/ExceptionHandler.java | 4 +-
.../v1/handler/ExecuteStatementHandler.java | 2 +-
.../protocol}/v1/handler/QueryDataSetHandler.java | 26 +-
.../v1/handler/RequestValidationHandler.java | 8 +-
.../v1/handler/StatementConstructionHandler.java | 4 +-
.../protocol}/v1/impl/GrafanaApiServiceImpl.java | 18 +-
.../rest/protocol}/v1/impl/RestApiServiceImpl.java | 32 +-
.../protocol/v2}/handler/ExceptionHandler.java | 4 +-
.../v2/handler/ExecuteStatementHandler.java | 2 +-
.../rest/protocol}/v2/handler/FastLastHandler.java | 10 +-
.../protocol}/v2/handler/QueryDataSetHandler.java | 22 +-
.../v2/handler/RequestValidationHandler.java | 12 +-
.../v2/handler/StatementConstructionHandler.java | 8 +-
.../protocol}/v2/impl/GrafanaApiServiceImpl.java | 18 +-
.../rest/protocol}/v2/impl/RestApiServiceImpl.java | 36 +-
integration-test/pom.xml | 7 +
integration-test/src/assembly/mpp-share.xml | 4 +
.../it/env/cluster/config/MppCommonConfig.java | 5 -
.../env/cluster/config/MppSharedCommonConfig.java | 6 -
.../it/env/cluster/node/AbstractNodeWrapper.java | 2 +-
.../it/env/remote/config/RemoteCommonConfig.java | 5 -
.../iotdb/it/utils/TsFileTableGenerator.java | 30 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 1 -
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 -
.../iotdb/ainode/it/AINodeCallInferenceIT.java | 14 +
.../apache/iotdb/ainode/utils/AINodeTestUtils.java | 4 +-
.../partition/IoTDBPartitionTableAutoCleanIT.java | 57 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 25 +
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 259 ++++
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 10 +-
.../iotdb/db/it/auth/IoTDBSeriesPermissionIT.java | 7 +
...stCache2IT.java => IoTDBLastQueryAlias2IT.java} | 2 +-
.../iotdb/db/it/last/IoTDBLastQueryAliasIT.java | 164 +++
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 363 +++++
.../db/it/query/IoTDBAggregationFirstByIT.java | 271 ++++
.../it/query/IoTDBAggregationFirstByInGroupIT.java | 177 +++
.../iotdb/db/it/query/IoTDBAggregationFirstIT.java | 349 +++++
.../it/query/IoTDBAggregationFirstInGroupIT.java | 172 +++
.../db/it/query/IoTDBAggregationLastByIT.java | 272 ++++
.../it/query/IoTDBAggregationLastByInGroupIT.java | 170 +++
.../iotdb/db/it/query/IoTDBAggregationLastIT.java | 333 +++++
.../db/it/query/IoTDBAggregationLastInGroupIT.java | 166 +++
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 1453 +++++++++++++++-----
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 235 ----
.../auto/basic/IoTDBTreePatternFormatIT.java | 258 +---
.../treemodel/manual/IoTDBPipeInclusionIT.java | 13 +-
.../treemodel/manual/IoTDBPipePermissionIT.java | 42 +
.../iotdb/pipe/it/single/IoTDBPipeOPCUAIT.java | 32 +-
.../it/db/it/IoTDBAuthenticationTableIT.java | 36 +
.../relational/it/db/it/IoTDBInsertTableIT.java | 1 +
.../relational/it/db/it/IoTDBLoadTsFileIT.java | 211 ++-
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 1 +
.../it/query/recent/IoTDBTableAggregationIT.java | 9 +
.../recent/scalar/IoTDBCastLiteralFunctionIT.java | 146 ++
.../it/rest/it/IoTDBRestServiceInsertValuesIT.java | 2 +-
.../it/schema/IoTDBAlterColumnTypeIT.java | 805 ++++++++---
.../relational/it/schema/IoTDBDatabaseIT.java | 15 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 24 +-
.../it/schema/IoTDBTableWithDefinedTimeIT.java | 230 ++++
.../it/cluster/IoTDBSubscriptionRestartIT.java | 7 +-
.../it/dual/AbstractSubscriptionDualIT.java | 3 -
.../dual/tablemodel/IoTDBSubscriptionTopicIT.java | 7 +
.../IoTDBSubscriptionConsumerGroupIT.java | 57 +
.../IoTDBSubscriptionTimePrecisionIT.java | 2 +
.../dual/treemodel/IoTDBSubscriptionTopicIT.java | 14 +
.../it/local/AbstractSubscriptionLocalIT.java | 1 -
.../it/local/IoTDBSubscriptionBasicIT.java | 8 +
.../it/local/IoTDBSubscriptionDataTypeIT.java | 21 +
.../it/local/IoTDBSubscriptionIdempotentIT.java | 4 +
.../it/local/IoTDBSubscriptionTopicIT.java | 5 +
.../tablemodel/IoTDBSubscriptionIsolationIT.java | 3 +
.../tablemodel/IoTDBSubscriptionPermissionIT.java | 5 +
.../it/triple/AbstractSubscriptionTripleIT.java | 5 -
.../treemodel/IoTDBSubscriptionSharingIT.java | 2 +
.../IoTDBDefaultPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultTsfilePushConsumerIT.java | 2 +
.../IoTDBRootDatasetPushConsumerIT.java | 2 +
.../IoTDBRootPullConsumeTsfileIT.java | 2 +
...merPullConsumerWith1TopicShareProcessMixIT.java | 2 +
.../param/IoTDBTestParamPullConsumerIT.java | 26 +
.../param/IoTDBTestParamPushConsumerIT.java | 19 +
.../param/IoTDBTestParamSubscriptionSessionIT.java | 6 +
.../regression/param/IoTDBTestParamTopicIT.java | 20 +
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 2 +
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 2 +
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDBPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 2 +
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 2 +
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBTSPatternPullConsumerDataSetIT.java | 2 +
.../time/IoTDBAllPullConsumerDataSetIT.java | 2 +
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 2 +
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 2 +
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 2 +
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 2 +
.../format/IoTDBTestPushConsumeDataSetIT.java | 2 +
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 2 +
.../format/IoTDBTestPushConsumeTsfileIT.java | 2 +
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 2 +
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 2 +
.../IoTDBLooseAllTsfilePushConsumerIT.java | 2 +
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 2 +
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 2 +
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 2 +
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +
.../IoTDBDBPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBDBPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 2 +
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 2 +
.../IoTDBRootPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBTSPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 2 +
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 2 +
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 2 +
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 2 +
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 2 +
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 2 +
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 2 +
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 2 +
.../regression/topic/IoTDBTestTopicNameIT.java | 2 +
.../regression/user/IoTDBOtherUserConsumerIT.java | 8 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 3 +-
iotdb-client/client-cpp/pom.xml | 3 +
iotdb-client/client-cpp/src/main/CMakeLists.txt | 51 +-
.../client-cpp/src/main/SessionConnection.cpp | 6 +
.../client-cpp/src/main/SessionConnection.h | 6 +-
.../client-cpp/src/main/ThriftConnection.cpp | 6 +
.../client-cpp/src/main/ThriftConnection.h | 4 +
iotdb-client/client-cpp/src/test/CMakeLists.txt | 92 +-
iotdb-client/client-py/iotdb/Session.py | 8 +-
.../client-py/iotdb/utils/SessionDataSet.py | 19 +
.../client-py/iotdb/utils/iotdb_rpc_dataset.py | 68 +
iotdb-client/client-py/session_example.py | 6 +
.../client-py/table_model_session_example.py | 4 +
.../client-py/tests/integration/test_dataframe.py | 50 +
.../client-py/tests/integration/test_todf.py | 2 +-
.../pool_scheduler/basic_pool_scheduler.py | 9 +
.../ainode/core/model/chronos2/chronos_bolt.py | 2 +-
.../ainode/iotdb/ainode/core/model/model_info.py | 13 +
.../ainode/iotdb/ainode/core/model/model_loader.py | 7 +-
.../iotdb/ainode/core/model/moirai2/__init__.py | 16 +-
.../ainode/core/model/moirai2/common}/__init__.py | 0
.../ainode/core/model/moirai2/common/torch_util.py | 130 ++
.../core/model/moirai2/configuration_moirai2.py | 61 +
.../ainode/core/model/moirai2/modeling_moirai2.py | 1352 ++++++++++++++++++
.../ainode/core/model/moirai2/module}/__init__.py | 0
.../ainode/core/model/moirai2/module/attention.py | 366 +++++
.../iotdb/ainode/core/model/moirai2/module/ffn.py | 159 +++
.../iotdb/ainode/core/model/moirai2/module/norm.py | 62 +
.../core/model/moirai2/module/packed_scaler.py | 125 ++
.../model/moirai2/module/position}/__init__.py | 34 +-
.../core/model/moirai2/module/position/additive.py | 81 ++
.../model/moirai2/module/position/attn_bias.py | 113 ++
.../moirai2/module/position/attn_projection.py | 215 +++
.../core/model/moirai2/module/transformer.py | 246 ++++
.../ainode/core/model/moirai2/module/ts_embed.py | 294 ++++
.../ainode/core/model/moirai2/pipeline_moirai2.py | 169 +++
.../core/model/moirai2/transform}/__init__.py | 0
.../ainode/core/model/moirai2/transform/_base.py | 71 +
.../ainode/core/model/moirai2/transform/_mixin.py | 126 ++
.../core/model/moirai2/transform/imputation.py | 133 ++
iotdb-core/ainode/pyproject.toml | 1 +
iotdb-core/confignode/pom.xml | 6 -
.../client/sync/CnToAnSyncRequestType.java | 7 +-
.../client/sync/SyncAINodeClientPool.java | 151 ++
.../consensus/request/ConfigPhysicalPlanType.java | 1 -
.../iotdb/confignode/manager/TTLManager.java | 14 +
.../agent/plugin/PipeConfigNodePluginAgent.java | 4 +-
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 4 +-
.../pipe/source/ConfigRegionListeningFilter.java | 2 +-
.../iotdb/confignode/persistence/TTLInfo.java | 17 +
.../confignode/persistence/schema/ConfigMTree.java | 12 +-
.../procedure/PartitionTableAutoCleaner.java | 18 +-
.../procedure/impl/node/RemoveAINodeProcedure.java | 22 +-
.../impl/region/AddRegionPeerProcedure.java | 2 +-
.../schema/AlterTimeSeriesDataTypeProcedure.java | 48 +-
.../persistence/schema/ConfigMTreeTest.java | 3 +-
iotdb-core/datanode/pom.xml | 58 +-
.../apache/iotdb/db/conf/DataNodeMemoryConfig.java | 1 -
.../dataregion/PipeDataRegionPluginAgent.java | 18 +-
.../schemaregion/PipeSchemaRegionPluginAgent.java | 4 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 23 +-
.../task/builder/PipeDataNodeTaskBuilder.java | 2 +-
.../pipe/agent/task/stage/PipeTaskSinkStage.java | 12 +-
.../subtask/sink/PipeSinkSubtaskLifeCycle.java | 6 +-
.../task/subtask/sink/PipeSinkSubtaskManager.java | 2 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 10 +-
.../sink/protocol/opcda/OpcDaServerHandle.java | 4 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 79 +-
.../sink/protocol/opcua/client/ClientRunner.java | 51 +-
.../protocol/opcua/client/IoTDBOpcUaClient.java | 34 +-
.../source/dataregion/IoTDBDataRegionSource.java | 9 +-
.../db/protocol/session/MqttClientSession.java | 6 +-
.../TableInsertTabletStatementGenerator.java | 10 +-
.../operator/process/TableIntoOperator.java | 7 +-
.../operator/process/ai/InferenceOperator.java | 7 +
.../AlignedUpdateViewPathLastCacheOperator.java | 25 +-
.../process/last/UpdateLastCacheOperator.java | 2 +-
.../last/UpdateViewPathLastCacheOperator.java | 2 +-
.../process/rowpattern/expression/Computation.java | 4 +
.../execution/operator/source/FileLoaderUtils.java | 8 +-
.../execution/operator/source/SeriesScanUtil.java | 8 +-
.../relational/LastQueryAggTableScanOperator.java | 64 +-
.../relational/aggregation/AccumulatorFactory.java | 162 +--
.../relational/aggregation/FirstAccumulator.java | 445 +++---
.../relational/aggregation/FirstByAccumulator.java | 494 +++----
.../aggregation/FirstByDescAccumulator.java | 180 +--
.../aggregation/FirstDescAccumulator.java | 168 +--
.../relational/aggregation/LastAccumulator.java | 373 +++--
.../relational/aggregation/LastByAccumulator.java | 442 +++---
.../aggregation/LastByDescAccumulator.java | 234 ++--
.../aggregation/LastDescAccumulator.java | 198 ++-
.../source/relational/aggregation/Utils.java | 39 +-
.../grouped/GroupedFirstAccumulator.java | 390 +++---
.../grouped/GroupedFirstByAccumulator.java | 473 ++++---
.../grouped/GroupedLastAccumulator.java | 390 +++---
.../grouped/GroupedLastByAccumulator.java | 476 ++++---
.../relational/ColumnTransformerBuilder.java | 32 +-
.../execution/schedule/DriverScheduler.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 6 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 7 +
.../analyze/load/LoadTsFileTableSchemaCache.java | 12 +-
.../execution/config/TableConfigTaskVisitor.java | 82 +-
.../config/executor/ClusterConfigTaskExecutor.java | 25 +-
.../plan/planner/LogicalPlanBuilder.java | 48 +-
.../plan/planner/LogicalPlanVisitor.java | 18 +-
.../plan/planner/OperatorTreeGenerator.java | 27 +-
.../plan/planner/TableOperatorGenerator.java | 85 +-
.../plan/planner/plan/node/PlanGraphPrinter.java | 7 +-
.../plan/node/load/LoadSingleTsFileNode.java | 18 +-
.../planner/plan/node/load/LoadTsFileNode.java | 14 +-
.../plan/node/process/last/LastQueryNode.java | 6 +-
.../plan/node/source/LastQueryScanNode.java | 104 +-
.../relational/analyzer/ExpressionAnalyzer.java | 105 ++
.../relational/analyzer/StatementAnalyzer.java | 28 +-
.../predicate/ConvertPredicateToFilterVisitor.java | 29 +-
.../PredicatePushIntoMetadataChecker.java | 6 +
.../plan/relational/metadata/Metadata.java | 22 +-
.../relational/metadata/TableMetadataImpl.java | 23 +-
.../fetcher/TableHeaderSchemaValidator.java | 96 +-
.../planner/CastToBlobLiteralVisitor.java | 6 +
.../planner/CastToBooleanLiteralVisitor.java | 6 +
.../planner/CastToDateLiteralVisitor.java | 6 +
.../planner/CastToDoubleLiteralVisitor.java | 6 +
.../planner/CastToFloatLiteralVisitor.java | 6 +
.../planner/CastToInt32LiteralVisitor.java | 6 +
.../planner/CastToInt64LiteralVisitor.java | 6 +
.../planner/CastToStringLiteralVisitor.java | 6 +
.../planner/CastToTimestampLiteralVisitor.java | 6 +
.../plan/relational/planner/IrTypeAnalyzer.java | 7 +
.../plan/relational/planner/LiteralEncoder.java | 7 +-
.../relational/planner/LiteralInterpreter.java | 7 +
.../plan/relational/planner/RelationPlanner.java | 6 +-
.../plan/relational/planner/SubqueryPlanner.java | 2 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 3 +-
.../plan/relational/sql/ast/AstVisitor.java | 4 +
.../plan/relational/sql/ast/Expression.java | 3 +
.../ast/{DoubleLiteral.java => FloatLiteral.java} | 54 +-
.../plan/relational/sql/ast/LoadTsFile.java | 11 +-
.../relational/sql/ast/TableExpressionType.java | 3 +-
.../plan/relational/sql/parser/AstBuilder.java | 80 +-
.../relational/sql/util/ExpressionFormatter.java | 15 +-
.../plan/statement/crud/LoadTsFileStatement.java | 9 +
.../udf/BuiltinTimeSeriesGeneratingFunction.java | 2 -
.../impl/SchemaReaderLimitOffsetWrapper.java | 2 +-
.../schemaregion/utils/ResourceByPathUtils.java | 19 +-
.../db/schemaengine/table/DataNodeTableCache.java | 8 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 4 -
.../externalservice/BuiltinExternalServices.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 18 +-
.../memtable/AlignedReadOnlyMemChunk.java | 12 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 8 +-
.../task/stage/SubscriptionTaskSinkStage.java | 16 +-
.../subtask/SubscriptionSinkSubtaskManager.java | 37 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 78 +-
.../iotdb/db/utils/TimestampPrecisionUtils.java | 4 +-
.../db/utils/datastructure/AlignedTVList.java | 6 +-
.../db/utils/datastructure/BackAlignedTVList.java | 3 +-
.../db/utils/datastructure/BackBinaryTVList.java | 3 +-
.../db/utils/datastructure/BackBooleanTVList.java | 3 +-
.../db/utils/datastructure/BackDoubleTVList.java | 3 +-
.../db/utils/datastructure/BackFloatTVList.java | 3 +-
.../db/utils/datastructure/BackIntTVList.java | 3 +-
.../db/utils/datastructure/BackLongTVList.java | 3 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 3 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 3 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 3 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 3 +-
.../db/utils/datastructure/QuickFloatTVList.java | 3 +-
.../db/utils/datastructure/QuickIntTVList.java | 3 +-
.../db/utils/datastructure/QuickLongTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TVList.java | 2 +-
.../db/utils/datastructure/TimAlignedTVList.java | 3 +-
.../db/utils/datastructure/TimBinaryTVList.java | 3 +-
.../db/utils/datastructure/TimBooleanTVList.java | 3 +-
.../db/utils/datastructure/TimDoubleTVList.java | 3 +-
.../db/utils/datastructure/TimFloatTVList.java | 3 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 3 +-
.../db/utils/datastructure/TimLongTVList.java | 3 +-
.../db/auth/role/LocalFileRoleAccessorTest.java | 2 +-
.../db/pipe/pattern/TreePatternPruningTest.java | 59 +-
.../db/pipe/source/IoTDBDataRegionSourceTest.java | 4 -
.../db/protocol/rest/GrafanaApiServiceTest.java | 450 ------
.../db/protocol/rest/IoTDBRestServiceTest.java | 918 -------------
.../process/window/function/FunctionTestUtils.java | 8 +-
.../distribution/AggregationTableScanTest.java | 177 +++
.../plan/planner/distribution/LastQueryTest.java | 3 +
.../logical/DataQueryLogicalPlannerTest.java | 11 +-
.../plan/planner/node/load/LoadTsFileNodeTest.java | 2 +-
.../planner/node/source/SourceNodeSerdeTest.java | 2 +
.../plan/relational/analyzer/AnalyzerTest.java | 6 +-
.../plan/relational/analyzer/TSBSMetadata.java | 6 +-
.../plan/relational/analyzer/TestMetadata.java | 6 +-
.../planner/assertions/ExpressionVerifier.java | 14 +
.../plan/statement/InsertStatementTest.java | 16 +-
.../compaction/CompactionDataTypeAlterTest.java | 55 +
.../dataregion/memtable/PrimitiveMemTableTest.java | 57 +
.../org/apache/iotdb/db/utils/AnnotationTest.java | 59 +
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 18 +-
.../iotdb/metrics/metricsets/jvm/JvmGcMetrics.java | 12 +-
iotdb-core/node-commons/pom.xml | 4 -
.../iotdb/commons/binaryallocator/arena/Arena.java | 7 +-
.../iotdb/commons/client/ClientPoolFactory.java | 22 +
...susServiceClient.java => SyncAINodeClient.java} | 56 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 11 +-
.../iotdb/commons/conf/CommonDescriptor.java | 5 -
.../commons/pipe/agent/plugin/PipePluginAgent.java | 68 +-
.../pipe/config/constant/PipeSinkConstant.java | 5 +
.../pipe/config/constant/PipeSourceConstant.java | 2 +
.../pipe/datastructure/pattern/TreePattern.java | 198 ++-
.../commons/schema/table/InformationSchema.java | 19 -
.../schema/table/TsFileTableSchemaUtil.java | 30 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 6 -
.../schema/table/column/TsTableColumnCategory.java | 4 +
.../apache/iotdb/commons/schema/ttl/TTLCache.java | 29 +
.../apache/iotdb/commons/service/ServiceType.java | 1 -
.../subscription/config/SubscriptionConfig.java | 4 +-
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 368 -----
.../schema/table/TsFileTableSchemaUtilTest.java | 16 +-
iotdb-protocol/pom.xml | 1 -
pom.xml | 16 +-
414 files changed, 14805 insertions(+), 6132 deletions(-)
rename {iotdb-protocol/openapi => external-service-impl/rest-openapi}/pom.xml
(87%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_common.yaml
(100%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_table_v1.yaml
(100%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_v1.yaml (100%)
rename {iotdb-protocol/openapi =>
external-service-impl/rest-openapi}/src/main/openapi3/iotdb_rest_v2.yaml (100%)
copy external-service-impl/{mqtt => rest}/pom.xml (59%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest}/RestService.java
(87%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/ApiOriginFilter.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/AuthorizationFilter.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/BasicSecurityContext.java
(96%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/User.java
(96%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/filter/UserCache.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/handler/AuthorizationHandler.java
(93%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/impl/PingApiServiceImpl.java
(91%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/ExceptionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/ExecuteStatementHandler.java
(99%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/QueryDataSetHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/RequestValidationHandler.java
(95%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/handler/StatementConstructionHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/table/v1/impl/RestApiServiceImpl.java
(92%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/utils/InsertRowDataUtils.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/utils/InsertTabletSortDataUtils.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v2
=>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v1}/handler/ExceptionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/ExecuteStatementHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/QueryDataSetHandler.java
(93%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/RequestValidationHandler.java
(90%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/handler/StatementConstructionHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/impl/GrafanaApiServiceImpl.java
(94%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v1/impl/RestApiServiceImpl.java
(91%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest/v1
=>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol/v2}/handler/ExceptionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/ExecuteStatementHandler.java
(98%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/FastLastHandler.java
(87%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/QueryDataSetHandler.java
(94%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/RequestValidationHandler.java
(93%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/handler/StatementConstructionHandler.java
(97%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/impl/GrafanaApiServiceImpl.java
(94%)
rename {iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/rest =>
external-service-impl/rest/src/main/java/org/apache/iotdb/rest/protocol}/v2/impl/RestApiServiceImpl.java
(94%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/last/{IoTDBLastQueryLastCache2IT.java
=> IoTDBLastQueryAlias2IT.java} (96%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/last/IoTDBLastQueryAliasIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstByInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationFirstInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastByIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastByInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBAggregationLastInGroupIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/scalar/IoTDBCastLiteralFunctionIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/schema/IoTDBTableWithDefinedTimeIT.java
copy docker/src/main/DockerCompose/start-1c1d.sh =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/__init__.py (78%)
mode change 100755 => 100644
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/common}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/common/torch_util.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/configuration_moirai2.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/modeling_moirai2.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/attention.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/ffn.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/norm.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/packed_scaler.py
copy {iotdb-client/client-py/iotdb/dbapi =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position}/__init__.py
(55%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position/additive.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position/attn_bias.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/position/attn_projection.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/transformer.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/module/ts_embed.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/pipeline_moirai2.py
copy {iotdb-client/client-py/iotdb =>
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform}/__init__.py (100%)
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform/_base.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform/_mixin.py
create mode 100644
iotdb-core/ainode/iotdb/ainode/core/model/moirai2/transform/imputation.py
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/MultiClusterIT2SubscriptionTreeRegressionMisc.java
=>
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/CnToAnSyncRequestType.java
(86%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/client/sync/SyncAINodeClientPool.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/sql/ast/{DoubleLiteral.java
=> FloatLiteral.java} (67%)
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/GrafanaApiServiceTest.java
delete mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/rest/IoTDBRestServiceTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/planner/distribution/AggregationTableScanTest.java
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/client/sync/{SyncPipeConsensusServiceClient.java
=> SyncAINodeClient.java} (73%)
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/UDTFJexl.java
