You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/02/20 09:49:55 UTC
[incubator-iotdb] branch cluster_new updated (02d9918 -> 9bce68a)

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

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


    from 02d9918  first implementation of aggregation and tests
     add 9bce68a  temp save

No new revisions were added by this update.

Summary of changes:
 .../cluster/query/filter/SlotTsFileFilter.java     |  31 +++++
 .../cluster/query/manage/ClusterQueryManager.java  |   2 +
 .../query/reader/RemoteAggregateReader.java        |  38 +++++-
 .../reader/RemoteSeriesReaderByTimestamp.java      |   2 +-
 .../query/reader/RemoteSimpleSeriesReader.java     |   6 +-
 .../apache/iotdb/cluster/server/ClientServer.java  |   2 +-
 .../iotdb/cluster/server/DataClusterServer.java    |   8 ++
 .../server/handlers/caller/GenericHandler.java     |   1 +
 .../cluster/server/member/DataGroupMember.java     |  58 ++++++---
 .../cluster/server/member/MetaGroupMember.java     | 114 +++++++++++------
 .../apache/iotdb/cluster/utils/PartitionUtils.java |  11 +-
 .../org/apache/iotdb/cluster/common/IoTDBTest.java |  16 ++-
 .../iotdb/cluster/common/TestDataGroupMember.java  |   2 +
 .../org/apache/iotdb/cluster/common/TestUtils.java |  31 +++++
 .../cluster/log/applier/DataLogApplierTest.java    |   2 +
 .../apache/iotdb/cluster/query/BaseQueryTest.java  | 114 +++++++++++++++--
 .../query/ClusterAggregateExecutorTest.java        |  18 ++-
 .../query/ClusterDataQueryExecutorTest.java        |   5 +-
 .../query/ClusterPhysicalGeneratorTest.java        |   5 +-
 .../cluster/query/ClusterQueryExecutorTest.java    |   4 +-
 .../cluster/query/ClusterQueryParserTest.java      |   4 +-
 .../cluster/query/ClusterQueryRouterTest.java      |   5 +-
 .../query/reader/RemoteAggregateReaderTest.java    |  15 +--
 .../reader/RemoteSeriesReaderByTimestampTest.java  |  22 ++--
 .../query/reader/RemoteSimpleSeriesReaderTest.java |  19 +--
 .../cluster/server/member/MetaGroupMemberTest.java | 136 ++++++++-------------
 cluster/src/test/resources/logback.xml             |   2 +-
 .../apache/iotdb/db/query/filter/TsFileFilter.java |   8 ++
 .../java/org/apache/iotdb/db/utils/QueryUtils.java |  14 +++
 29 files changed, 463 insertions(+), 232 deletions(-)
 create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/filter/SlotTsFileFilter.java
 create mode 100644 server/src/main/java/org/apache/iotdb/db/query/filter/TsFileFilter.java