This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch fix_last_flush_time_map_test
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6f50eff7458 fix more
add 0160b65d67b Pipe: make exception message more friendly when creating
data sync pipe failed (#14208)
add d9552365dc2 Set fetchSize to max_tsblock_line_number if it's equal to
or less than zero
add 8a6405cdfa7 [remove datanode] Do not allow regions to inherit the
Removing state from datanode (#14185)
add 77a21a71e7f Fixed the bugs of the table cache
add b072f9e861c Fix throw exception when compare with null
add d751364acb3 Refactor UDF management process to support table model
user-defined function
add 8618464d861 Fix table model insert without measurement error (#14222)
new 1d915bd4e97 Merge branch 'master' of github.com:apache/iotdb into
fix_last_flush_time_map_test
new 246611d3ae9 recover
The 2 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/unit-test.yml | 1 -
.../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 | 4 +-
.../iotdb/udf/api/relational/SQLFunction.java | 4 +-
.../iotdb/udf/api/relational/ScalarFunction.java | 4 +-
.../iotdb/udf/api/relational/TableFunction.java | 4 +-
.../Row.java => relational/access/Record.java} | 13 +-
.../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 +-
...teFunctionPlan.java => UpdateFunctionPlan.java} | 45 +---
.../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} | 39 ++-
.../thrift-commons/src/main/thrift/common.thrift | 5 +
.../src/main/thrift/confignode.thrift | 8 +-
.../src/main/thrift/datanode.thrift | 1 +
87 files changed, 1087 insertions(+), 756 deletions(-)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/AIClusterIT.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/AggregationFunction.java
(88%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/ClusterIT.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/SQLFunction.java
(91%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/AIClusterIT.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/ScalarFunction.java
(89%)
copy
integration-test/src/main/java/org/apache/iotdb/itbase/category/AIClusterIT.java
=>
iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/relational/TableFunction.java
(89%)
copy iotdb-api/udf-api/src/main/java/org/apache/iotdb/udf/api/{access/Row.java
=> relational/access/Record.java} (95%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/function/{GetFunctionTablePlan.java
=> GetAllFunctionTablePlan.java} (86%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/{DropFunctionPlan.java
=> DropTableModelFunctionPlan.java} (85%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/{DropFunctionPlan.java
=> DropTreeModelFunctionPlan.java} (85%)
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/function/{CreateFunctionPlan.java
=> UpdateFunctionPlan.java} (65%)
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/udf/UDFType.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/security/Identity.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/udf/utils/TreeUDFUtils.java}
(59%)
