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 17a3f0d fix partition table is not correctly updated
add c69739d add no filter group by
No new revisions were added by this update.
Summary of changes:
.../iotdb/cluster/query/ClusterQueryRouter.java | 15 +-
.../iotdb/cluster/query/RemoteQueryContext.java | 16 +-
.../groupby/ClusterGroupByNoVFilterDataSet.java | 43 +++++
.../query/groupby/MergeGroupByExecutor.java | 75 +++++++++
.../query/groupby/RemoteGroupByExecutor.java | 73 ++++++++
.../cluster/query/manage/ClusterQueryManager.java | 25 ++-
.../iotdb/cluster/query/reader/EmptyReader.java | 34 +++-
.../cluster/server/member/DataGroupMember.java | 74 +++++++-
.../cluster/server/member/MetaGroupMember.java | 86 ++++++++++
.../db/query/aggregation/AggregateResult.java | 4 +
.../dataset/groupby/GroupByEngineDataSet.java | 13 +-
.../db/query/dataset/groupby/GroupByExecutor.java | 15 ++
.../groupby/GroupByWithoutValueFilterDataSet.java | 183 ++------------------
.../dataset/groupby/LocalGroupByExecutor.java | 187 +++++++++++++++++++++
.../iotdb/db/query/executor/QueryRouter.java | 11 +-
service-rpc/src/main/thrift/cluster.thrift | 23 +++
.../tsfile/read/query/dataset/QueryDataSet.java | 3 +
17 files changed, 688 insertions(+), 192 deletions(-)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/ClusterGroupByNoVFilterDataSet.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/MergeGroupByExecutor.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/groupby/RemoteGroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/GroupByExecutor.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/dataset/groupby/LocalGroupByExecutor.java
