Subscription: simplify table and tree consumer builder interface (#15399)

Author: VGalaxies

example/session/src/main/java/org/apache/iotdb/TableModelSubscriptionSessionExample.java

@@ -119,7 +119,7 @@ private static void dataSubscription() throws Exception {
         new SubscriptionTablePullConsumerBuilder()
             .consumerId("c1")
             .consumerGroupId("cg1")
-            .buildTablePullConsumer()) {
+            .build()) {
       consumer1.open();
       consumer1.subscribe(TOPIC_1);
       while (true) {

iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/SubscriptionTableTsFile.java

@@ -109,7 +109,7 @@ public void createConsumers(String groupId) {
                   .autoCommit(Constants.AUTO_COMMIT)
                   .autoCommitIntervalMs(Constants.AUTO_COMMIT_INTERVAL)
                   .fileSaveDir(commonParam.getTargetDir())
-                  .buildTablePullConsumer());
+                  .build());
     }
     commonParam
         .getPullTableConsumers()

iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumerBuilder.java

@@ -21,10 +21,6 @@
 
 import org.apache.iotdb.isession.SessionConfig;
 import org.apache.iotdb.rpc.subscription.config.ConsumerConstant;
-import org.apache.iotdb.session.subscription.consumer.ISubscriptionTablePullConsumer;
-import org.apache.iotdb.session.subscription.consumer.ISubscriptionTablePushConsumer;
-import org.apache.iotdb.session.subscription.consumer.ISubscriptionTreePullConsumer;
-import org.apache.iotdb.session.subscription.consumer.ISubscriptionTreePushConsumer;
 import org.apache.iotdb.session.subscription.util.IdentifierUtils;
 
 import org.apache.thrift.annotation.Nullable;
@@ -131,20 +127,4 @@ public AbstractSubscriptionConsumerBuilder maxPollParallelism(final int maxPollP
     this.maxPollParallelism = Math.max(maxPollParallelism, 1);
     return this;
   }
-
-  public ISubscriptionTreePullConsumer buildTreePullConsumer() {
-    throw new UnsupportedOperationException();
-  }
-
-  public ISubscriptionTreePushConsumer buildTreePushConsumer() {
-    throw new UnsupportedOperationException();
-  }
-
-  public ISubscriptionTablePullConsumer buildTablePullConsumer() {
-    throw new UnsupportedOperationException();
-  }
-
-  public ISubscriptionTablePushConsumer buildTablePushConsumer() {
-    throw new UnsupportedOperationException();
-  }
 }

iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePullConsumerBuilder.java

@@ -118,8 +118,7 @@ public SubscriptionTablePullConsumerBuilder autoCommitIntervalMs(
     return this;
   }
 
-  @Override
-  public ISubscriptionTablePullConsumer buildTablePullConsumer() {
+  public ISubscriptionTablePullConsumer build() {
     return new SubscriptionTablePullConsumer(this);
   }
 }

iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/table/SubscriptionTablePushConsumerBuilder.java

@@ -132,8 +132,7 @@ public SubscriptionTablePushConsumerBuilder autoPollTimeoutMs(final long autoPol
     return this;
   }
 
-  @Override
-  public ISubscriptionTablePushConsumer buildTablePushConsumer() {
+  public ISubscriptionTablePushConsumer build() {
     return new SubscriptionTablePushConsumer(this);
   }
 }

iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePullConsumerBuilder.java

@@ -117,8 +117,7 @@ public SubscriptionTreePullConsumerBuilder autoCommitIntervalMs(final long autoC
     return this;
   }
 
-  @Override
-  public ISubscriptionTreePullConsumer buildTreePullConsumer() {
+  public ISubscriptionTreePullConsumer build() {
     return new SubscriptionTreePullConsumer(this);
   }
 }

iotdb-client/session/src/main/java/org/apache/iotdb/session/subscription/consumer/tree/SubscriptionTreePushConsumerBuilder.java

@@ -132,8 +132,7 @@ public SubscriptionTreePushConsumerBuilder autoPollTimeoutMs(final long autoPoll
     return this;
   }
 
-  @Override
-  public ISubscriptionTreePushConsumer buildTreePushConsumer() {
+  public ISubscriptionTreePushConsumer build() {
     return new SubscriptionTreePushConsumer(this);
   }
 }