This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a change to branch 1.3-sub
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 312e0477dc6 Optimized the hint for subscription (#17115)
add fd1bc16e116 Subscription: Optimized the performance (#17121)
No new revisions were added by this update.
Summary of changes:
.../it/env/cluster/config/MppCommonConfig.java | 5 --
.../env/cluster/config/MppSharedCommonConfig.java | 6 ---
.../it/env/remote/config/RemoteCommonConfig.java | 4 --
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 -
.../it/cluster/IoTDBSubscriptionRestartIT.java | 7 +--
.../it/dual/AbstractSubscriptionDualIT.java | 4 --
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 57 ++++++++++++++++++++++
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 2 +
.../it/dual/IoTDBSubscriptionTopicIT.java | 14 ++++++
.../it/local/AbstractSubscriptionLocalIT.java | 1 -
.../it/local/IoTDBSubscriptionBasicIT.java | 8 +++
.../it/local/IoTDBSubscriptionDataTypeIT.java | 21 ++++++++
.../it/local/IoTDBSubscriptionIdempotentIT.java | 4 ++
.../it/local/IoTDBSubscriptionTopicIT.java | 5 ++
.../it/triple/AbstractSubscriptionTripleIT.java | 5 --
.../it/triple/IoTDBSubscriptionSharingIT.java | 2 +
.../IoTDBDefaultPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultTsfilePushConsumerIT.java | 2 +
.../IoTDBRootDatasetPushConsumerIT.java | 2 +
.../IoTDBRootPullConsumeTsfileIT.java | 2 +
...merPullConsumerWith1TopicShareProcessMixIT.java | 2 +
.../param/IoTDBTestParamPullConsumerIT.java | 26 ++++++++++
.../param/IoTDBTestParamPushConsumerIT.java | 19 ++++++++
.../param/IoTDBTestParamSubscriptionSessionIT.java | 6 +++
.../regression/param/IoTDBTestParamTopicIT.java | 20 ++++++++
...DBTestAutoCommitFalseDataSetPullConsumerIT.java | 2 +
...TDBTestAutoCommitTrueDataSetPullConsumerIT.java | 2 +
.../format/IoTDBDBDataSetPullConsumerIT.java | 2 +
.../format/IoTDBDBTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsDatasetPullConsumerIT.java | 2 +
.../IoTDBAllTsTsfilePullConsumerIT.java | 2 +
.../IoTDBAllTsfilePullConsumerSnapshotIT.java | 2 +
.../IoTDBPathDeviceDataSetPullConsumerIT.java | 2 +
.../IoTDBPathDeviceTsfilePullConsumerIT.java | 2 +
.../IoTDBTimeTsDatasetPullConsumerIT.java | 2 +
.../IoTDBTimeTsTsfilePullConsumerIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerDataSetIT.java | 2 +
.../IoTDBSnapshotDevicePullConsumerTsfileIT.java | 2 +
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +
.../pattern/IoTDBDBPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDBPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDefaultPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBDevicePatternPullConsumeTsfileIT.java | 2 +
.../IoTDBDevicePatternPullConsumerDataSetIT.java | 2 +
...DBMiddleMatch2PatternPullConsumerDataSetIT.java | 2 +
...IoTDBMiddleMatchPatternPullConsumeTsfileIT.java | 2 +
...TDBMiddleMatchPatternPullConsumerDataSetIT.java | 2 +
.../IoTDBRootPatternPullConsumeTsfileIT.java | 2 +
.../pattern/IoTDBTSPatternPullConsumeTsfileIT.java | 2 +
.../IoTDBTSPatternPullConsumerDataSetIT.java | 2 +
.../time/IoTDBAllPullConsumerDataSetIT.java | 2 +
.../time/IoTDBHistoryPullConsumerDataSetIT.java | 2 +
.../time/IoTDBRealTimePullConsumerDataSetIT.java | 2 +
...oTDBTimeRangeAccuratePullConsumerDataSetIT.java | 2 +
.../time/IoTDBTimeRangePullConsumerDataSetIT.java | 2 +
.../format/IoTDBTestPushConsumeDataSetIT.java | 2 +
.../IoTDBTestPushConsumeNoTargetDirTsfileIT.java | 2 +
.../format/IoTDBTestPushConsumeTsfileIT.java | 2 +
.../IoTDBLooseAllTsDatasetPushConsumerIT.java | 2 +
...TDBLooseAllTsDatasetPushConsumerSnapshotIT.java | 2 +
.../IoTDBLooseAllTsfilePushConsumerIT.java | 2 +
.../IoTDBPathLooseDeviceTsfilePushConsumerIT.java | 2 +
.../IoTDBPathLooseTsDatasetPushConsumerIT.java | 2 +
.../IoTDBPathLooseTsfilePushConsumerIT.java | 2 +
.../IoTDBPathTsLooseDatasetPushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsDatasetPushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsTsfilePushConsumerIT.java | 2 +
.../IoTDBTimeLooseTsfilePushConsumerIT.java | 2 +
.../IoTDBTimeTsLooseDatasetPushConsumerIT.java | 2 +
...oTDBSnapshotTSPatternDatasetPushConsumerIT.java | 2 +
...IoTDBSnapshotTSPatternTsfilePushConsumerIT.java | 2 +
...DBConsumer2With1TopicShareProcessDataSetIT.java | 2 +
...TDBConsumer2With1TopicShareProcessTsfileIT.java | 2 +
.../multi/IoTDBMultiGroupVsMultiConsumerIT.java | 2 +
.../IoTDBOneConsumerMultiTopicsDatasetIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsMixIT.java | 2 +
.../multi/IoTDBOneConsumerMultiTopicsTsfileIT.java | 2 +
.../IoTDBDBPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBDBPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBDefaultPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBDevicePatternDatasetPushConsumerIT.java | 2 +
.../IoTDBDevicePatternTsfilePushConsumerIT.java | 2 +
.../IoTDBRootPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBTSPatternDatasetPushConsumerIT.java | 2 +
.../IoTDBTSPatternTsfilePushConsumerIT.java | 2 +
.../IoTDBHistoryRootDatasetPushConsumerIT.java | 2 +
.../time/IoTDBHistoryRootTsFilePushConsumerIT.java | 2 +
.../time/IoTDBRealTimeDBDatasetPushConsumerIT.java | 2 +
.../time/IoTDBRealTimeDBTsfilePushConsumerIT.java | 2 +
...DBTimeRangeAccurateDBDataSetPushConsumerIT.java | 2 +
.../IoTDBTimeRangeDBDataSetPushConsumerIT.java | 2 +
.../time/IoTDBTimeRangeDBTsfilePushConsumerIT.java | 2 +
.../topic/IoTDBDataSet1TopicConsumerSpecialIT.java | 2 +
.../regression/topic/IoTDBTestTopicNameIT.java | 2 +
.../regression/user/IoTDBOtherUserConsumerIT.java | 8 ++-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 3 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 8 ---
.../iotdb/commons/conf/CommonDescriptor.java | 5 --
.../subscription/config/SubscriptionConfig.java | 4 +-
104 files changed, 355 insertions(+), 49 deletions(-)
