[incubator-iotdb] branch cluster_new updated (cb7693b -> f4f9671)

[ji...@apache.org]

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 cb7693b  Merge branch 'master' into cluster_new
     add f4f9671  support pulling timeseries

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/iotdb/cluster/ClusterMain.java |  8 +-
 .../apache/iotdb/cluster/client/DataClient.java    |  2 +-
 .../apache/iotdb/cluster/client/MetaClient.java    |  2 +-
 .../iotdb/cluster/config/ClusterConstant.java      |  2 +
 .../iotdb/cluster/log/applier/BaseApplier.java     | 29 +++++++-
 .../iotdb/cluster/log/applier/DataLogApplier.java  |  5 ++
 .../iotdb/cluster/log/applier/MetaLogApplier.java  |  1 +
 .../iotdb/cluster/log/manage/MemoryLogManager.java |  2 +-
 .../log/manage/PartitionedSnapshotLogManager.java  | 19 +----
 .../iotdb/cluster/server/DataClusterServer.java    | 44 +++++++++++
 .../iotdb/cluster/server/MetaClusterServer.java    | 19 ++++-
 ...ndler.java => PullTimeseriesSchemaHandler.java} | 52 ++++++-------
 ...hUpHandler.java => RequestCommitIdHandler.java} | 37 +++++-----
 .../cluster/server/member/DataGroupMember.java     | 63 ++++++++++++----
 .../cluster/server/member/MetaGroupMember.java     | 86 ++++++++++++++++++++--
 .../iotdb/cluster/server/member/RaftMember.java    | 79 ++++++++++++++++++--
 .../apache/iotdb/cluster/utils/PartitionUtils.java | 30 ++++----
 .../apache/iotdb/cluster/utils/StatusUtils.java    | 14 ++++
 .../iotdb/db/exception/ProcessException.java       |  5 ++
 ...ception.java => PathAlreadyExistException.java} |  8 +-
 ...stException.java => PathNotExistException.java} |  6 +-
 .../db/exception/query/QueryProcessException.java  |  3 +-
 .../java/org/apache/iotdb/db/metadata/MGraph.java  |  4 +-
 .../org/apache/iotdb/db/metadata/MManager.java     | 67 ++++++++++-------
 .../java/org/apache/iotdb/db/metadata/MTree.java   | 36 ++++-----
 .../iotdb/db/qp/executor/QueryProcessExecutor.java | 21 ++----
 .../org/apache/iotdb/db/utils/SchemaUtils.java     | 37 +++++++++-
 .../iotdb/db/metadata/MManagerImproveTest.java     |  2 +-
 .../java/org/apache/iotdb/rpc/TSStatusCode.java    |  4 +-
 service-rpc/src/main/thrift/cluster.thrift         | 22 +++++-
 30 files changed, 518 insertions(+), 191 deletions(-)
 copy cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/{PullSnapshotHandler.java => PullTimeseriesSchemaHandler.java} (50%)
 copy cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/{SnapshotCatchUpHandler.java => RequestCommitIdHandler.java} (56%)
 rename server/src/main/java/org/apache/iotdb/db/exception/metadata/{TimeseriesAlreadyExistException.java => PathAlreadyExistException.java} (78%)
 rename server/src/main/java/org/apache/iotdb/db/exception/metadata/{TimeseriesNotExistException.java => PathNotExistException.java} (83%)