This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch table_model_auto_cast
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 5dc50a68379 fix tests
add f2a5854f182 WAL buffer queue memory control (#14329)
add 6073d25712c Restruct procedure waiting strategy to fix NPE bug when
completed procedures were cleaned before getting result (#14360)
add 21652cc2180 Fixed the bug of ID Like judgement in queries
add 589866872db Fix group by nature month when timezone is not default
add 70691e4b2be Add `removeInput` and `removable` to some specific
Accmulators
add ba824548e0b fix wal queue stuck and fix metric (#14387)
add 37450ec160b Supprt trusted_uri_pattern in config file
add e1884cad2f8 Support us and ns timePrecision in udf-library part-1
add 24cb32f621b Merge branch 'master' into table_model_auto_cast
No new revisions were added by this update.
Summary of changes:
.../iotdb/it/env/cluster/env/AbstractEnv.java | 15 +
.../iotdb/it/env/remote/env/RemoteServerEnv.java | 9 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 3 +
.../org/apache/iotdb/ainode/it/AINodeBasicIT.java | 1 +
.../db/it/groupby/IoTDBGroupByNaturalMonthIT.java | 28 +
.../iotdb/db/it/udf/IoTDBUDFBlockQueryIT.java | 12 +
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 2 +-
.../it/db/it/udf/IoTDBSQLFunctionManagementIT.java | 16 +-
.../it/db/it/udf/scalar/IoTDBScalarFunctionIT.java | 21 +-
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 36 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../iotdb/confignode/manager/ProcedureManager.java | 639 +++++++++------------
.../confignode/procedure/ProcedureExecutor.java | 24 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 23 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 49 +-
.../deletion/persist/PageCacheDeletionBuffer.java | 2 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../timerangeiterator/AggrWindowIterator.java | 26 +-
.../PreAggrWindowWithNaturalMonthIterator.java | 8 +-
.../TimeRangeIteratorFactory.java | 9 +-
.../execution/operator/AggregationUtil.java | 7 +-
.../process/SlidingWindowAggregationOperator.java | 7 +-
.../relational/aggregation/AvgAccumulator.java | 73 +++
.../relational/aggregation/CountAccumulator.java | 20 +
.../relational/aggregation/SumAccumulator.java | 69 +++
.../relational/aggregation/TableAccumulator.java | 8 +
.../aggregation/TableModeAccumulator.java | 102 ++++
.../aggregation/TableVarianceAccumulator.java | 86 +++
.../queryengine/plan/analyze/AnalyzeVisitor.java | 4 +-
.../plan/analyze/TemplatedAggregationAnalyze.java | 4 +-
.../execution/config/TableConfigTaskVisitor.java | 20 +-
.../execution/config/TreeConfigTaskVisitor.java | 42 +-
.../config/executor/ClusterConfigTaskExecutor.java | 18 +-
.../plan/optimization/LimitOffsetPushDown.java | 20 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 4 +-
.../plan/planner/OperatorTreeGenerator.java | 31 +-
.../plan/planner/plan/node/write/InsertNode.java | 10 +
.../iotdb/db/service/metrics/WritingMetrics.java | 32 ++
.../storageengine/buffer/CacheHitRatioMonitor.java | 4 +-
.../dataregion/memtable/AbstractMemTable.java | 1 -
.../dataregion/wal/buffer/WALBuffer.java | 6 +-
.../dataregion/wal/buffer/WALEntry.java | 2 +
.../dataregion/wal/buffer/WALInfoEntry.java | 34 ++
.../dataregion/wal/buffer/WALSignalEntry.java | 5 +
.../storageengine/dataregion/wal/node/WALNode.java | 4 +-
.../wal/utils/MemoryControlledWALEntryQueue.java | 81 +++
.../db/storageengine/rescon/memory/SystemInfo.java | 31 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 9 +-
.../schemaRegion/SchemaRegionTableDeviceTest.java | 13 +-
.../aggregation/TimeRangeIteratorTest.java | 53 +-
.../operator/AggregationOperatorTest.java | 7 +-
.../AlignedSeriesAggregationScanOperatorTest.java | 3 +-
.../operator/HorizontallyConcatOperatorTest.java | 5 +-
.../execution/operator/LastQueryOperatorTest.java | 9 +-
.../operator/LastQueryTreeSortOperatorTest.java | 9 +-
.../execution/operator/OperatorMemoryTest.java | 16 +-
.../operator/RawDataAggregationOperatorTest.java | 3 +-
.../SeriesAggregationScanOperatorTest.java | 3 +-
.../SlidingWindowAggregationOperatorTest.java | 8 +-
.../operator/UpdateLastCacheOperatorTest.java | 3 +-
.../plan/optimization/LimitOffsetPushDownTest.java | 11 +-
.../buffer/CacheHitRatioMonitorTest.java | 4 +-
.../conf/iotdb-system.properties.template | 29 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 11 +
.../commons/executable/ExecutableManager.java | 5 +
.../filter/impl/StringValueFilterVisitor.java | 5 +-
.../schema/filter/impl/values/LikeFilter.java | 2 +-
.../iotdb/commons/service/metric/enums/Metric.java | 1 +
.../iotdb/library/dprofile/UDTFResample.java | 6 +-
.../iotdb/library/dquality/UDTFCompleteness.java | 3 +-
.../iotdb/library/dquality/UDTFConsistency.java | 2 +-
.../iotdb/library/dquality/UDTFTimeliness.java | 3 +-
.../iotdb/library/dquality/UDTFValidity.java | 3 +-
.../apache/iotdb/library/frequency/UDTFIFFT.java | 7 +-
.../library/series/UDTFConsecutiveSequences.java | 5 +-
.../library/series/UDTFConsecutiveWindows.java | 11 +-
.../java/org/apache/iotdb/library/util/Util.java | 90 ++-
77 files changed, 1385 insertions(+), 608 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/utils/MemoryControlledWALEntryQueue.java
