This is an automated email from the ASF dual-hosted git repository. hui pushed a commit to branch QueryPerformace in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 960fe9e0b0996056949d30657cb6035eefe40812 Merge: b76b253b51 438abe0c78 Author: Minghui Liu <[email protected]> AuthorDate: Wed Jun 22 14:49:23 2022 +0800 Merge remote-tracking branch 'origin/accelerateCount' into QueryPerformace .github/workflows/standalone-it-for-mpp.yml | 2 +- client-py/tests/test_dataframe.py | 2 + client-py/tests/test_one_device.py | 1 + client-py/tests/test_tablet.py | 2 + client-py/tests/test_todf.py | 3 + .../resources/conf/iotdb-confignode.properties | 4 - .../confignode/client/AsyncDataNodeClientPool.java | 18 + .../confignode/client/SyncDataNodeClientPool.java | 21 +- .../confignode/client/handlers/FlushHandler.java | 66 +++ .../iotdb/confignode/conf/ConfigNodeConfig.java | 11 - .../confignode/conf/ConfigNodeDescriptor.java | 5 - .../statemachine/PartitionRegionStateMachine.java | 2 + .../iotdb/confignode/manager/ConfigManager.java | 16 +- .../apache/iotdb/confignode/manager/Manager.java | 3 + .../iotdb/confignode/manager/NodeManager.java | 27 ++ .../iotdb/confignode/manager/UDFManager.java | 18 +- .../iotdb/confignode/manager/load/LoadManager.java | 76 ++-- .../thrift/ConfigNodeRPCServiceProcessor.java | 15 +- .../apache/iotdb/consensus/config/RatisConfig.java | 4 +- .../iotdb/consensus/ratis/RatisConsensus.java | 9 + .../Administration-Management/Administration.md | 288 +++++++++++-- .../Administration-Management/Administration.md | 287 +++++++++++-- integration-test/README.md | 95 +---- integration-test/pom.xml | 466 +++++++-------------- .../java/org/apache/iotdb/it/env/AbstractEnv.java | 31 +- .../apache/iotdb/it/env/AbstractNodeWrapper.java | 18 +- .../iotdb/itbase/runtime/ClusterTestStatement.java | 15 +- .../main/java/org/apache/iotdb/jdbc/Config.java | 3 + .../org/apache/iotdb/jdbc/IoTDBConnection.java | 11 +- .../apache/iotdb/jdbc/IoTDBConnectionParams.java | 13 + .../src/main/java/org/apache/iotdb/jdbc/Utils.java | 4 + .../iotdb/db/localconfignode/LocalConfigNode.java | 2 +- .../iotdb/db/mpp/aggregation/Accumulator.java | 8 +- .../iotdb/db/mpp/aggregation/Aggregator.java | 9 +- .../iotdb/db/mpp/aggregation/AvgAccumulator.java | 34 +- .../iotdb/db/mpp/aggregation/CountAccumulator.java | 24 +- .../db/mpp/aggregation/ExtremeAccumulator.java | 34 +- .../db/mpp/aggregation/FirstValueAccumulator.java | 80 ++-- .../mpp/aggregation/FirstValueDescAccumulator.java | 48 ++- .../db/mpp/aggregation/LastValueAccumulator.java | 68 +-- .../mpp/aggregation/LastValueDescAccumulator.java | 60 ++- .../db/mpp/aggregation/MaxTimeAccumulator.java | 8 +- .../db/mpp/aggregation/MaxTimeDescAccumulator.java | 10 +- .../db/mpp/aggregation/MaxValueAccumulator.java | 34 +- .../db/mpp/aggregation/MinTimeAccumulator.java | 10 +- .../db/mpp/aggregation/MinTimeDescAccumulator.java | 8 +- .../db/mpp/aggregation/MinValueAccumulator.java | 34 +- .../iotdb/db/mpp/aggregation/SumAccumulator.java | 34 +- .../slidingwindow/SlidingWindowAggregator.java | 3 +- .../process/RawDataAggregationOperator.java | 45 +- .../process/SlidingWindowAggregationOperator.java | 14 +- .../AlignedSeriesAggregationScanOperator.java | 37 +- .../source/SeriesAggregationScanOperator.java | 37 +- .../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 32 +- ...piServiceIT.java => GrafanaApiServiceTest.java} | 2 +- ...estServiceIT.java => IoTDBRestServiceTest.java} | 2 +- .../org/apache/iotdb/db/script/EnvScriptIT.java | 1 + .../main/java/org/apache/iotdb/rpc/RpcUtils.java | 12 + .../read/common/block/column/TimeColumn.java | 4 + 59 files changed, 1401 insertions(+), 829 deletions(-)
