You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xi...@apache.org on 2022/05/10 11:22:31 UTC
[iotdb] branch aggregationOp updated (afde440773 -> dde1304b50)

This is an automated email from the ASF dual-hosted git repository.

xiangweiwei pushed a change to branch aggregationOp
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from afde440773 add raw data aggregate operator
     add bfbaab3691 add rawDataAggregateOperator test
     add dde1304b50 add time range iterator to MPP

No new revisions were added by this update.

Summary of changes:
 .../iotdb/db/mpp/aggregation/AvgAccumulator.java   |   8 +-
 .../iotdb/db/mpp/aggregation/CountAccumulator.java |   2 +-
 .../db/mpp/aggregation/ExtremeAccumulator.java     |   8 +-
 .../db/mpp/aggregation/FirstValueAccumulator.java  |  12 +-
 .../mpp/aggregation/FirstValueDescAccumulator.java |  12 +-
 .../db/mpp/aggregation/LastValueAccumulator.java   |  12 +-
 .../mpp/aggregation/LastValueDescAccumulator.java  |  12 +-
 .../db/mpp/aggregation/MaxTimeAccumulator.java     |   2 +-
 .../db/mpp/aggregation/MaxTimeDescAccumulator.java |   2 +-
 .../db/mpp/aggregation/MaxValueAccumulator.java    |   8 +-
 .../db/mpp/aggregation/MinTimeAccumulator.java     |   2 +-
 .../db/mpp/aggregation/MinTimeDescAccumulator.java |   2 +-
 .../db/mpp/aggregation/MinValueAccumulator.java    |   8 +-
 .../iotdb/db/mpp/aggregation/SumAccumulator.java   |   8 +-
 .../timerangeiterator/AggrWindowIterator.java      |  15 +-
 .../timerangeiterator/ITimeRangeIterator.java      |  15 +-
 .../timerangeiterator/PreAggrWindowIterator.java   |  13 +-
 .../PreAggrWindowWithNaturalMonthIterator.java     |  37 ++-
 .../SingleTimeWindowIterator.java                  |   2 +-
 .../TimeRangeIteratorFactory.java                  |  12 +-
 .../operator/process/AggregateOperator.java        |   2 +-
 .../operator/process/RawDataAggregateOperator.java |  16 +-
 .../source/SeriesAggregateScanOperator.java        |  25 +-
 .../aggregation}/TimeRangeIteratorTest.java        | 316 +++++++++---------
 .../execution/operator/AggregateOperatorTest.java  |  15 +-
 .../operator/RawDataAggregateOperatorTest.java     | 369 +++++++++++++++------
 .../operator/SeriesAggregateScanOperatorTest.java  |  25 +-
 .../apache/iotdb/tsfile/read/common/TimeRange.java |  20 +-
 28 files changed, 600 insertions(+), 380 deletions(-)
 copy server/src/main/java/org/apache/iotdb/db/{utils => mpp/aggregation}/timerangeiterator/AggrWindowIterator.java (93%)
 copy server/src/main/java/org/apache/iotdb/db/{utils => mpp/aggregation}/timerangeiterator/ITimeRangeIterator.java (69%)
 copy server/src/main/java/org/apache/iotdb/db/{utils => mpp/aggregation}/timerangeiterator/PreAggrWindowIterator.java (92%)
 copy server/src/main/java/org/apache/iotdb/db/{utils => mpp/aggregation}/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java (74%)
 copy server/src/main/java/org/apache/iotdb/db/{utils => mpp/aggregation}/timerangeiterator/SingleTimeWindowIterator.java (96%)
 copy server/src/main/java/org/apache/iotdb/db/{utils => mpp/aggregation}/timerangeiterator/TimeRangeIteratorFactory.java (87%)
 copy server/src/test/java/org/apache/iotdb/db/{utils => mpp/aggregation}/TimeRangeIteratorTest.java (50%)