This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 39c8865 fix non-query bug: fail to execute when leader down
new 626f2a3 add group by it and add ClusterNullableBatach data to handle
null timevalue pair
new 2a30289 Merge branch 'cluster' of github.com:apache/incubator-iotdb
into cluster
new 61e8452 remove useless code
The 3 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:
.../apache/iotdb/cluster/config/ClusterConfig.java | 2 +-
.../cluster/qp/executor/NonQueryExecutor.java | 3 -
...atchData.java => ClusterNullableBatchData.java} | 42 ++++++---
.../ClusterGroupByDataSetWithOnlyTimeFilter.java | 12 ++-
.../ClusterGroupByDataSetWithTimeGenerator.java | 101 +++++++++++++++++++++
.../cluster/query/executor/ClusterQueryRouter.java | 2 +-
.../querynode/ClusterLocalQueryManager.java | 7 +-
.../querynode/ClusterLocalSingleQueryManager.java | 10 +-
.../ClusterFillSelectSeriesBatchReader.java | 11 ++-
...lusterGroupBySelectSeriesBatchReaderEntity.java | 10 +-
.../query/utils/ClusterTimeValuePairUtils.java | 34 ++++++-
.../iotdb/cluster/rpc/raft/NodeAsClient.java | 7 +-
.../iotdb/cluster/integration/IOTDBGroupByIT.java | 59 ++++++------
.../integration/IoTDBAggregationSmallDataIT.java | 15 ---
.../groupby/GroupByWithValueFilterDataSet.java | 10 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 4 +-
16 files changed, 228 insertions(+), 101 deletions(-)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/common/{FillBatchData.java
=> ClusterNullableBatchData.java} (54%)
