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%)
