[iotdb] branch cluster_new updated (8ed3620 -> 9093e8f)

[ji...@apache.org]

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 8ed3620  Merge pull request #2172 from LebronAl/cluster_new_add_setup_example_docs
     add 2f90321  add snappy in transport
     add 1f94649  fix read
     add af7dae3  fix read
     add 0a42b77  refactor transport factory
     add e515abd  fix non socket transport
     add 938ec8b  fix thrift dependency
     add c986c26  fix buffer resize
     add d5dacc5  remove redundant resize
     add 7962ebc  do not resize when reading request size
     add 369fb6f  buffer will not shrink benethe initial capacity
     add 6fb6226  fix missing initial size
     add a184758  add compression report fix single node does not commit
     add 2aba5fb  abstract TCompressedElasticFramedTransport
     add aa059e1  limit shrink frequency
     add ce3edd0  Merge branch 'cluster_new' into cluster_add_snappy
     add 5a1189e  refactor extended transports
     add e82c6b1  fix missing plan index
     add 9093e8f  Merge branch 'cluster_add_snappy' into cluster_new

No new revisions were added by this update.

Summary of changes:
 .../java/org/apache/iotdb/cluster/ClientMain.java  |   4 +-
 .../cluster/client/rpcutils/AutoScalingBuffer.java |  39 -----
 .../rpcutils/AutoScalingBufferReadTransport.java   |  41 ------
 .../iotdb/cluster/client/sync/SyncDataClient.java  |   9 +-
 .../client/sync/SyncDataHeartbeatClient.java       |   4 +-
 .../iotdb/cluster/client/sync/SyncMetaClient.java  |   4 +-
 .../client/sync/SyncMetaHeartbeatClient.java       |   4 +-
 .../apache/iotdb/cluster/server/ClientServer.java  |   6 +-
 .../apache/iotdb/cluster/server/NodeReport.java    |  18 +++
 .../apache/iotdb/cluster/server/RaftServer.java    |   6 +-
 .../cluster/server/heartbeat/HeartbeatServer.java  |   7 +-
 .../iotdb/cluster/server/member/RaftMember.java    |   7 +-
 .../apache/iotdb/cluster/utils/ClusterUtils.java   |   7 +-
 .../TimeoutChangeableTFastFramedTransportTest.java |  24 ---
 .../org/apache/iotdb/jdbc/IoTDBConnection.java     |  16 +-
 .../db/service/thrift/ThriftServiceThread.java     |   4 +-
 .../iotdb/db/sync/sender/transfer/SyncClient.java  |   5 +-
 .../org/apache/iotdb/rpc/AutoResizingBuffer.java   |  80 ++++++++++
 .../iotdb/rpc/AutoScalingBufferReadTransport.java  |  91 ++++++++++++
 .../rpc}/AutoScalingBufferWriteTransport.java      |  26 ++--
 ...atementExecutionException.java => RpcStat.java} |  33 +++--
 ...tionException.java => RpcTransportFactory.java} |  35 ++---
 .../main/java/org/apache/iotdb/rpc/RpcUtils.java   |   9 ++
 .../rpc/TCompressedElasticFramedTransport.java     | 161 +++++++++++++++++++++
 .../apache/iotdb/rpc}/TElasticFramedTransport.java |  33 ++++-
 .../iotdb/rpc/TSnappyElasticFramedTransport.java   |  85 +++++++++++
 .../TimeoutChangeableTFastFramedTransport.java     |  20 ++-
 .../TimeoutChangeableTSnappyFramedTransport.java   |  22 ++-
 .../iotdb/rpc/TimeoutChangeableTransport.java      |  12 +-
 .../apache/iotdb/session/SessionConnection.java    |   4 +-
 30 files changed, 602 insertions(+), 214 deletions(-)
 delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/AutoScalingBuffer.java
 delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/AutoScalingBufferReadTransport.java
 delete mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/client/rpcutils/TimeoutChangeableTFastFramedTransportTest.java
 create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/AutoResizingBuffer.java
 create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/AutoScalingBufferReadTransport.java
 rename {cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils => service-rpc/src/main/java/org/apache/iotdb/rpc}/AutoScalingBufferWriteTransport.java (77%)
 copy service-rpc/src/main/java/org/apache/iotdb/rpc/{StatementExecutionException.java => RpcStat.java} (56%)
 copy service-rpc/src/main/java/org/apache/iotdb/rpc/{BatchExecutionException.java => RpcTransportFactory.java} (53%)
 create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TCompressedElasticFramedTransport.java
 rename {cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils => service-rpc/src/main/java/org/apache/iotdb/rpc}/TElasticFramedTransport.java (86%)
 create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/TSnappyElasticFramedTransport.java
 copy {cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils => service-rpc/src/main/java/org/apache/iotdb/rpc}/TimeoutChangeableTFastFramedTransport.java (71%)
 rename cluster/src/main/java/org/apache/iotdb/cluster/client/rpcutils/TimeoutChangeableTFastFramedTransport.java => service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTSnappyFramedTransport.java (62%)
 copy server/src/main/java/org/apache/iotdb/db/exception/LoadEmptyFileException.java => service-rpc/src/main/java/org/apache/iotdb/rpc/TimeoutChangeableTransport.java (81%)