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/18 12:57:30 UTC
[incubator-iotdb] branch cluster_new updated (d03ddd9 -> e45ec8c)
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 d03ddd9 add unfinished update partition table
add e45ec8c refactor partition table
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/cluster/config/ClusterConfig.java | 20 +-
.../cluster/exception/NotInSameGroupException.java | 3 +-
.../cluster/partition/AddNodePartitionUpdate.java | 25 +++
.../cluster/partition/HashRingPartitionTable.java | 222 -------------------
.../iotdb/cluster/partition/PartitionGroup.java | 35 +--
.../iotdb/cluster/partition/PartitionTable.java | 18 +-
.../cluster/partition/SocketPartitionTable.java | 242 +++++++++++++++++++++
.../iotdb/cluster/server/DataClusterServer.java | 19 +-
.../server/heartbeat/MetaHeartBeatThread.java | 7 +-
.../cluster/server/member/DataGroupMember.java | 49 ++---
.../cluster/server/member/MetaGroupMember.java | 99 ++++-----
.../apache/iotdb/cluster/utils/SerializeUtils.java | 59 +++++
service-rpc/src/main/thrift/cluster.thrift | 42 ++--
13 files changed, 446 insertions(+), 394 deletions(-)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/AddNodePartitionUpdate.java
delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/HashRingPartitionTable.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/partition/SocketPartitionTable.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/SerializeUtils.java