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 0927009a779 [AINode] Fix the seed when inference (#15850)
add 71df4956ef0 Subscription: intro poll and prefetch v2 for tsfile topic
(#15790)
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 17 +
.../env/cluster/config/MppSharedCommonConfig.java | 19 +
.../it/env/remote/config/RemoteCommonConfig.java | 11 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 6 +
.../it/triple/AbstractSubscriptionTripleIT.java | 7 +
.../AbstractSubscriptionTreeRegressionIT.java | 71 +++-
.../IoTDBRootPullConsumeTsfileIT.java | 15 +-
.../format/IoTDBDBTsfilePullConsumerIT.java | 18 +-
.../IoTDBAllTsTsfilePullConsumerIT.java | 16 +-
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 14 +-
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 17 +-
.../IoTDBTimeTsTsfilePullConsumerIT.java | 17 +-
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 16 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 33 +-
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 39 +--
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 15 +-
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 14 +-
.../IoTDBRootPatternPullConsumeTsfileIT.java | 12 +-
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 15 +-
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 8 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 11 +
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 4 +-
.../db/subscription/broker/SubscriptionBroker.java | 35 +-
.../broker/SubscriptionPrefetchingQueue.java | 387 ++++++++++++++++++++-
.../broker/SubscriptionPrefetchingTabletQueue.java | 7 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 6 -
.../SubscriptionPipeEventBatchSegmentLock.java} | 55 +--
.../event/batch/SubscriptionPipeEventBatches.java | 118 ++++---
.../batch/SubscriptionPipeTsFileEventBatch.java | 40 +--
.../receiver/SubscriptionReceiverV1.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 4 +-
31 files changed, 719 insertions(+), 330 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/resource/tsfile/PipeTsFileResourceSegmentLock.java
=> subscription/event/batch/SubscriptionPipeEventBatchSegmentLock.java} (60%)
