You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2024/11/27 06:50:21 UTC
(iotdb) 01/02: Merge branch 'master' of github.com:apache/iotdb into fix_last_flush_time_map_test
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 <hh...@outlook.com>
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(-)