You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/03/13 14:19:48 UTC
[iotdb] branch master updated (49bd401 -> a95558e)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 49bd401 Construct basic framework of ConfigNode (#5199)
add a95558e [IOTDB-2673] Implement the consensus layer basic framework (#5204)
No new revisions were added by this update.
Summary of changes:
{example/pulsar => consensus}/pom.xml | 26 +--
.../org/apache/iotdb/consensus/IConsensus.java | 57 +++++
.../iotdb/consensus/common/ConsensusGroup.java | 42 ++--
.../iotdb/consensus/common/ConsensusGroupId.java | 38 +--
.../org/apache/iotdb/consensus/common/DataSet.java | 5 +-
.../apache/iotdb/consensus/common/Endpoint.java | 41 ++--
.../apache/iotdb/consensus/common/GroupType.java | 12 +-
.../org/apache/iotdb/consensus/common/Peer.java | 41 ++--
.../common/request/IConsensusRequest.java | 12 +-
.../common/response/ConsensusGenericResponse.java | 64 ++++++
.../common/response/ConsensusReadResponse.java | 65 ++++++
.../common/response/ConsensusResponse.java | 21 +-
.../common/response/ConsensusWriteResponse.java | 65 ++++++
.../consensus/exception/ConsensusException.java | 6 +-
.../ConsensusGroupAlreadyExistException.java | 21 +-
.../exception/ConsensusGroupNotExistException.java | 21 +-
.../exception/IllegalPeerNumException.java | 9 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 90 ++++++++
.../consensus/standalone/StandAloneConsensus.java | 170 ++++++++++++++
.../consensus/standalone/StandAloneServerImpl.java | 61 +++++
.../consensus/statemachine/EmptyStateMachine.java | 24 +-
.../consensus/statemachine/IStateMachine.java | 25 +-
.../standalone/StandAloneConsensusTest.java | 254 +++++++++++++++++++++
pom.xml | 1 +
server/pom.xml | 5 +
.../apache/iotdb/db/consensus/ConsensusMain.java | 95 ++++++++
.../ratis/RatisDataRegionStateMachine.java | 34 +--
.../ratis/RatisSchemaRegionStateMachine.java | 34 +--
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 18 +-
29 files changed, 1164 insertions(+), 193 deletions(-)
copy {example/pulsar => consensus}/pom.xml (72%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/IConsensus.java
copy server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/PlainDeviceID.java => consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusGroup.java (59%)
copy server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/PlainDeviceID.java => consensus/src/main/java/org/apache/iotdb/consensus/common/ConsensusGroupId.java (61%)
copy integration/src/main/java/org/apache/iotdb/itbase/category/RemoteTest.java => consensus/src/main/java/org/apache/iotdb/consensus/common/DataSet.java (91%)
copy server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/PlainDeviceID.java => consensus/src/main/java/org/apache/iotdb/consensus/common/Endpoint.java (64%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java => consensus/src/main/java/org/apache/iotdb/consensus/common/GroupType.java (81%)
copy server/src/main/java/org/apache/iotdb/db/metadata/idtable/entry/PlainDeviceID.java => consensus/src/main/java/org/apache/iotdb/consensus/common/Peer.java (60%)
copy cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataGroupEngineMBean.java => consensus/src/main/java/org/apache/iotdb/consensus/common/request/IConsensusRequest.java (78%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusGenericResponse.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusReadResponse.java
copy server/src/main/java/org/apache/iotdb/db/engine/upgrade/UpgradeCheckStatus.java => consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusResponse.java (68%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/common/response/ConsensusWriteResponse.java
copy server/src/main/java/org/apache/iotdb/db/exception/WriteLockFailedException.java => consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusException.java (84%)
copy grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java => consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupAlreadyExistException.java (66%)
copy grafana-connector/src/main/java/org/apache/iotdb/web/grafana/dao/BasicDao.java => consensus/src/main/java/org/apache/iotdb/consensus/exception/ConsensusGroupNotExistException.java (67%)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/BadSeedUrlFormatException.java => consensus/src/main/java/org/apache/iotdb/consensus/exception/IllegalPeerNumException.java (75%)
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/ratis/RatisConsensus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneConsensus.java
create mode 100644 consensus/src/main/java/org/apache/iotdb/consensus/standalone/StandAloneServerImpl.java
copy server/src/main/java/org/apache/iotdb/db/exception/BatchProcessException.java => consensus/src/main/java/org/apache/iotdb/consensus/statemachine/EmptyStateMachine.java (64%)
copy jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBSQLException.java => consensus/src/main/java/org/apache/iotdb/consensus/statemachine/IStateMachine.java (63%)
create mode 100644 consensus/src/test/java/org/apache/iotdb/consensus/standalone/StandAloneConsensusTest.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/consensus/ConsensusMain.java
copy cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogCallback.java => server/src/main/java/org/apache/iotdb/db/consensus/ratis/RatisDataRegionStateMachine.java (50%)
copy cluster/src/main/java/org/apache/iotdb/cluster/log/CommitLogCallback.java => server/src/main/java/org/apache/iotdb/db/consensus/ratis/RatisSchemaRegionStateMachine.java (50%)