You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/04/14 02:25:27 UTC
[incubator-iotdb] branch cluster_new updated (9075be9 -> 3215776)
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 9075be9 Merge branch 'master' into cluster_new
add 3215776 [IOTDB-351] Serialize raft log (#958)
No new revisions were added by this update.
Summary of changes:
.../resources/conf/iotdb-cluster.properties | 3 +
.../apache/iotdb/cluster/config/ClusterConfig.java | 12 +
.../iotdb/cluster/config/ClusterDescriptor.java | 5 +-
.../cluster/exception/MemberReadOnlyException.java | 19 +
.../java/org/apache/iotdb/cluster/log/Log.java | 1 +
.../org/apache/iotdb/cluster/log/LogManager.java | 1 -
.../iotdb/cluster/log/logtypes/AddNodeLog.java | 1 +
.../cluster/log/logtypes/PhysicalPlanLog.java | 1 +
.../iotdb/cluster/log/logtypes/RemoveNodeLog.java | 19 +
.../iotdb/cluster/log/manage/DiskLogManager.java | 144 +++++
.../manage/FilePartitionedSnapshotLogManager.java | 3 +-
.../iotdb/cluster/log/manage/MemoryLogManager.java | 65 ++-
.../log/manage/MetaSingleSnapshotLogManager.java | 4 +-
.../manage/serializable/LogDequeSerializer.java | 79 +++
.../log/manage/serializable/LogManagerMeta.java | 111 ++++
.../serializable/SyncLogDequeSerializer.java | 482 +++++++++++++++++
.../iotdb/cluster/partition/NodeRemovalResult.java | 19 +
.../cluster/query/ClusterAggregateExecutor.java | 19 +
.../cluster/query/ClusterConcatPathOptimizer.java | 19 +
.../iotdb/cluster/query/ClusterFillExecutor.java | 19 +
.../cluster/query/filter/SlotTsFileFilter.java | 19 +
.../groupby/ClusterGroupByNoVFilterDataSet.java | 19 +
.../groupby/ClusterGroupByVFilterDataSet.java | 19 +
.../query/groupby/MergeGroupByExecutor.java | 19 +
.../query/groupby/RemoteGroupByExecutor.java | 19 +
.../iotdb/cluster/query/reader/EmptyReader.java | 19 +
.../cluster/query/reader/ManagedMergeReader.java | 19 +
.../cluster/query/reader/MergedReaderByTime.java | 19 +
.../apache/iotdb/cluster/server/NodeReport.java | 19 +
.../iotdb/cluster/utils/nodetool/NodeTool.java | 6 +-
.../cluster/utils/nodetool/function/LogView.java | 65 +++
.../org/apache/iotdb/cluster/common/TestUtils.java | 15 +
...LogManagerTest.java => DiskLogManagerTest.java} | 89 +---
.../serializable/SyncLogDequeSerializerTest.java | 584 +++++++++++++++++++++
.../query/ClusterAggregateExecutorTest.java | 19 +
.../cluster/query/ClusterFillExecutorTest.java | 19 +
.../ClusterGroupByNoVFilterDataSetTest.java | 19 +
.../groupby/ClusterGroupByVFilterDataSetTest.java | 19 +
.../query/groupby/MergeGroupByExecutorTest.java | 19 +
.../query/groupby/RemoteGroupByExecutorTest.java | 19 +
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 9 +
41 files changed, 1995 insertions(+), 84 deletions(-)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/DiskLogManager.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/LogDequeSerializer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/LogManagerMeta.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializer.java
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/utils/nodetool/function/LogView.java
copy cluster/src/test/java/org/apache/iotdb/cluster/log/manage/{MemoryLogManagerTest.java => DiskLogManagerTest.java} (62%)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/log/manage/serializable/SyncLogDequeSerializerTest.java