[incubator-iotdb] branch cluster_read updated (4fb3ef4 -> 3bfb4d3)

[lt...@apache.org]

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

lta pushed a change to branch cluster_read
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.


    from 4fb3ef4  complete code of no filter reader
     new 4db2a66  reorganize engine executor with time generator
     new cf779d8  reorganize engine executor with time generator
     new b7bcd0f  complete query with no value filter
     new 3bfb4d3  add construct filter query time generator

The 1767 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:
 .../{utils/query => qp/task}/QueryTask.java        |   2 +-
 .../query/{PathType.java => QueryType.java}        |   4 +-
 .../dataset/ClusterDataSetWithTimeGenerator.java   |  13 +-
 .../executor/ClusterExecutorWithTimeGenerator.java |  55 +++++---
 .../ClusterExecutorWithoutTimeGenerator.java       |  69 ++--------
 .../cluster/query/executor/ClusterQueryRouter.java |  18 +--
 .../query/factory/ClusterSeriesReaderFactory.java  |  81 ++++++++++++
 .../ClusterRpcSingleQueryManager.java              | 141 ++++++++++-----------
 .../IClusterRpcSingleQueryManager.java             |   7 +-
 .../querynode/ClusterLocalSingleQueryManager.java  |  20 +--
 .../cluster/query/reader/ClusterSeriesReader.java  |  20 ++-
 .../query/timegenerator/ClusterLeafNode.java       |  20 +--
 .../timegenerator/ClusterNodeConstructor.java      |  69 ++++++++++
 .../query/timegenerator/ClusterTimeGenerator.java  |  28 ++--
 .../iotdb/cluster/rpc/raft/NodeAsClient.java       |   2 +-
 .../rpc/raft/impl/RaftNodeAsClientManager.java     |   2 +-
 .../request/querydata/QuerySeriesDataRequest.java  |  30 +++--
 .../querydata/QuerySeriesDataResponse.java         |  23 +++-
 .../cluster/utils/query/ClusterRpcReaderUtils.java |   5 +-
 .../utils/query/QueryPlanPartitionUtils.java       |  79 ++++++++++++
 .../db/qp/executor/IQueryProcessExecutor.java      |   8 +-
 .../db/query/control/QueryResourceManager.java     |  17 +++
 .../EngineExecutorWithoutTimeGenerator.java        |  64 +---------
 .../iotdb/db/query/executor/EngineQueryRouter.java |   4 +-
 ...nstructor.java => AbstractNodeConstructor.java} |  57 ++++-----
 .../query/timegenerator/EngineNodeConstructor.java |  62 +--------
 .../query/timegenerator/EngineTimeGenerator.java   |   1 -
 .../org/apache/iotdb/db/service/TSServiceImpl.java |   4 +-
 .../iotdb/db/integration/IoTDBSeriesReaderIT.java  |   2 +-
 .../org/apache/iotdb/db/qp/plan/QPUpdateTest.java  |   2 +-
 30 files changed, 510 insertions(+), 399 deletions(-)
 rename cluster/src/main/java/org/apache/iotdb/cluster/{utils/query => qp/task}/QueryTask.java (96%)
 copy cluster/src/main/java/org/apache/iotdb/cluster/query/{PathType.java => QueryType.java} (93%)
 copy iotdb/src/main/java/org/apache/iotdb/db/query/dataset/EngineDataSetWithTimeGenerator.java => cluster/src/main/java/org/apache/iotdb/cluster/query/dataset/ClusterDataSetWithTimeGenerator.java (90%)
 create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/factory/ClusterSeriesReaderFactory.java
 copy iotdb/src/main/java/org/apache/iotdb/db/query/timegenerator/EngineLeafNode.java => cluster/src/main/java/org/apache/iotdb/cluster/query/timegenerator/ClusterLeafNode.java (75%)
 create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/timegenerator/ClusterNodeConstructor.java
 copy iotdb/src/main/java/org/apache/iotdb/db/query/timegenerator/EngineTimeGenerator.java => cluster/src/main/java/org/apache/iotdb/cluster/query/timegenerator/ClusterTimeGenerator.java (67%)
 create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/query/QueryPlanPartitionUtils.java
 copy iotdb/src/main/java/org/apache/iotdb/db/query/timegenerator/{EngineNodeConstructor.java => AbstractNodeConstructor.java} (70%)