This is an automated email from the ASF dual-hosted git repository.
spricoder pushed a change to branch feature/optimize_memory
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 64428133aa0 Merge branch 'master' into feature/optimize_memory
add c2673ffd031 Reduce some deletion-related log levels (#14631)
add 7bbf27df0ac Make show-queries can execute on more status node
add eb5d1df9a4e Load: Convert TsFiles into Tablets when the target regions
are unavailable (#14626)
add 2af3d029a7a Add aggregate function count_if for relational table
add 95451e45583 Pipe IT: Add table model testPipeAfterDataRegionLeaderStop
retry logic and extend IoTDBPipeTypeConversionIT retry time (#14628)
add 9bcfe0552fa Merge branch 'master' into feature/optimize_memory
add 9bf1bc84f9f change metric name
No new revisions were added by this update.
Summary of changes:
.../pipe/it/manual/IoTDBPipeTypeConversionIT.java | 2 +-
.../pipe/it/tablemodel/IoTDBPipeClusterIT.java | 290 +++++++++---------
.../it/query/recent/IoTDBTableAggregationIT.java | 331 +++++++++++++++++++++
.../iotdb/confignode/manager/ConfigManager.java | 4 +-
.../apache/iotdb/confignode/manager/IManager.java | 2 +-
.../iotdb/confignode/manager/load/LoadManager.java | 11 +
.../confignode/manager/load/cache/LoadCache.java | 17 ++
.../iotdb/confignode/manager/node/NodeManager.java | 13 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 4 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 4 +-
.../relational/aggregation/AccumulatorFactory.java | 5 +
...untAccumulator.java => CountIfAccumulator.java} | 59 ++--
...mulator.java => GroupedCountIfAccumulator.java} | 9 +-
.../db/queryengine/plan/analyze/Analysis.java | 10 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 31 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 19 +-
.../plan/planner/LogicalPlanBuilder.java | 2 +-
.../relational/metadata/TableMetadataImpl.java | 9 +
.../DataNodeLocationSupplierFactory.java | 40 +--
.../plan/relational/sql/ast/LoadTsFile.java | 5 +-
.../plan/scheduler/load/LoadTsFileScheduler.java | 80 ++++-
.../metrics/memory/ConsensusMemoryMetrics.java | 4 +-
.../metrics/memory/GlobalMemoryMetrics.java | 10 +-
.../metrics/memory/QueryEngineMemoryMetrics.java | 20 +-
.../metrics/memory/SchemaEngineMemoryMetrics.java | 12 +-
.../metrics/memory/StorageEngineMemoryMetrics.java | 22 +-
.../metrics/memory/StreamEngineMemoryMetrics.java | 4 +-
.../db/storageengine/dataregion/DataRegion.java | 14 +-
.../converter/LoadTsFileDataTypeConverter.java | 29 +-
.../load/metrics/LoadTsFileCostMetricsSet.java | 13 +-
.../apache/iotdb/commons/cluster/NodeStatus.java | 13 +
.../iotdb/commons/service/metric/enums/Metric.java | 2 +-
.../TableBuiltinAggregationFunction.java | 2 +
.../src/main/thrift/confignode.thrift | 4 +-
34 files changed, 784 insertions(+), 312 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{CountAccumulator.java
=> CountIfAccumulator.java} (68%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/{GroupedCountAccumulator.java
=> GroupedCountIfAccumulator.java} (89%)
