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