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
