This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch fix_last_flush_time_map_test in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1d915bd4e972142176a233fdd6fc589e21b27a5e Merge: 6f50eff7458 8618464d861 Author: HTHou <[email protected]> AuthorDate: Wed Nov 27 14:48:25 2024 +0800 Merge branch 'master' of github.com:apache/iotdb into fix_last_flush_time_map_test .../confignode/it/IoTDBConfigNodeSnapshotIT.java | 14 +- .../it/partition/IoTDBPartitionCreationIT.java | 59 +++-- .../it/partition/IoTDBPartitionDurableIT.java | 130 ---------- .../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 8 +- .../it/IoTDBSyntaxConventionStringLiteralIT.java | 2 +- .../iotdb/db/it/udaf/IoTDBUDAFManagementIT.java | 12 +- .../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 17 +- .../it/query/old/IoTDBFilterTableIT.java | 24 ++ .../iotdb/session/it/IoTDBSessionRelationalIT.java | 32 +++ .../udf/api/relational/AggregationFunction.java | 12 +- .../iotdb/udf/api/relational/SQLFunction.java | 12 +- .../iotdb/udf/api/relational/ScalarFunction.java | 12 +- .../iotdb/udf/api/relational/TableFunction.java | 12 +- .../iotdb/udf/api/relational/access/Record.java | 129 ++++++++++ .../java/org/apache/iotdb/rpc/TSStatusCode.java | 2 + .../heartbeat/DataNodeHeartbeatHandler.java | 14 +- .../consensus/request/ConfigPhysicalPlan.java | 10 +- .../consensus/request/ConfigPhysicalPlanType.java | 5 +- ...TablePlan.java => GetAllFunctionTablePlan.java} | 6 +- .../read/function/GetFunctionTablePlan.java | 10 +- ...onPlan.java => DropTableModelFunctionPlan.java} | 12 +- ...ionPlan.java => DropTreeModelFunctionPlan.java} | 12 +- ...opFunctionPlan.java => UpdateFunctionPlan.java} | 44 ++-- .../response/function/FunctionTableResp.java | 14 +- .../iotdb/confignode/manager/ConfigManager.java | 10 +- .../apache/iotdb/confignode/manager/IManager.java | 6 +- .../iotdb/confignode/manager/UDFManager.java | 95 +++++-- .../manager/load/cache/AbstractLoadCache.java | 2 +- .../confignode/manager/load/cache/LoadCache.java | 8 + .../load/cache/region/RegionGroupCache.java | 4 + .../iotdb/confignode/manager/node/NodeManager.java | 2 +- .../iotdb/confignode/persistence/UDFInfo.java | 43 +++- .../persistence/executor/ConfigPlanExecutor.java | 20 +- .../procedure/env/RemoveDataNodeHandler.java | 27 +- .../thrift/ConfigNodeRPCServiceProcessor.java | 7 +- .../request/ConfigPhysicalPlanSerDeTest.java | 22 +- .../response/ConvertToThriftRespTest.java | 19 +- .../iotdb/confignode/persistence/UDFInfoTest.java | 6 +- .../iotdb/db/protocol/client/ConfigNodeClient.java | 5 +- .../protocol/thrift/impl/ClientRPCServiceImpl.java | 1 + .../impl/DataNodeInternalRPCServiceImpl.java | 3 +- .../common/header/ColumnHeaderConstant.java | 4 +- .../execution/aggregation/UDAFAccumulator.java | 2 +- .../plan/execution/config/ConfigExecution.java | 2 +- .../execution/config/TreeConfigTaskVisitor.java | 5 +- .../config/executor/ClusterConfigTaskExecutor.java | 76 +++--- .../config/executor/IConfigTaskExecutor.java | 14 +- .../config/metadata/CreateFunctionTask.java | 28 +- .../config/metadata/DropFunctionTask.java | 10 +- .../config/metadata/ShowFunctionsTask.java | 102 ++++++-- .../plan/expression/multi/FunctionExpression.java | 4 +- .../db/queryengine/plan/parser/ASTVisitor.java | 9 +- .../function/arithmetic/AdditionResolver.java | 14 + .../function/arithmetic/DivisionResolver.java | 10 + .../function/arithmetic/ModulusResolver.java | 10 + .../arithmetic/MultiplicationResolver.java | 10 + .../function/arithmetic/SubtractionResolver.java | 10 + .../relational/metadata/TableMetadataImpl.java | 17 +- .../metadata/CreateFunctionStatement.java | 24 +- .../dag/column/leaf/NullColumnTransformer.java | 4 +- .../AbstractCastFunctionColumnTransformer.java | 4 +- .../dag/udf/UDAFInformationInferrer.java | 2 +- .../transformation/dag/udf/UDTFExecutor.java | 2 +- .../dag/udf/UDTFInformationInferrer.java | 2 +- .../db/schemaengine/table/DataNodeTableCache.java | 3 +- .../java/org/apache/iotdb/db/service/DataNode.java | 16 +- .../dataregion/flush/MemTableFlushTask.java | 2 +- .../dataregion/memtable/AbstractMemTable.java | 7 +- .../memtable/AlignedWritableMemChunk.java | 18 +- .../memtable/AlignedWritableMemChunkGroup.java | 10 +- .../dataregion/memtable/IWritableMemChunk.java | 5 +- .../dataregion/memtable/WritableMemChunk.java | 2 +- .../apache/iotdb/db/utils/QueryDataSetUtils.java | 6 + .../apache/iotdb/commons/conf/IoTDBConstant.java | 2 + .../connector/client/IoTDBSyncClientManager.java | 25 +- .../schema/table/TsTableInternalRPCUtil.java | 6 +- .../apache/iotdb/commons/udf/UDFInformation.java | 64 +++-- .../org/apache/iotdb/commons/udf/UDFTable.java | 105 ++++---- .../java/org/apache/iotdb/commons/udf/UDFType.java | 71 +++++ .../BuiltinTimeSeriesGeneratingFunction.java | 13 + .../commons/udf/service/UDFExecutableManager.java | 46 ++++ .../commons/udf/service/UDFManagementService.java | 286 ++++++++------------- .../iotdb/commons/udf/utils/TreeUDFUtils.java} | 33 ++- .../thrift-commons/src/main/thrift/common.thrift | 5 + .../src/main/thrift/confignode.thrift | 8 +- .../src/main/thrift/datanode.thrift | 1 + 86 files changed, 1226 insertions(+), 757 deletions(-)
