This is an automated email from the ASF dual-hosted git repository.
xingtanzjr pushed a change to branch xingtanzjr/operator-design
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 0b279d1 move query distribution folder to cluster
new 1d7b20e rename operator to node
add 60cd7f7 design of source, sink and internal operators
add bdbd38e design of source, sink and internal operators
new ed432ec Merge branch 'suyurong/operator-design' into
xingtanzjr/operator-design
new d8f2e1f align class name
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../cluster/query/distribution/common/Tablet.java | 29 -----------
.../cluster/query/distribution/common/TsBlock.java | 30 ++++++++++++
.../{TabletMetadata.java => TsBlockMetadata.java} | 2 +-
.../query/distribution/operator/ExecOperator.java | 18 -------
.../query/distribution/operator/FillOperator.java | 25 ----------
.../query/distribution/operator/LimitOperator.java | 24 ---------
.../distribution/operator/OffsetOperator.java | 24 ---------
.../distribution/operator/SeriesScanOperator.java | 57 ----------------------
.../query/distribution/operator/SortOperator.java | 23 ---------
.../cluster/query/distribution/plan/PlanNode.java | 12 +++++
.../process/DeviceMergeNode.java} | 22 ++-------
.../query/distribution/plan/process/FillNode.java | 16 ++++++
.../process/FilterNode.java} | 17 ++-----
.../process/GroupByLevelNode.java} | 17 ++-----
.../query/distribution/plan/process/LimitNode.java | 15 ++++++
.../distribution/plan/process/OffsetNode.java | 15 ++++++
.../distribution/plan/process/ProcessNode.java | 6 +++
.../process/SeriesAggregateNode.java} | 21 ++++----
.../query/distribution/plan/process/SortNode.java | 15 ++++++
.../process/TimeJoinNode.java} | 17 ++-----
.../process/WithoutNode.java} | 17 ++-----
.../query/distribution/plan/sink/CsvSinkNode.java | 9 ++--
.../distribution/plan/sink/SinkNode.java} | 13 +++--
.../distribution/plan/sink/ThriftSinkNode.java | 10 ++--
.../distribution/plan/source/CsvSourceNode.java | 19 +++-----
.../distribution/plan/source/SeriesScanNode.java | 45 +++++++++++++++++
.../query/distribution/plan/source/SourceNode.java | 11 ++---
27 files changed, 217 insertions(+), 312 deletions(-)
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/common/Tablet.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/common/TsBlock.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/common/{TabletMetadata.java
=> TsBlockMetadata.java} (96%)
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/operator/ExecOperator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/operator/FillOperator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/operator/LimitOperator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/operator/OffsetOperator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/operator/SeriesScanOperator.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/operator/SortOperator.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/PlanNode.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/{operator/DeviceMergeOperator.java
=> plan/process/DeviceMergeNode.java} (57%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/process/FillNode.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/{operator/FilterExecOperator.java
=> plan/process/FilterNode.java} (52%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/{operator/GroupByLevelOperator.java
=> plan/process/GroupByLevelNode.java} (73%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/process/LimitNode.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/process/OffsetNode.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/process/ProcessNode.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/{operator/SeriesAggregateOperator.java
=> plan/process/SeriesAggregateNode.java} (55%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/process/SortNode.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/{operator/TimeJoinOperator.java
=> plan/process/TimeJoinNode.java} (71%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/{operator/WithoutOperator.java
=> plan/process/WithoutNode.java} (50%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFAsin.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/sink/CsvSinkNode.java
(77%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{server/service/package-info.java
=> query/distribution/plan/sink/SinkNode.java} (78%)
copy server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFAcos.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/sink/ThriftSinkNode.java
(77%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/filter/factory/FilterType.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/source/CsvSourceNode.java
(73%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/source/SeriesScanNode.java
copy
server/src/main/java/org/apache/iotdb/db/service/metrics/MetricsServiceMBean.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/distribution/plan/source/SourceNode.java
(75%)
