This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch fix_insert_long_min_max
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from bed0deb7bf1 Merge branch 'master' into fix_insert_long_min_max
add d87f9342fab Pipe: Fix the problem that the Pipe indicator is
inaccurate and negative (#14627)
add 992f18e0639 Fix that place-holder tag column are not Binary[] (#14621)
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 51c92c3620c Compaction task memory is incorrect when
compaction_max_aligned_series_num_in_one_batch <= 0 (#14603)
add d357756f40e Merge branch 'master' into fix_insert_long_min_max
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 +++++++++++++++++++++
.../it/session/IoTDBSessionRelationalIT.java | 155 +++++++---
.../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 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 20 +-
.../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 ++++-
.../db/storageengine/dataregion/DataRegion.java | 14 +-
...a => CompactionSourceFileDeletedException.java} | 7 +-
.../execute/task/InnerSpaceCompactionTask.java | 6 +-
.../estimator/AbstractCrossSpaceEstimator.java | 7 +-
.../estimator/AbstractInnerSpaceEstimator.java | 8 +-
.../estimator/CompactionEstimateUtils.java | 35 ++-
.../FastCompactionInnerCompactionEstimator.java | 16 +-
.../FastCrossSpaceCompactionEstimator.java | 17 +-
...eQueryMemMeasurement.java => MetadataInfo.java} | 30 +-
.../ReadChunkInnerCompactionEstimator.java | 15 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 5 +-
.../converter/LoadTsFileDataTypeConverter.java | 29 +-
.../load/metrics/LoadTsFileCostMetricsSet.java | 13 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 6 -
.../cross/CrossSpaceCompactionSelectorTest.java | 102 +------
.../utils/CompactionTaskMemCostEstimatorTest.java | 48 +++
.../apache/iotdb/commons/cluster/NodeStatus.java | 13 +
.../TableBuiltinAggregationFunction.java | 2 +
.../src/main/thrift/confignode.thrift | 4 +-
42 files changed, 1003 insertions(+), 496 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%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/execute/exception/{CompactionMemoryNotEnoughException.java
=> CompactionSourceFileDeletedException.java} (81%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/estimator/{IFileQueryMemMeasurement.java
=> MetadataInfo.java} (53%)
