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 aaff44910bd Pipe: aggregate tablets with different measurements under
the same table before write into tsfile (#15372)
add 74827521421 Subscription: obtain database name for message payload
subscribed by table model consumer (#15374)
No new revisions were added by this update.
Summary of changes:
.../TableModelSubscriptionSessionExample.java | 1 +
.../rpc/subscription/annotation/TableModel.java | 12 +++--
.../subscription/payload/poll/FileSealPayload.java | 27 +++++++++--
.../subscription/payload/poll/TabletsPayload.java | 41 +++++++++++++---
.../base/AbstractSubscriptionConsumer.java | 24 +++++++---
.../payload/SubscriptionFileHandler.java | 7 ---
.../subscription/payload/SubscriptionMessage.java | 29 +++++++----
.../payload/SubscriptionMessageHandler.java | 7 +--
.../payload/SubscriptionSessionDataSet.java | 12 ++++-
.../SubscriptionSessionDataSetsHandler.java | 56 +++++++++++++++-------
.../payload/SubscriptionTsFileHandler.java | 14 ++++--
.../broker/SubscriptionPrefetchingTsFileQueue.java | 3 ++
.../db/subscription/event/SubscriptionEvent.java | 4 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 27 +++++++----
.../batch/SubscriptionPipeTsFileEventBatch.java | 5 +-
.../response/SubscriptionEventTabletResponse.java | 20 ++++----
.../response/SubscriptionEventTsFileResponse.java | 9 +++-
17 files changed, 211 insertions(+), 87 deletions(-)
copy
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/schema/node/utils/MNodeFactory.java
=>
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/subscription/annotation/TableModel.java
(78%)
