This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch calc_commons
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 3626a42372a update pom.xml
add 022e11332e6 Enable show queries to be executed immediately when the
available memory in the memoryPool is insufficient (#17507)
add f5d26af79b2 Update 3 UDFs: Percentile, Quantile and Cluster (#17375)
add d142b7517d3 CI: Add GitHub Actions workflow to package C++ client
binaries (#17528)
add 4e06946fac0 Pipe: Rewrote the OPC UA subscription logic to avoid the
bug of third-party subscription model (#17525)
add 97af27f1bea Merge branch 'iotdb_master' into calc_commons
No new revisions were added by this update.
Summary of changes:
.github/workflows/client-cpp-package.yml | 226 +++++++++++++++++++++
.../apache/iotdb/libudf/it/dlearn/DLearnIT.java | 82 ++++++++
.../treemodel/auto/basic/IoTDBPipeAutoSplitIT.java | 4 +-
.../db/pipe/sink/protocol/opcua/OpcUaSink.java | 13 +-
.../sink/protocol/opcua/server/OpcUaNameSpace.java | 156 ++++++++++++--
.../protocol/opcua/server/OpcUaServerBuilder.java | 14 +-
.../db/queryengine/common/MPPQueryContext.java | 14 ++
.../execution/exchange/MPPDataExchangeManager.java | 56 ++++-
.../execution/exchange/SharedTsBlockQueue.java | 57 ++++--
.../execution/exchange/sink/SinkChannel.java | 62 ++++--
.../execution/exchange/source/SourceHandle.java | 90 ++++++--
.../fragment/FragmentInstanceContext.java | 13 ++
.../fragment/FragmentInstanceManager.java | 2 +
.../queryengine/execution/memory/MemoryPool.java | 56 +++--
.../db/queryengine/plan/analyze/Analysis.java | 2 +-
.../queryengine/plan/execution/QueryExecution.java | 7 +-
.../planner/DataNodeTableOperatorGenerator.java | 6 +-
.../plan/planner/OperatorTreeGenerator.java | 6 +-
.../plan/planner/plan/FragmentInstance.java | 2 +
.../execution/exchange/LocalSinkChannelTest.java | 10 +-
.../execution/exchange/SharedTsBlockQueueTest.java | 11 +-
.../execution/exchange/ShuffleSinkHandleTest.java | 5 +-
.../execution/exchange/SourceHandleTest.java | 5 +-
.../db/queryengine/execution/exchange/Utils.java | 26 ++-
.../execution/memory/MemoryPoolTest.java | 115 +++++++++--
.../pipe/config/constant/PipeSinkConstant.java | 5 +
library-udf/src/assembly/tools/register-UDF.bat | 111 +++++-----
library-udf/src/assembly/tools/register-UDF.sh | 1 +
.../apache/iotdb/library/dlearn/UDTFCluster.java | 216 ++++++++++++++++++++
.../library/dlearn/util/cluster/ClusterUtils.java | 156 ++++++++++++++
.../iotdb/library/dlearn/util/cluster/KMeans.java | 130 ++++++++++++
.../iotdb/library/dlearn/util/cluster/KShape.java | 190 +++++++++++++++++
.../library/dlearn/util/cluster/MedoidShape.java | 213 +++++++++++++++++++
.../iotdb/library/dprofile/UDAFQuantile.java | 78 ++++---
.../dprofile/util/ExactOrderStatistics.java | 53 ++---
.../iotdb/library/dprofile/util/GKArray.java | 15 +-
36 files changed, 1944 insertions(+), 264 deletions(-)
create mode 100644 .github/workflows/client-cpp-package.yml
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dlearn/UDTFCluster.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dlearn/util/cluster/ClusterUtils.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dlearn/util/cluster/KMeans.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dlearn/util/cluster/KShape.java
create mode 100644
library-udf/src/main/java/org/apache/iotdb/library/dlearn/util/cluster/MedoidShape.java
