This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch ml/windowSet
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from c8b333f1f8 update interface define
new 38cc84b784 change interface name
new 21df9f4ea8 add WindowConcatNode
new 64b0342513 add WindowConcatOperator
new 9c7d6c7bbd add SampleWindowSliceIterator
new cf1cffa7f9 modify WindowSplitOperator
The 5 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:
.../main/java/org/apache/iotdb/SessionExample.java | 7 +-
.../iotdb/session/it/IoTDBFetchWindowSetIT.java | 2 +-
.../timerangeiterator/SampleWindowIterator.java | 6 +-
.../SampleWindowSliceIterator.java} | 86 ++++++++++++----------
.../TimeRangeIteratorFactory.java | 10 ++-
...fsetOperator.java => WindowConcatOperator.java} | 61 +++++++--------
.../operator/process/WindowSplitOperator.java | 27 +++++--
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 16 ++--
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +-
.../db/mpp/plan/parser/StatementGenerator.java | 8 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 16 ++++
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 13 ++--
.../db/mpp/plan/planner/OperatorTreeGenerator.java | 47 +++++++++++-
.../planner/distribution/DistributionPlanner.java | 4 +-
.../SimpleFragmentParallelPlanner.java | 4 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 9 ++-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 ++
...{WindowSplitNode.java => WindowConcatNode.java} | 22 +++---
.../db/mpp/plan/statement/StatementVisitor.java | 6 +-
...atement.java => FetchWindowBatchStatement.java} | 15 ++--
.../service/thrift/impl/ClientRPCServiceImpl.java | 27 +++----
.../db/service/thrift/impl/TSServiceImpl.java | 6 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 2 +-
.../db/mpp/aggregation/TimeRangeIteratorTest.java | 71 +++++++++++++++++-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 10 +--
.../java/org/apache/iotdb/session/ISession.java | 2 +-
.../java/org/apache/iotdb/session/Session.java | 4 +-
.../apache/iotdb/session/SessionConnection.java | 24 +++---
thrift/src/main/thrift/client.thrift | 8 +-
29 files changed, 340 insertions(+), 180 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/{utils/timerangeiterator/PreAggrWindowWithNaturalMonthIterator.java
=> mpp/aggregation/timerangeiterator/SampleWindowSliceIterator.java} (64%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/{OffsetOperator.java
=> WindowConcatOperator.java} (57%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/process/{WindowSplitNode.java
=> WindowConcatNode.java} (86%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/crud/{FetchWindowSetStatement.java
=> FetchWindowBatchStatement.java} (85%)
