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 618cc39 improve robustness of query metadata
new 167a30e add fill feature
new fe9937a add aggre feature without timegenerator
new aa3aa0d fix a serve bug of filter serializable
new 4abde09 add aggregation query it
new 3020603 Increase the function of query polling
new 3ee37c3 fix some error bugs: add select series group entity, add
query for all nodes features
new 9487dbf add it test of aggregation function
new d079f5e Merge branch 'cluster' into cluster_fill_aggre_groupby
new 6a733d9 fix a serve bug of set readmetadata level
new 20c93d1 fix a serve bug
new 3577857 fix a bug
The 11 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:
.../org/apache/iotdb/cluster/entity/Server.java | 24 +-
.../qp/executor/ClusterQueryProcessExecutor.java | 11 +-
.../cluster/qp/executor/QueryMetadataExecutor.java | 1 -
.../iotdb/cluster/query/common/FillBatchData.java | 47 ++--
.../executor/ClusterAggregateEngineExecutor.java | 251 +++++++++++++++++++++
.../executor/ClusterExecutorWithTimeGenerator.java | 35 +--
.../ClusterExecutorWithoutTimeGenerator.java | 21 +-
.../query/executor/ClusterFillEngineExecutor.java | 75 +++---
.../cluster/query/executor/ClusterQueryRouter.java | 40 +++-
.../query/factory/ClusterSeriesReaderFactory.java | 28 ++-
.../ClusterRpcSingleQueryManager.java | 239 ++++++++------------
...oupEntity.java => FilterSeriesGroupEntity.java} | 4 +-
.../IClusterRpcSingleQueryManager.java | 11 +-
...oupEntity.java => SelectSeriesGroupEntity.java} | 56 ++---
.../querynode/ClusterLocalQueryManager.java | 2 +-
.../querynode/ClusterLocalSingleQueryManager.java | 222 ++++++++++++++----
.../querynode/IClusterLocalQueryManager.java | 4 +-
.../querynode/IClusterLocalSingleQueryManager.java | 5 +-
.../AbstractClusterPointReader.java | 7 +-
.../coordinatornode/ClusterFilterSeriesReader.java | 19 +-
.../coordinatornode/ClusterSelectSeriesReader.java | 25 +-
...=> AbstractClusterSelectSeriesBatchReader.java} | 2 +-
...ava => ClusterFillSelectSeriesBatchReader.java} | 23 +-
...a => ClusterFilterSeriesBatchReaderEntity.java} | 14 +-
...or.java => ClusterSelectSeriesBatchReader.java} | 14 +-
...ClusterSelectSeriesBatchReaderByTimestamp.java} | 7 +-
...a => ClusterSelectSeriesBatchReaderEntity.java} | 43 +++-
... => IClusterFilterSeriesBatchReaderEntity.java} | 2 +-
.../timegenerator/ClusterNodeConstructor.java | 4 +-
.../cluster/query/utils/ClusterRpcReaderUtils.java | 74 +++---
.../ClusterTimeValuePairUtils.java} | 31 +--
.../iotdb/cluster/query/utils/ExpressionUtils.java | 12 +-
.../query/utils/QueryPlanPartitionUtils.java | 192 ++++++++++++----
.../iotdb/cluster/rpc/raft/NodeAsClient.java | 3 +-
.../querydata/InitSeriesReaderSyncProcessor.java | 5 +
.../request/querydata/InitSeriesReaderRequest.java | 72 ++++--
.../QuerySeriesDataByTimestampRequest.java | 17 +-
.../request/querydata/QuerySeriesDataRequest.java | 16 +-
.../cluster/service/TSServiceClusterImpl.java | 14 +-
.../org/apache/iotdb/cluster/utils/RaftUtils.java | 87 ++++---
.../iotdb/cluster}/integration/Constant.java | 2 +-
.../cluster}/integration/IoTDBAggregationIT.java | 157 ++++++++++---
.../integration/IoTDBAggregationLargeDataIT.java | 102 +++++----
.../integration/IoTDBAggregationSmallDataIT.java | 221 ++++++------------
.../cluster/integration/IoTDBFillQueryIT.java | 79 ++++---
.../integration/IoTDBMetadataFetchLocallyIT.java | 1 -
.../IoTDBQueryIT.java} | 5 +-
.../IoTDBQueryLargeDataIT.java} | 6 +-
.../query/manager/ClusterLocalManagerTest.java | 135 +++++------
.../query/manager/ClusterRpcManagerTest.java | 46 +---
.../cluster/query/utils/ExpressionUtilsTest.java | 17 +-
.../query/utils/QueryPlanPartitionUtilsTest.java | 60 +++--
.../apache/iotdb/cluster/utils/RaftUtilsTest.java | 19 +-
.../java/org/apache/iotdb/cluster/utils/Utils.java | 5 +
.../iotdb/db/engine/filenode/FileNodeManager.java | 3 +
.../io/LocalTextModificationAccessor.java | 1 +
.../db/qp/executor/IQueryProcessExecutor.java | 4 +-
.../db/query/control/QueryResourceManager.java | 1 +
.../dataset/EngineDataSetWithoutTimeGenerator.java | 4 +
.../groupby/GroupByWithValueFilterDataSet.java | 8 +-
.../db/query/executor/AggregateEngineExecutor.java | 87 ++++---
.../iotdb/db/query/executor/EngineQueryRouter.java | 4 +-
.../db/query/executor/FillEngineExecutor.java | 11 +-
.../db/query/executor/IFillEngineExecutor.java | 16 +-
.../java/org/apache/iotdb/db/query/fill/IFill.java | 14 +-
.../org/apache/iotdb/db/query/fill/LinearFill.java | 4 +-
.../apache/iotdb/db/query/fill/PreviousFill.java | 6 +-
.../timegenerator/AbstractNodeConstructor.java | 3 -
.../org/apache/iotdb/db/service/TSServiceImpl.java | 5 +
.../java/org/apache/iotdb/db/service/Utils.java | 3 +
70 files changed, 1677 insertions(+), 1111 deletions(-)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/series/EmptyFileSeriesReader.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/common/FillBatchData.java
(50%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/executor/ClusterAggregateEngineExecutor.java
copy
iotdb/src/main/java/org/apache/iotdb/db/query/executor/FillEngineExecutor.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/executor/ClusterFillEngineExecutor.java
(50%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/manager/coordinatornode/{FilterGroupEntity.java
=> FilterSeriesGroupEntity.java} (97%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/manager/coordinatornode/{FilterGroupEntity.java
=> SelectSeriesGroupEntity.java} (54%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/querynode/{AbstractClusterBatchReader.java
=> AbstractClusterSelectSeriesBatchReader.java} (93%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/querynode/{IClusterFilterSeriesBatchReader.java
=> ClusterFillSelectSeriesBatchReader.java} (62%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/querynode/{ClusterFilterSeriesBatchReader.java
=> ClusterFilterSeriesBatchReaderEntity.java} (89%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/querynode/{ClusterBatchReaderWithoutTimeGenerator.java
=> ClusterSelectSeriesBatchReader.java} (84%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/querynode/{ClusterBatchReaderByTimestamp.java
=> ClusterSelectSeriesBatchReaderByTimestamp.java} (90%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/querynode/{AbstractClusterBatchReader.java
=> ClusterSelectSeriesBatchReaderEntity.java} (52%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/querynode/{IClusterFilterSeriesBatchReader.java
=> IClusterFilterSeriesBatchReaderEntity.java} (95%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/query/{reader/querynode/AbstractClusterBatchReader.java
=> utils/ClusterTimeValuePairUtils.java} (57%)
copy {iotdb/src/test/java/org/apache/iotdb/db =>
cluster/src/test/java/org/apache/iotdb/cluster}/integration/Constant.java (98%)
copy {iotdb/src/test/java/org/apache/iotdb/db =>
cluster/src/test/java/org/apache/iotdb/cluster}/integration/IoTDBAggregationIT.java
(81%)
copy {iotdb/src/test/java/org/apache/iotdb/db =>
cluster/src/test/java/org/apache/iotdb/cluster}/integration/IoTDBAggregationLargeDataIT.java
(93%)
copy {iotdb/src/test/java/org/apache/iotdb/db =>
cluster/src/test/java/org/apache/iotdb/cluster}/integration/IoTDBAggregationSmallDataIT.java
(82%)
copy iotdb/src/test/java/org/apache/iotdb/db/integration/IOTDBFillIT.java =>
cluster/src/test/java/org/apache/iotdb/cluster/integration/IoTDBFillQueryIT.java
(88%)
rename
cluster/src/test/java/org/apache/iotdb/cluster/{query/ClusterQueryTest.java =>
integration/IoTDBQueryIT.java} (99%)
rename
cluster/src/test/java/org/apache/iotdb/cluster/{query/ClusterQueryLargeDataTest.java
=> integration/IoTDBQueryLargeDataIT.java} (99%)
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/query/executor/QueryExecutor.java
=>
iotdb/src/main/java/org/apache/iotdb/db/query/executor/IFillEngineExecutor.java
(67%)
