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/iotdb.git.
from 9e33a73 fix tests
add f409921 fix code smells
No new revisions were added by this update.
Summary of changes:
.../iotdb/cluster/log/catchup/CatchUpTask.java | 27 +--
.../log/manage/UnCommittedEntryManager.java | 45 ++--
.../apache/iotdb/cluster/metadata/CMManager.java | 15 +-
.../cluster/partition/slot/SlotPartitionTable.java | 53 +----
.../groupby/ClusterGroupByNoVFilterDataSet.java | 17 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 18 +-
.../handlers/caller/AppendNodeEntryHandler.java | 1 -
.../iotdb/cluster/server/member/RaftMember.java | 7 +-
.../cluster/server/service/DataSyncService.java | 2 +-
.../engine/storagegroup/StorageGroupProcessor.java | 67 +++---
.../db/engine/storagegroup/TsFileProcessor.java | 114 +++++-----
.../db/engine/storagegroup/TsFileResource.java | 73 ++++---
.../iotdb/db/exception/BatchProcessException.java | 9 +-
.../org/apache/iotdb/db/metadata/MManager.java | 193 +++++++++--------
.../org/apache/iotdb/db/monitor/StatMonitor.java | 1 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 213 ++++++++-----------
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 21 ++
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 87 ++++----
.../dataset/groupby/GroupByEngineDataSet.java | 7 +-
.../groupby/GroupByWithValueFilterDataSet.java | 2 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 1 -
.../org/apache/iotdb/db/utils/SerializeUtils.java | 233 +++++++++++++--------
.../db/writelog/node/ExclusiveWriteLogNode.java | 1 -
.../engine/storagegroup/TsFileProcessorTest.java | 8 +-
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 14 +-
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 19 +-
...ngeableTransport.java => NonOpenTransport.java} | 20 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 3 +-
.../rpc/TCompressedElasticFramedTransport.java | 56 +----
.../apache/iotdb/rpc/TElasticFramedTransport.java | 18 +-
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 9 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 12 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 11 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 14 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 114 +++-------
35 files changed, 678 insertions(+), 827 deletions(-)
copy
service-rpc/src/main/java/org/apache/iotdb/rpc/{TimeoutChangeableTransport.java
=> NonOpenTransport.java} (71%)
