[incubator-iotdb] branch cluster_new updated (dbe9e16 -> 876e2f0)

[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 dbe9e16  multiple refinements
     add 876e2f0  support creating timeseries

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/iotdb/cluster/ClientMain.java  |  22 +++-
 .../apache/iotdb/cluster/client/MetaClient.java    |   2 +-
 .../iotdb/cluster/config/ClusterConstant.java      |   6 +-
 .../java/org/apache/iotdb/cluster/log/Log.java     |   2 -
 .../org/apache/iotdb/cluster/log/LogParser.java    |   8 +-
 .../{MetaLogApplier.java => BaseApplier.java}      |  46 +-------
 .../iotdb/cluster/log/applier/DataLogApplier.java  |  18 ++-
 .../iotdb/cluster/log/applier/MetaLogApplier.java  |  24 +---
 .../iotdb/cluster/log/catchup/LogCatchUpTask.java  |   3 +
 .../cluster/log/catchup/SnapshotCatchUpTask.java   |   5 +-
 .../log/manage/PartitionedSnapshotLogManager.java  |  53 +++++++--
 ...SimpleSnapshot.java => DataSimpleSnapshot.java} |  37 +++---
 .../cluster/log/snapshot/PartitionedSnapshot.java  |   6 +-
 ...Snapshot.java => RemoteDataSimpleSnapshot.java} |  44 +++++--
 .../iotdb/cluster/partition/PartitionTable.java    |   2 +-
 .../cluster/partition/SocketPartitionTable.java    |   3 +-
 .../iotdb/cluster/server/DataClusterServer.java    |   6 +-
 .../apache/iotdb/cluster/server/RaftServer.java    |   4 +-
 .../server/handlers/caller/ElectionHandler.java    |  17 +--
 .../cluster/server/heartbeat/HeartBeatThread.java  |   7 ++
 .../cluster/server/member/DataGroupMember.java     |  66 +++++++----
 .../cluster/server/member/MetaGroupMember.java     | 131 +++++++--------------
 .../iotdb/cluster/server/member/RaftMember.java    | 120 ++++++++++++++++++-
 .../apache/iotdb/cluster/utils/PartitionUtils.java |  66 +++++++++++
 .../apache/iotdb/cluster/utils/SerializeUtils.java |   4 +-
 .../apache/iotdb/cluster/utils/StatusUtils.java    |   1 +
 .../db/exception/NotStorageGroupException.java     |   3 +-
 .../iotdb/db/exception/PathErrorException.java     |   4 +-
 ...tion.java => SeriesAlreadyExistsException.java} |   6 +-
 .../java/org/apache/iotdb/db/metadata/MGraph.java  |   2 +-
 .../org/apache/iotdb/db/metadata/MManager.java     |  45 ++++---
 .../java/org/apache/iotdb/db/metadata/MTree.java   |   7 +-
 .../org/apache/iotdb/db/monitor/StatMonitor.java   |   2 +-
 .../iotdb/db/qp/executor/QueryProcessExecutor.java |  19 ++-
 .../iotdb/db/qp/logical/crud/FilterOperator.java   |  10 +-
 .../apache/iotdb/db/qp/physical/PhysicalPlan.java  |   7 +-
 .../db/qp/physical/sys/CreateTimeSeriesPlan.java   |  43 +++++--
 .../org/apache/iotdb/db/service/TSServiceImpl.java |   6 +-
 .../db/sync/receiver/transfer/SyncServiceImpl.java |   2 +-
 .../org/apache/iotdb/db/metadata/MGraphTest.java   |   2 +-
 .../iotdb/db/metadata/MManagerAdvancedTest.java    |   2 +-
 .../iotdb/db/metadata/MManagerBasicTest.java       |  33 +++---
 .../iotdb/db/metadata/MManagerImproveTest.java     |   8 +-
 .../org/apache/iotdb/db/metadata/MTreeTest.java    |  12 +-
 .../org/apache/iotdb/db/metadata/MetadataTest.java |   2 +-
 .../java/org/apache/iotdb/rpc/TSStatusCode.java    |   3 +-
 service-rpc/src/main/thrift/cluster.thrift         |   9 +-
 47 files changed, 580 insertions(+), 350 deletions(-)
 copy cluster/src/main/java/org/apache/iotdb/cluster/log/applier/{MetaLogApplier.java => BaseApplier.java} (51%)
 copy cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/{MetaSimpleSnapshot.java => DataSimpleSnapshot.java} (59%)
 rename cluster/src/main/java/org/apache/iotdb/cluster/log/snapshot/{RemoteSimpleSnapshot.java => RemoteDataSimpleSnapshot.java} (62%)
 create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/PartitionUtils.java
 copy server/src/main/java/org/apache/iotdb/db/exception/{StorageGroupAlreadyExistException.java => SeriesAlreadyExistsException.java} (78%)