This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new bac9f664f5f Subscription: unify table and tree consumer builder 
interface (#15392)
bac9f664f5f is described below

commit bac9f664f5f9acc772d2ae44bec8c07268d96857
Author: VGalaxies <[email protected]>
AuthorDate: Wed Apr 23 10:18:43 2025 +0800

    Subscription: unify table and tree consumer builder interface (#15392)
---
 .../consumer/base/AbstractSubscriptionConsumerBuilder.java            | 4 ++--
 .../consumer/tree/SubscriptionTreePullConsumerBuilder.java            | 2 +-
 .../consumer/tree/SubscriptionTreePushConsumerBuilder.java            | 2 +-
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java
 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java
index 0ea275a7ace..7ddcca7b9c6 100644
--- 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java
+++ 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java
@@ -132,11 +132,11 @@ public class AbstractSubscriptionConsumerBuilder {
     return this;
   }
 
-  public ISubscriptionTreePullConsumer buildPullConsumer() {
+  public ISubscriptionTreePullConsumer buildTreePullConsumer() {
     throw new UnsupportedOperationException();
   }
 
-  public ISubscriptionTreePushConsumer buildPushConsumer() {
+  public ISubscriptionTreePushConsumer buildTreePushConsumer() {
     throw new UnsupportedOperationException();
   }
 
diff --git 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java
 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java
index 8c6796af00d..ebd87bdc0ff 100644
--- 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java
+++ 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java
@@ -118,7 +118,7 @@ public class SubscriptionTreePullConsumerBuilder extends 
AbstractSubscriptionPul
   }
 
   @Override
-  public ISubscriptionTreePullConsumer buildPullConsumer() {
+  public ISubscriptionTreePullConsumer buildTreePullConsumer() {
     return new SubscriptionTreePullConsumer(this);
   }
 }
diff --git 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java
 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java
index be156dbc417..09c6e60dc8b 100644
--- 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java
+++ 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java
@@ -133,7 +133,7 @@ public class SubscriptionTreePushConsumerBuilder extends 
AbstractSubscriptionPus
   }
 
   @Override
-  public ISubscriptionTreePushConsumer buildPushConsumer() {
+  public ISubscriptionTreePushConsumer buildTreePushConsumer() {
     return new SubscriptionTreePushConsumer(this);
   }
 }

Reply via email to