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);
}
}