You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by er...@apache.org on 2022/03/21 06:55:27 UTC
[iotdb] branch new_mpp updated (0b5356f -> 87accb7)
This is an automated email from the ASF dual-hosted git repository.
ericpai pushed a change to branch new_mpp
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 0b5356f Implement phase 1
add 87accb7 [To_new_mpp] data block manager interface (#5280)
No new revisions were added by this update.
Summary of changes:
.../iotdb/commons/concurrent/ThreadName.java | 6 +-
.../apache/iotdb/commons/service/ServiceType.java | 3 +-
.../iotdb/db/mpp/buffer/DataBlockManager.java | 116 +++++++++++++++++++++
.../buffer/DataBlockManagerService.java} | 62 +++++------
.../DataBlockManagerServiceThriftHandler.java | 11 +-
.../mpp/buffer/DataBlockServiceClientFactory.java | 44 ++++++++
.../iotdb/db/mpp/buffer/DataBlockServiceImpl.java | 52 +++------
.../iotdb/db/mpp/buffer/IDataBlockManager.java | 80 --------------
.../buffer/{SinkHandle.java => ISinkHandle.java} | 35 ++++---
.../{SourceHandle.java => ISourceHandle.java} | 11 +-
.../apache/iotdb/db/mpp/buffer/SourceHandle.java | 70 +++++++++++--
.../db/mpp/schedule/task/FragmentInstanceID.java | 4 +-
thrift/src/main/thrift/common.thrift | 27 -----
.../src/main/thrift/mpp.thrift | 50 ++++-----
14 files changed, 329 insertions(+), 242 deletions(-)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManager.java
copy server/src/main/java/org/apache/iotdb/db/{service/InfluxDBRPCService.java => mpp/buffer/DataBlockManagerService.java} (51%)
copy cluster/src/main/java/org/apache/iotdb/cluster/server/raft/RaftServiceHandler.java => server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockManagerServiceThriftHandler.java (75%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceClientFactory.java
copy tsfile/src/test/java/org/apache/iotdb/tsfile/write/writer/TestTsFileOutput.java => server/src/main/java/org/apache/iotdb/db/mpp/buffer/DataBlockServiceImpl.java (50%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/buffer/IDataBlockManager.java
rename server/src/main/java/org/apache/iotdb/db/mpp/buffer/{SinkHandle.java => ISinkHandle.java} (53%)
copy server/src/main/java/org/apache/iotdb/db/mpp/buffer/{SourceHandle.java => ISourceHandle.java} (72%)
delete mode 100644 thrift/src/main/thrift/common.thrift
copy cluster/src/main/java/org/apache/iotdb/cluster/server/member/RaftMemberMBean.java => thrift/src/main/thrift/mpp.thrift (50%)