You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by lt...@apache.org on 2019/12/18 13:09:40 UTC
[incubator-iotdb] branch cluster_new updated (238f3fb -> c282746)
This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 238f3fb add query coordinator framework
add 2b711e1 add host and ring feature for node tool
add 376e7a3 add DataPartition command of NodeTool
add 4b7be30 add status command of nodetool
add 0f0efc1 merge cluster_new
add c282746 fix some bugs
No new revisions were added by this update.
Summary of changes:
cluster/src/assembly/resources/sbin/add-node.sh | 2 +-
.../src/assembly/resources/sbin/nodetool.bat | 23 +--
.../src/assembly/resources/sbin/nodetool.sh | 20 +--
cluster/src/assembly/resources/sbin/start-node.sh | 2 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 8 +-
.../iotdb/cluster/config/ClusterConstant.java | 1 +
.../iotdb/cluster/partition/PartitionGroup.java | 2 +-
.../iotdb/cluster/partition/PartitionTable.java | 2 +
.../cluster/partition/SlotPartitionTable.java | 5 +
.../iotdb/cluster/server/MetaClusterServer.java | 16 +-
.../apache/iotdb/cluster/server/RaftServer.java | 3 +-
...{GenericHandler.java => NodeStatusHandler.java} | 34 ++---
.../cluster/server/member/DataGroupMember.java | 1 +
.../cluster/server/member/MetaGroupMember.java | 108 +++++++++----
.../apache/iotdb/cluster/utils/PartitionUtils.java | 22 +++
.../cluster/utils/nodetool/ClusterMonitor.java | 167 +++++++++++++++++++++
.../utils/nodetool/ClusterMonitorMBean.java | 72 +++++++++
.../iotdb/cluster/utils/nodetool/NodeTool.java | 42 +++---
.../iotdb/cluster/utils/nodetool/Printer.java | 26 ++--
.../cluster/utils/nodetool/function/Host.java | 70 +++++++++
.../utils/nodetool/function/NodeToolCmd.java | 102 +++++++++++++
.../cluster/utils/nodetool/function/Partition.java | 85 +++++++++++
.../nodetool/function/Ring.java} | 30 ++--
.../nodetool/function/Status.java} | 30 ++--
.../org/apache/iotdb/db/service/ServiceType.java | 3 +-
service-rpc/src/main/thrift/cluster.thrift | 2 +
.../tsfile/read/filter/FilterSerializeTest.java | 18 +++
27 files changed, 763 insertions(+), 133 deletions(-)
copy client/src/assembly/resources/tools/import-csv.bat => cluster/src/assembly/resources/sbin/nodetool.bat (72%)
mode change 100644 => 100755
copy server/src/assembly/resources/tools/detect-watermark.sh => cluster/src/assembly/resources/sbin/nodetool.sh (87%)
mode change 100644 => 100755
copy cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/{GenericHandler.java => NodeStatusHandler.java} (63%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitor.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/ClusterMonitorMBean.java
copy server/src/main/java/org/apache/iotdb/db/tools/memestimation/MemEstTool.java => cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/NodeTool.java (70%)
copy server/src/main/java/org/apache/iotdb/db/qp/logical/crud/UpdateOperator.java => cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/Printer.java (66%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Host.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/NodeToolCmd.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/Partition.java
copy cluster/src/main/java/org/apache/iotdb/cluster/{exception/LeaderUnknownException.java => utils/nodetool/function/Ring.java} (52%)
copy cluster/src/main/java/org/apache/iotdb/cluster/{exception/LeaderUnknownException.java => utils/nodetool/function/Status.java} (52%)