This is an automated email from the ASF dual-hosted git repository.
Caideyipi pushed a change to branch time-partition-boundary-overflow-fix
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 8acf6564dd6 fix
add b19e8314a12 Fix additional time boundary overflow cases
No new revisions were added by this update.
Summary of changes:
.../fill/filter/FixedIntervalFillFilter.java | 10 +-
.../operator/process/fill/linear/LinearFill.java | 5 +-
.../process/gapfill/AbstractGapFillOperator.java | 9 +-
.../scalar/DateBinFunctionColumnTransformer.java | 61 ++++++--
.../query/QueryTimeoutRuntimeException.java | 17 +-
.../processor/TumblingWindowingProcessor.java | 40 ++++-
.../downsampling/DownSamplingTimeUtils.java} | 45 ++----
.../downsampling/changing/ChangingValueFilter.java | 11 +-
.../sdt/SwingingDoorTrendingFilter.java | 14 +-
.../tumbling/TumblingTimeSamplingProcessor.java | 4 +-
.../dataregion/DataRegionWatermarkInjector.java | 18 ++-
.../aggregation/TimeDurationAccumulator.java | 7 +-
.../timerangeiterator/AggrWindowIterator.java | 45 ++++--
.../timerangeiterator/ITimeRangeIterator.java | 58 ++++++-
.../timerangeiterator/PreAggrWindowIterator.java | 46 ++++--
.../PreAggrWindowWithNaturalMonthIterator.java | 12 +-
.../TableDateBinTimeRangeIterator.java | 6 +-
.../operator/process/ai/InferenceOperator.java | 28 +++-
.../execution/operator/window/SessionWindow.java | 25 ++-
.../operator/window/SessionWindowManager.java | 3 +-
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 8 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 20 ++-
.../plan/expression/ExpressionFactory.java | 17 +-
.../plan/optimization/LimitOffsetPushDown.java | 113 +++++++++++---
.../db/queryengine/plan/parser/ASTVisitor.java | 45 ++++--
.../planner/plan/node/write/InsertTabletNode.java | 7 +-
.../ir/GapFillStartAndEndTimeExtractVisitor.java | 6 +
.../plan/relational/sql/parser/AstBuilder.java | 14 +-
.../plan/statement/crud/InsertTabletStatement.java | 3 +-
.../dag/intermediate/IntermediateLayer.java | 11 ++
.../dag/intermediate/MultiInputLayer.java | 7 +-
.../SingleInputMultiReferenceLayer.java | 7 +-
.../SingleInputSingleReferenceLayer.java | 7 +-
.../memtable/AlignedReadOnlyMemChunk.java | 8 +-
.../memtable/MemChunkTimeRangeUtils.java | 56 +++++++
.../dataregion/memtable/ReadOnlyMemChunk.java | 8 +-
.../load/splitter/AlignedChunkData.java | 12 +-
.../splitter/BatchedAlignedValueChunkData.java | 6 +-
.../load/splitter/NonAlignedChunkData.java | 6 +-
.../load/splitter/TsFileSplitter.java | 14 +-
.../iotdb/db/utils/DataNodeDateTimeUtils.java | 54 ++++---
.../SlidingTimeWindowEvaluationHandler.java | 26 ++--
.../processor/TumblingWindowingProcessorTest.java | 100 ++++++++++++
.../DataRegionWatermarkInjectorTest.java} | 28 ++--
.../execution/aggregation/AccumulatorTest.java | 19 +++
.../aggregation/TimeRangeIteratorTest.java | 127 +++++++++++++++
.../process/ai/InferenceOperatorTest.java} | 31 ++--
.../operator/window/SessionWindowTest.java | 53 +++++++
.../ConvertPredicateToTimeFilterTest.java | 5 +
.../db/queryengine/plan/analyze/AnalyzeTest.java | 13 ++
.../queryengine/plan/analyze/AnalyzeUtilsTest.java | 53 +++++++
.../plan/parser/StatementGeneratorTest.java | 60 ++++++++
.../planner/node/write/WritePlanNodeSplitTest.java | 48 ++++++
.../memtable/MemChunkTimeRangeUtilsTest.java | 59 +++++++
.../db/storageengine/load/TsFileSplitterTest.java | 163 +++++++++++++++++++-
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 41 +++++
.../SlidingTimeWindowEvaluationHandlerTest.java | 15 ++
.../commons/partition/SeriesPartitionTable.java | 10 +-
.../function/tvf/ForecastTableFunction.java | 18 +--
.../queryengine/plan/udf/ForecastTimeUtils.java | 74 +++++++++
.../commons/queryengine/plan/udf/UDTFForecast.java | 15 +-
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 117 +++++++-------
.../commons/udf/builtin/UDTFTimeDifference.java | 13 +-
.../relational/tvf/CapacityTableFunction.java | 30 +++-
.../relational/tvf/CumulateTableFunction.java | 22 ++-
.../builtin/relational/tvf/HOPTableFunction.java | 17 +-
.../relational/tvf/SessionTableFunction.java | 10 +-
.../relational/tvf/TumbleTableFunction.java | 11 +-
.../udf/builtin/relational/tvf/WindowTVFUtils.java | 29 ++++
.../iotdb/commons/utils/TimePartitionUtils.java | 29 +++-
.../partition/SeriesPartitionTableTest.java | 22 +++
.../relational/tvf/CapacityTableFunctionTest.java | 58 +++++--
.../relational/tvf/ForecastTimeUtilsTest.java | 61 ++++++++
.../tvf/TimeWindowTableFunctionBoundaryTest.java | 171 +++++++++++++++++++++
.../commons/utils/TimePartitionUtilsTest.java | 54 +++++++
75 files changed, 2107 insertions(+), 388 deletions(-)
copy
iotdb-core/{calc-commons/src/main/java/org/apache/iotdb/calc/execution/operator/process/rowpattern/matcher/Jump.java
=>
datanode/src/main/java/org/apache/iotdb/db/pipe/processor/downsampling/DownSamplingTimeUtils.java}
(54%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemChunkTimeRangeUtils.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/processor/aggregate/window/processor/TumblingWindowingProcessorTest.java
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/{processor/twostage/plugin/TwoStageCountProcessorTest.java
=> source/dataregion/DataRegionWatermarkInjectorTest.java} (55%)
copy
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/{pipe/processor/twostage/plugin/TwoStageCountProcessorTest.java
=> queryengine/execution/operator/process/ai/InferenceOperatorTest.java} (52%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/window/SessionWindowTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemChunkTimeRangeUtilsTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/queryengine/plan/udf/ForecastTimeUtils.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/ForecastTimeUtilsTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/udf/builtin/relational/tvf/TimeWindowTableFunctionBoundaryTest.java
