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/03/06 09:00:34 UTC
[incubator-iotdb] branch cluster_new updated (2fd2670 -> 1d600ef)
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 2fd2670 Merge branch 'master' into cluster_new
add 1d600ef add group by test
No new revisions were added by this update.
Summary of changes:
.../manage/FilePartitionedSnapshotLogManager.java | 2 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 5 +-
...aSet.java => ClusterGroupByVFilterDataSet.java} | 28 +++--
.../query/groupby/MergeGroupByExecutor.java | 1 +
.../iotdb/cluster/server/DataClusterServer.java | 14 +++
.../cluster/server/member/DataGroupMember.java | 2 +
.../cluster/server/member/MetaGroupMember.java | 11 +-
.../iotdb/cluster/common/TestDataClient.java | 14 +++
.../org/apache/iotdb/cluster/common/TestUtils.java | 2 +-
.../FilePartitionedSnapshotLogManagerTest.java | 5 +-
.../apache/iotdb/cluster/query/BaseQueryTest.java | 22 +++-
.../cluster/query/ClusterFillExecutorTest.java | 4 +
.../cluster/query/ClusterQueryRouterTest.java | 98 ++++++++++++++++++
.../ClusterGroupByNoVFilterDataSetTest.java | 61 +++++++++++
.../groupby/ClusterGroupByVFilterDataSetTest.java | 72 +++++++++++++
.../query/groupby/MergeGroupByExecutorTest.java | 80 +++++++++++++++
.../query/groupby/RemoteGroupByExecutorTest.java | 114 +++++++++++++++++++++
.../cluster/server/member/DataGroupMemberTest.java | 102 ++++++++++++++++++
.../db/query/aggregation/AggregateResult.java | 96 +++++++++--------
.../db/query/aggregation/impl/AvgAggrResult.java | 9 ++
.../aggregation/impl/FirstValueAggrResult.java | 6 ++
.../aggregation/impl/LastValueAggrResult.java | 6 ++
.../groupby/GroupByWithValueFilterDataSet.java | 26 ++++-
.../db/query/executor/AggregationExecutor.java | 4 +-
24 files changed, 712 insertions(+), 72 deletions(-)
copy cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/{ClusterGroupByNoVFilterDataSet.java => ClusterGroupByVFilterDataSet.java} (53%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSetTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByVFilterDataSetTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutorTest.java
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutorTest.java