This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from d329317 update
new f72c1f8 add physical codec unit test
new bd17560 merge serialize-physicalplan
new c372675 add insert and author plan function
new b42fd35 add DataStateMachine Handler
new 4275731 Deprecated RouteTable and redesign refresh leader logic
new 0659ca8 fix conflicts
The 1584 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../apache/iotdb/cluster/callback/MultiTask.java | 2 +-
.../apache/iotdb/cluster/callback/SingleTask.java | 12 +-
.../org/apache/iotdb/cluster/callback/Task.java | 18 ++-
.../org/apache/iotdb/cluster/entity/Server.java | 19 ++-
.../entity/raft/DataPartitionRaftHolder.java | 2 +-
.../cluster/entity/raft/DataStateMachine.java | 57 +++++++-
.../cluster/entity/raft/MetadataRaftHolder.java | 2 +-
.../cluster/entity/raft/MetadataStateManchine.java | 80 +++++------
.../apache/iotdb/cluster/qp/ClusterQPExecutor.java | 21 ++-
.../cluster/qp/executor/NonQueryExecutor.java | 71 ++++++----
.../cluster/qp/executor/QueryMetadataExecutor.java | 2 +-
.../processor/ChangeMetadataAsyncProcessor.java | 85 -----------
.../rpc/processor/NonQueryAsyncProcessor.java | 113 +++++++++++++++
.../rpc/processor/QueryMetadataAsyncProcessor.java | 37 ++---
.../iotdb/cluster/rpc/request/BasicRequest.java | 2 +
...geMetadataRequest.java => NonQueryRequest.java} | 19 ++-
.../iotdb/cluster/rpc/response/BasicResponse.java | 35 ++++-
.../cluster/rpc/response/NonQueryResponse.java | 6 +-
.../rpc/response/QueryMetadataResponse.java | 6 +-
.../cluster/rpc/service/TSServiceClusterImpl.java | 7 +-
.../org/apache/iotdb/cluster/utils/RaftUtils.java | 39 +++++-
.../iotdb/db/qp/logical/sys/MetadataOperator.java | 3 +-
.../org/apache/iotdb/db/utils/ByteBufferUtils.java | 59 --------
.../iotdb/db/writelog/transfer/CodecInstances.java | 156 ++++++++++++---------
.../writelog/transfer/PhysicalPlanLogTransfer.java | 67 +++++----
25 files changed, 535 insertions(+), 385 deletions(-)
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/ChangeMetadataAsyncProcessor.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/rpc/processor/NonQueryAsyncProcessor.java
rename
cluster/src/main/java/org/apache/iotdb/cluster/rpc/request/{ChangeMetadataRequest.java
=> NonQueryRequest.java} (78%)
delete mode 100644
iotdb/src/main/java/org/apache/iotdb/db/utils/ByteBufferUtils.java
