This is an automated email from the ASF dual-hosted git repository.
tanxinyu pushed a change to branch cluster-
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from c3ee7b6 [cluster refactor] fix code style of single line in if block
add ea399f5 fix code smell step 1
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 66 +++++++++++-----------
.../apache/iotdb/cluster/ClusterIoTDBMBean.java | 5 +-
.../apache/iotdb/cluster/client/BaseFactory.java | 8 +--
.../iotdb/cluster/client/ClientCategory.java | 2 +-
.../apache/iotdb/cluster/client/ClientManager.java | 24 ++++----
.../iotdb/cluster/client/ClientPoolFactory.java | 2 +-
.../cluster/client/async/AsyncBaseFactory.java | 4 +-
.../cluster/client/async/AsyncDataClient.java | 3 +-
.../cluster/client/async/AsyncMetaClient.java | 6 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 6 +-
.../iotdb/cluster/client/sync/SyncMetaClient.java | 4 +-
.../iotdb/cluster/config/ClusterConstant.java | 2 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 5 +-
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 8 +--
.../apache/iotdb/cluster/metadata/CMManager.java | 22 ++------
.../apache/iotdb/cluster/metadata/MetaPuller.java | 10 +---
.../iotdb/cluster/query/ClusterPlanExecutor.java | 43 +++-----------
.../cluster/query/aggregate/ClusterAggregator.java | 5 +-
.../cluster/query/fill/ClusterPreviousFill.java | 21 +++----
.../query/groupby/RemoteGroupByExecutor.java | 12 ++--
.../cluster/query/reader/ClusterReaderFactory.java | 8 +--
.../reader/RemoteSeriesReaderByTimestamp.java | 4 +-
.../query/reader/RemoteSimpleSeriesReader.java | 4 +-
.../query/reader/mult/MultDataSourceInfo.java | 14 ++---
.../query/reader/mult/RemoteMultSeriesReader.java | 9 +--
.../cluster/server/ClusterRPCServiceMBean.java | 1 +
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 15 +----
.../cluster/server/PullSnapshotHintService.java | 4 +-
.../cluster/server/heartbeat/HeartbeatThread.java | 2 +-
.../server/member/DataGroupMemberMBean.java | 1 +
.../cluster/server/member/MetaGroupMember.java | 26 +--------
.../server/member/MetaGroupMemberMBean.java | 1 +
.../iotdb/cluster/server/member/RaftMember.java | 5 +-
.../cluster/server/member/RaftMemberMBean.java | 1 +
.../server/raft/AbstractDataRaftService.java | 1 +
.../server/raft/AbstractMetaRaftService.java | 1 +
.../server/raft/DataRaftHeartBeatService.java | 1 +
.../server/raft/DataRaftHeartBeatServiceMBean.java | 1 +
.../iotdb/cluster/server/raft/DataRaftService.java | 1 +
.../cluster/server/raft/DataRaftServiceMBean.java | 1 +
.../server/raft/MetaRaftHeartBeatService.java | 1 +
.../server/raft/MetaRaftHeartBeatServiceMBean.java | 1 +
.../iotdb/cluster/server/raft/MetaRaftService.java | 1 +
.../cluster/server/raft/MetaRaftServiceMBean.java | 1 +
.../cluster/server/raft/RaftServiceHandler.java | 7 ++-
.../cluster/server/service/DataGroupEngine.java | 28 +++------
.../server/service/DataGroupEngineMBean.java | 1 +
47 files changed, 147 insertions(+), 252 deletions(-)
