You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ta...@apache.org on 2022/04/07 09:56:51 UTC

[iotdb] branch datanode_consensus_init updated (2f1d22eea1 -> 3fa51af757)

This is an automated email from the ASF dual-hosted git repository.

tanxinyu pushed a change to branch datanode_consensus_init
in repository https://gitbox.apache.org/repos/asf/iotdb.git


    from 2f1d22eea1 fix SchemaEngine typo
     add 3fa51af757 abstract ConsensusGroupId

No new revisions were added by this update.

Summary of changes:
 .../iotdb/confignode/manager/ConsensusManager.java |   4 +-
 .../persistence/RegionInfoPersistence.java         |   6 +-
 .../iotdb/confignode/physical/PhysicalPlan.java    |   2 +-
 .../physical/sys/SchemaPartitionPlan.java          |   3 +-
 .../iotdb/consensus/common/ConsensusType.java      |  54 ----------
 .../ConsensusGroupAlreadyExistException.java       |   2 +-
 .../org/apache/iotdb/consensus/ratis/Utils.java    |  17 +--
 .../iotdb/consensus/ratis/RatisConsensusTest.java  |   4 +-
 .../apache/iotdb/consensus/ratis/UtilsTest.java    |   7 +-
 .../standalone/StandAloneConsensusTest.java        |  10 +-
 .../iotdb/commons/consensus/ConsensusGroupId.java  |  81 ++++++--------
 .../{ConsensusGroupId.java => DataRegionId.java}   |  42 ++------
 ...onsensusGroupId.java => PartitionRegionId.java} |  42 ++------
 .../{ConsensusGroupId.java => SchemaRegionId.java} |  42 ++------
 .../iotdb/commons/partition/RegionReplicaSet.java  |   8 +-
 .../iotdb/db/consensus/ConsensusExample.java       | 118 ---------------------
 .../apache/iotdb/db/consensus/ConsensusImpl.java   |  10 +-
 .../statemachine/DataRegionStateMachine.java       |   7 ++
 .../statemachine/SchemaRegionStateMachine.java     |   7 ++
 .../org/apache/iotdb/db/engine/StorageEngine.java  |  15 +--
 .../iotdb/db/metadata/LocalConfigManager.java      |  32 +++---
 .../db/metadata/LocalSchemaPartitionTable.java     |  26 +++--
 .../db/metadata/schemaregion/SchemaEngine.java     |  22 ++--
 .../db/metadata/schemaregion/SchemaRegion.java     |   8 +-
 .../iotdb/db/metadata/template/Template.java       |  18 ++--
 .../db/metadata/template/TemplateManager.java      |   6 +-
 .../mpp/sql/analyze/FakePartitionFetcherImpl.java  |  13 ++-
 .../db/mpp/sql/plan/DistributionPlannerTest.java   |  13 ++-
 28 files changed, 186 insertions(+), 433 deletions(-)
 delete mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusType.java
 copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => DataRegionId.java} (60%)
 copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => PartitionRegionId.java} (60%)
 copy node-commons/src/main/java/org/apache/iotdb/commons/consensus/{ConsensusGroupId.java => SchemaRegionId.java} (60%)
 delete mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusExample.java