You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/06/13 01:49:48 UTC
[iotdb] 01/02: Merge branch 'master' of https://github.com/apache/iotdb into try_wal_ci
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch try_wal_ci
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c828009572eb42e1a4085f0d0ace2a1dce2aeaaa
Merge: 64dfddc263 7b07fd9cba
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon Jun 13 09:45:34 2022 +0800
Merge branch 'master' of https://github.com/apache/iotdb into try_wal_ci
checkstyle.xml | 2 +-
client-py/SessionExample.py | 11 ++
client-py/iotdb/Session.py | 35 ++++++-
client-py/iotdb/tsfile/__init__.py | 17 ++++
client-py/iotdb/tsfile/common/__init__.py | 17 ++++
.../iotdb/consensus/ratis/RatisConsensus.java | 2 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 59 +++++++++--
.../java/org/apache/iotdb/it/env/ConfigNode.java | 4 +-
.../threadpool/ScheduledExecutorUtil.java | 104 +++++++++++++++++--
.../iotdb/commons/partition/DataPartition.java | 7 +-
.../statemachine/visitor/DataExecutionVisitor.java | 10 --
.../org/apache/iotdb/db/engine/StorageEngine.java | 16 +--
.../apache/iotdb/db/engine/StorageEngineV2.java | 25 ++---
.../engine/compaction/CompactionTaskManager.java | 32 +++---
.../db/engine/storagegroup/TsFileResource.java | 6 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 4 +-
.../localconfignode/LocalDataPartitionTable.java | 28 +++--
.../apache/iotdb/db/metadata/path/AlignedPath.java | 4 +
.../metadata/visitor/SchemaExecutionVisitor.java | 14 ---
.../execution/datatransfer/DataBlockService.java | 21 ++--
.../execution/datatransfer/SharedTsBlockQueue.java | 4 +-
.../mpp/execution/datatransfer/SourceHandle.java | 2 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 16 ---
.../mpp/plan/analyze/GroupByLevelController.java | 57 ++++++++++-
.../db/mpp/plan/execution/QueryExecution.java | 3 +-
.../plan/execution/memory/MemorySourceHandle.java | 4 +-
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 18 ++--
.../planner/distribution/DistributionPlanner.java | 2 +-
.../planner/distribution/ExchangeNodeAdder.java | 19 +++-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 7 --
.../db/mpp/plan/planner/plan/PlanFragment.java | 3 +-
.../plan/planner/plan/node/DeleteRegionNode.java | 113 ---------------------
.../plan/planner/plan/node/PlanGraphPrinter.java | 20 +++-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 3 -
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 6 +-
.../planner/plan/node/process/AggregationNode.java | 2 +-
.../plan/node/process/LastQueryMergeNode.java | 3 +-
.../plan/node/source/AlignedLastQueryScanNode.java | 4 +-
.../source/AlignedSeriesAggregationScanNode.java | 10 ++
.../plan/node/source/AlignedSeriesScanNode.java | 4 +-
.../node/source/SeriesAggregationScanNode.java | 1 +
.../plan/parameter/AggregationDescriptor.java | 3 +
.../java/org/apache/iotdb/db/service/DataNode.java | 47 ++++-----
.../thrift/impl/DataNodeTSIServiceImpl.java | 10 +-
.../service/thrift/impl/InternalServiceImpl.java | 110 ++++++++++++++------
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 12 ++-
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 7 ++
.../distribution/NoDataRegionPlanningTest.java | 84 +++++++++++++++
.../plan/node/write/DeleteRegionNodeSerdeTest.java | 60 -----------
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 3 +
thrift/src/main/thrift/mpp.thrift | 31 ++----
51 files changed, 656 insertions(+), 430 deletions(-)