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 2023/02/17 09:25:23 UTC

[iotdb] branch DONTBlock updated (3dae858983 -> fff5756e71)

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

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


    from 3dae858983 implement AggregationOperator
     add fff5756e71 implement consumeAllOperator

No new revisions were added by this update.

Summary of changes:
 .../process/AbstractConsumeAllOperator.java        | 128 +++++++++++++++++++++
 .../operator/process/AbstractProcessOperator.java  |  24 ----
 .../operator/process/AggregationOperator.java      |  80 +------------
 .../operator/process/DeviceMergeOperator.java      |   1 +
 .../operator/process/MergeSortOperator.java        | 104 ++++++++++-------
 .../operator/process/TagAggregationOperator.java   |  72 ++----------
 .../process/join/HorizontallyConcatOperator.java   |  67 +++--------
 .../process/join/RowBasedTimeJoinOperator.java     | 120 ++++++++++---------
 .../operator/process/join/TimeJoinOperator.java    |   4 +-
 9 files changed, 281 insertions(+), 319 deletions(-)
 create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractConsumeAllOperator.java
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/AbstractProcessOperator.java