This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-meta-sync
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 25db924dab4 Pipe Schema: schema events (#11763)
add 8a0bc3d2e88 [IOTDB-6275] Disable limit/offset push down in ORDER BY
(#11772)
add 539ec0f83f9 [IOTDB-6282] Remove DataNode RPC address conflict check
(#11803)
add cea15bbe37d [IOTDB-6283] Adjust the leader election waiting time when
create RegionGroup (#11804)
add 3d81881fd8b [IOTDB-6261] Pipe: support leader cache in
iotdb-thrift-async-connector (#11807)
add bc77397a872 Merge branch 'master' of github.com:apache/iotdb into
pipe-meta-sync
add 9374afd980d Update IoTDBThriftAsyncClientManager.java
add a1605e9dc9a Merge branch 'pipe-meta-sync' of github.com:apache/iotdb
into pipe-meta-sync
No new revisions were added by this update.
Summary of changes:
.../apache/iotdb/db/it/orderBy/IoTDBOrderByIT.java | 54 ++++--
.../confignode/manager/load/cache/LoadCache.java | 8 +-
.../manager/node/ClusterNodeStartUtils.java | 5 -
...eManager.java => IoTDBThriftClientManager.java} | 19 +-
.../async/IoTDBThriftAsyncClientManager.java | 200 ++++++++++++++++++++
.../thrift/async/IoTDBThriftAsyncConnector.java | 210 +++++----------------
.../PipeTransferTabletInsertNodeEventHandler.java | 12 ++
.../PipeTransferTabletInsertionEventHandler.java | 17 +-
.../handler/PipeTransferTabletRawEventHandler.java | 7 +
.../thrift/sync/IoTDBThriftSyncClientManager.java | 30 ++-
.../thrift/sync/IoTDBThriftSyncConnector.java | 2 +-
.../plan/optimization/LimitOffsetPushDown.java | 8 +
.../async/AsyncPipeDataTransferServiceClient.java | 8 +
13 files changed, 367 insertions(+), 213 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/{LeaderCacheManager.java
=> IoTDBThriftClientManager.java} (66%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/protocol/thrift/async/IoTDBThriftAsyncClientManager.java
