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%)
