Subscription: unify tablet push consumer builder return type (apache#14971)

VGalaxies · web-flow · commit f1a224e56c17 · 2025-02-27T16:38:58.000+08:00
diff --git a/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumerBuilder.java b/iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumerBuilder.java
@@ -21,6 +21,7 @@
 
 import org.apache.iotdb.session.subscription.consumer.AckStrategy;
 import org.apache.iotdb.session.subscription.consumer.ConsumeListener;
+import org.apache.iotdb.session.subscription.consumer.ISubscriptionTablePushConsumer;
 import org.apache.iotdb.session.subscription.consumer.base.AbstractSubscriptionPushConsumerBuilder;
 
 import java.util.List;
@@ -132,7 +133,7 @@ public SubscriptionTablePushConsumerBuilder autoPollTimeoutMs(final long autoPol
   }
 
   @Override
-  public SubscriptionTablePushConsumer buildTablePushConsumer() {
+  public ISubscriptionTablePushConsumer buildTablePushConsumer() {
     return new SubscriptionTablePushConsumer(this);
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -21,6 +21,7 @@`
`21`	`21`
`22`	`22`	`import org.apache.iotdb.session.subscription.consumer.AckStrategy;`
`23`	`23`	`import org.apache.iotdb.session.subscription.consumer.ConsumeListener;`
	`24`	`+import org.apache.iotdb.session.subscription.consumer.ISubscriptionTablePushConsumer;`
`24`	`25`	`import org.apache.iotdb.session.subscription.consumer.base.AbstractSubscriptionPushConsumerBuilder;`
`25`	`26`
`26`	`27`	`import java.util.List;`
`@@ -132,7 +133,7 @@ public SubscriptionTablePushConsumerBuilder autoPollTimeoutMs(final long autoPol`
`132`	`133`	`}`
`133`	`134`
`134`	`135`	`@Override`
`135`		`- public SubscriptionTablePushConsumer buildTablePushConsumer() {`
	`136`	`+ public ISubscriptionTablePushConsumer buildTablePushConsumer() {`
`136`	`137`	`return new SubscriptionTablePushConsumer(this);`
`137`	`138`	`}`
`138`	`139`	`}`