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 b6f9ab4 change default compression in iotdb-engine.properties for
cluster
add 3c89485 fix sonar issue add sync adaptor
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 1 +
.../java/org/apache/iotdb/cluster/ClusterMain.java | 23 +++--
.../cluster/client/{ => async}/ClientFactory.java | 2 +-
.../cluster/client/{ => async}/ClientPool.java | 2 +-
.../cluster/client/{ => async}/DataClient.java | 6 +-
.../cluster/client/{ => async}/MetaClient.java | 6 +-
.../cluster/client/sync/SyncClientAdaptor.java | 104 +++++++++++++++++++++
.../iotdb/cluster/log/catchup/CatchUpTask.java | 44 ++++-----
.../cluster/log/snapshot/PullSnapshotTask.java | 2 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 3 +-
.../query/groupby/RemoteGroupByExecutor.java | 2 +-
.../cluster/query/manage/QueryCoordinator.java | 2 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 68 +++++---------
.../reader/RemoteSeriesReaderByTimestamp.java | 2 +-
.../query/reader/RemoteSimpleSeriesReader.java | 2 +-
.../apache/iotdb/cluster/server/ClientServer.java | 2 +-
.../cluster/server/member/DataGroupMember.java | 4 +-
.../cluster/server/member/MetaGroupMember.java | 6 +-
.../iotdb/cluster/server/member/RaftMember.java | 2 +-
.../iotdb/cluster/client/ClientPoolTest.java | 4 +
.../iotdb/cluster/common/TestClientFactory.java | 4 +-
.../iotdb/cluster/common/TestDataClient.java | 4 +-
.../iotdb/cluster/common/TestMetaClient.java | 4 +-
.../cluster/query/reader/DatasourceInfoTest.java | 2 +-
.../reader/RemoteSeriesReaderByTimestampTest.java | 2 +-
.../query/reader/RemoteSimpleSeriesReaderTest.java | 2 +-
.../iotdb/cluster/server/member/MemberTest.java | 2 +-
.../cluster/server/member/MetaGroupMemberTest.java | 8 +-
28 files changed, 200 insertions(+), 115 deletions(-)
rename cluster/src/main/java/org/apache/iotdb/cluster/client/{ =>
async}/ClientFactory.java (96%)
rename cluster/src/main/java/org/apache/iotdb/cluster/client/{ =>
async}/ClientPool.java (98%)
rename cluster/src/main/java/org/apache/iotdb/cluster/client/{ =>
async}/DataClient.java (96%)
rename cluster/src/main/java/org/apache/iotdb/cluster/client/{ =>
async}/MetaClient.java (96%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncClientAdaptor.java
