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%)
