You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/11/13 12:57:21 UTC
[incubator-iotdb] branch cluster_new updated (b032b22 -> 01c2bee)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from b032b22 code refinements
add 01c2bee separate network layer and raft transaction layer
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/cluster/config/ClusterConfig.java | 12 +
.../cluster/partition/HashRingPartitionTable.java | 105 +++++
.../iotdb/cluster/partition/PartitionGroup.java | 41 +-
.../iotdb/cluster/partition/PartitionTable.java | 9 +-
.../VNode.java} | 24 +-
.../iotdb/cluster/server/DataClusterServer.java | 41 ++
.../iotdb/cluster/server/LogCatchUpTask.java | 23 +-
.../iotdb/cluster/server/MetaClusterServer.java | 457 +------------------
.../apache/iotdb/cluster/server/RaftServer.java | 506 +--------------------
.../server/handlers/caller/AppendEntryHandler.java | 26 +-
.../server/handlers/caller/CatchUpHandler.java | 22 +-
.../server/handlers/caller/ElectionHandler.java | 22 +-
.../server/handlers/caller/HeartBeatHandler.java | 26 +-
.../server/handlers/caller/JoinClusterHandler.java | 5 +-
.../cluster/server/heartbeat/HeartBeatThread.java | 60 +--
.../server/heartbeat/MetaHeartBeatThread.java | 26 +-
.../MetaGroupMember.java} | 200 ++++----
.../{RaftServer.java => member/RaftMember.java} | 297 ++++--------
.../member/package-info.java} | 15 +-
19 files changed, 558 insertions(+), 1359 deletions(-)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/HashRingPartitionTable.java
copy cluster/src/main/java/org/apache/iotdb/cluster/{exception/RequestTimeOutException.java => partition/VNode.java} (62%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/server/DataClusterServer.java
copy cluster/src/main/java/org/apache/iotdb/cluster/server/{MetaClusterServer.java => member/MetaGroupMember.java} (84%)
copy cluster/src/main/java/org/apache/iotdb/cluster/server/{RaftServer.java => member/RaftMember.java} (74%)
copy cluster/src/main/java/org/apache/iotdb/cluster/{exception/RequestTimeOutException.java => server/member/package-info.java} (76%)