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 ade1501 rename connect node and fix readString
add 3634857 add sync interface
add 36d524d [IOTDB-627]Support range deletion for timeseries (#1400)
add 8d8938b Merge branch 'master' into cluster_new
add 3a6e418 disable selector thread when not using async servers
No new revisions were added by this update.
Summary of changes:
.../cluster/client/async/AsyncDataClient.java | 16 +-
.../cluster/client/async/AsyncMetaClient.java | 16 +-
.../cluster/client/sync/SyncClientAdaptor.java | 4 +-
.../SyncClientFactory.java} | 9 +-
.../SyncClientPool.java} | 43 ++-
.../iotdb/cluster/client/sync/SyncDataClient.java | 81 ++++
.../iotdb/cluster/client/sync/SyncMetaClient.java | 73 ++++
.../apache/iotdb/cluster/config/ClusterConfig.java | 11 +
.../iotdb/cluster/log/catchup/CatchUpTask.java | 16 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 129 +++++--
.../cluster/log/catchup/SnapshotCatchUpTask.java | 42 +-
.../cluster/log/snapshot/PullSnapshotTask.java | 41 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 87 ++++-
.../query/groupby/RemoteGroupByExecutor.java | 13 +-
.../query/last/ClusterLastQueryExecutor.java | 70 +++-
.../cluster/query/manage/QueryCoordinator.java | 15 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 16 +-
.../reader/RemoteSeriesReaderByTimestamp.java | 62 ++-
.../query/reader/RemoteSimpleSeriesReader.java | 82 ++--
.../apache/iotdb/cluster/server/ClientServer.java | 10 +-
.../iotdb/cluster/server/DataClusterServer.java | 187 ++++++++-
.../iotdb/cluster/server/MetaClusterServer.java | 111 +++++-
.../cluster/server/PullSnapshotHintService.java | 29 +-
.../apache/iotdb/cluster/server/RaftServer.java | 59 ++-
.../server/heartbeat/DataHeartbeatThread.java | 10 +-
.../cluster/server/heartbeat/HeartbeatThread.java | 104 ++++-
.../server/heartbeat/MetaHeartbeatThread.java | 28 +-
.../cluster/server/member/DataGroupMember.java | 54 ++-
.../cluster/server/member/MetaGroupMember.java | 430 +++++++++++++++++----
.../iotdb/cluster/server/member/RaftMember.java | 188 +++++++--
...{BaseAsyncService.java => BaseSyncService.java} | 88 ++---
.../cluster/server/service/DataSyncService.java | 279 +++++++++++++
...{MetaAsyncService.java => MetaSyncService.java} | 102 +++--
.../cluster/log/applier/DataLogApplierTest.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 | 2 +-
.../DML Data Manipulation Language.md | 28 +-
docs/UserGuide/Operation Manual/SQL Reference.md | 9 +-
.../DML Data Manipulation Language.md | 25 +-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 9 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 4 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 8 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 23 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 5 +-
.../db/engine/memtable/IWritableMemChunk.java | 10 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 9 +-
.../db/engine/merge/task/MergeMultiChunkTask.java | 3 +-
.../iotdb/db/engine/modification/Deletion.java | 47 ++-
.../io/LocalTextModificationAccessor.java | 20 +-
.../engine/storagegroup/StorageGroupProcessor.java | 60 ++-
.../db/engine/storagegroup/TsFileProcessor.java | 3 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 5 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 9 +-
.../db/qp/logical/crud/DeleteDataOperator.java | 18 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 49 ++-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 59 ++-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 2 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 3 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 40 +-
.../iotdb/db/utils/datastructure/TVList.java | 35 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 8 +-
.../iotdb/db/engine/merge/MergeTaskTest.java | 2 +-
.../engine/modification/DeletionFileNodeTest.java | 28 +-
.../db/engine/modification/DeletionQueryTest.java | 52 +--
.../engine/modification/ModificationFileTest.java | 8 +-
.../storagegroup/StorageGroupProcessorTest.java | 2 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 37 ++
.../apache/iotdb/db/integration/IoTDBLastIT.java | 52 +++
.../iotdb/db/qp/plan/LogicalPlanSmallTest.java | 93 +++++
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 11 +
.../apache/iotdb/db/writelog/PerformanceTest.java | 4 +-
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 2 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 8 +-
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 2 +-
.../db/writelog/io/MultiFileLogReaderTest.java | 2 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 6 +-
.../java/org/apache/iotdb/session/Session.java | 19 +-
thrift/rpc-changelist.md | 4 +-
thrift/src/main/thrift/rpc.thrift | 3 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 46 ++-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 2 +-
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 17 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 51 ++-
.../read/controller/CachedChunkLoaderImpl.java | 2 +-
.../tsfile/read/reader/chunk/ChunkReader.java | 24 +-
.../read/reader/chunk/ChunkReaderByTimestamp.java | 4 +-
.../iotdb/tsfile/read/reader/page/PageReader.java | 41 +-
.../tsfile/v1/file/metadata/ChunkMetadataV1.java | 11 +-
.../tsfile/v1/read/TsFileSequenceReaderForV1.java | 2 +-
.../iotdb/tsfile/read/common/TimeRangeTest.java | 70 ++++
.../iotdb/tsfile/read/reader/PageReaderTest.java | 55 +++
95 files changed, 2948 insertions(+), 724 deletions(-)
copy
cluster/src/main/java/org/apache/iotdb/cluster/client/{async/AsyncClientFactory.java
=> sync/SyncClientFactory.java} (80%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/client/{async/AsyncClientPool.java
=> sync/SyncClientPool.java} (69%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncDataClient.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/client/sync/SyncMetaClient.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/service/{BaseAsyncService.java
=> BaseSyncService.java} (52%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/service/DataSyncService.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/service/{MetaAsyncService.java
=> MetaSyncService.java} (70%)
