This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b7bafc1882e Bump semver from 5.7.1 to 5.7.2 in
/iotdb-connector/grafana-plugin (#10547)
add 0a5d4ec993f [IOTDB-6123] Pipe: reduce the de/ser to slove the slow log
transfer problem (#10913)
No new revisions were added by this update.
Summary of changes:
.../payload/evolvable/PipeRequestType.java | 7 +-
...oTDBThriftAsyncPipeTransferBatchReqBuilder.java | 13 +--
...IoTDBThriftSyncPipeTransferBatchReqBuilder.java | 13 +--
.../builder/PipeTransferBatchReqBuilder.java | 33 ++++++++
...tchReq.java => PipeTransferTabletBatchReq.java} | 81 ++++++++++++------
...deReq.java => PipeTransferTabletBinaryReq.java} | 65 ++++++++-------
...q.java => PipeTransferTabletInsertNodeReq.java} | 18 ++--
...abletReq.java => PipeTransferTabletRawReq.java} | 18 ++--
.../protocol/airgap/IoTDBAirGapConnector.java | 19 +++--
.../thrift/async/IoTDBThriftAsyncConnector.java | 65 ++++++++-------
...va => PipeTransferTabletBatchEventHandler.java} | 11 ++-
... PipeTransferTabletInsertNodeEventHandler.java} | 4 +-
...java => PipeTransferTabletRawEventHandler.java} | 4 +-
.../thrift/sync/IoTDBThriftSyncConnector.java | 25 ++++--
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 15 +++-
.../receiver/thrift/IoTDBThriftReceiverV1.java | 58 +++++++++----
.../dataregion/wal/utils/WALEntryHandler.java | 36 +++++++-
.../dataregion/wal/utils/WALEntryPosition.java | 14 +++-
.../dataregion/wal/utils/WALInsertNodeCache.java | 96 +++++++++++++++-------
.../iotdb/db/pipe/connector/PipeReceiverTest.java | 4 +-
.../db/pipe/connector/PipeThriftRequestTest.java | 17 ++--
.../dataregion/wal/node/WALEntryHandlerTest.java | 6 +-
.../wal/utils/WALInsertNodeCacheTest.java | 8 +-
23 files changed, 408 insertions(+), 222 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferBatchReq.java
=> PipeTransferTabletBatchReq.java} (63%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferInsertNodeReq.java
=> PipeTransferTabletBinaryReq.java} (72%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferInsertNodeReq.java
=> PipeTransferTabletInsertNodeReq.java} (87%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/payload/evolvable/request/{PipeTransferTabletReq.java
=> PipeTransferTabletRawReq.java} (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/{PipeTransferTabletBatchInsertionEventHandler.java
=> PipeTransferTabletBatchEventHandler.java} (90%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/{PipeTransferInsertNodeTabletInsertionEventHandler.java
=> PipeTransferTabletInsertNodeEventHandler.java} (93%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/handler/{PipeTransferRawTabletInsertionEventHandler.java
=> PipeTransferTabletRawEventHandler.java} (94%)
