refactor: change function name

Author: NguyenHoangSon96

src/main/java/com/influxdb/v3/client/internal/GrpcCallOptions.java

@@ -60,6 +60,24 @@ private GrpcCallOptions(@Nonnull final Builder builder) {
         this.callOptions = builder.callOptions.toArray(new CallOption[0]);
     }
 
+
+    /**
+     * Creates a default instance of {@link GrpcCallOptions} with predefined settings.
+     * <p>
+     * The default configuration includes:
+     * <ul>
+     *   <li>Maximum inbound message size set to {@link Integer#MAX_VALUE}.</li>
+     * </ul>
+     * Other options can be customized using the {@link GrpcCallOptions.Builder}.
+     *
+     * @return the default configuration of {@link GrpcCallOptions}.
+     */
+    public static GrpcCallOptions getDefaultOptions() {
+        GrpcCallOptions.Builder builder = new GrpcCallOptions.Builder();
+        builder.withMaxInboundMessageSize(Integer.MAX_VALUE);
+        return builder.build();
+    }
+
     /**
      * Merges two arrays of {@link CallOption} into a single array. The method combines the elements
      * from the baseCallOptions array and the additional callOptions array. If either of the input

src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java

@@ -342,7 +342,8 @@ private Stream<VectorSchemaRoot> queryData(@Nonnull final String query,
             }
         });
 
-        CallOption[] callOptions = options.grpcCallOption() != null ? options.grpcCallOption().getCallOptions() : null;
+        CallOption[] callOptions = options.grpcCallOptions() != null
+                ? options.grpcCallOptions().getCallOptions() : null;
         return flightSqlClient.execute(
                 query,
                 database,

src/main/java/com/influxdb/v3/client/query/QueryOptions.java

@@ -62,7 +62,7 @@ public final class QueryOptions {
     private final String database;
     private final QueryType queryType;
     private final Map<String, String> headers;
-    private GrpcCallOptions grpcCallOption;
+    private GrpcCallOptions grpcCallOptions = GrpcCallOptions.getDefaultOptions();
 
     /**
      * Construct QueryAPI options. The query type is set to SQL.
@@ -148,18 +148,18 @@ public Map<String, String> headersSafe() {
 
     /**
      * Sets the GrpcCallOptions object.
-     * @param grpcCallOption the grpcCallOption
+     * @param grpcCallOptions the grpcCallOptions
      */
-    public void setGrpcCallOption(@Nonnull final GrpcCallOptions grpcCallOption) {
-        this.grpcCallOption = grpcCallOption;
+    public void setGrpcCallOptions(@Nonnull final GrpcCallOptions grpcCallOptions) {
+        this.grpcCallOptions = grpcCallOptions;
     }
 
     /**
      * @return the GrpcCallOptions object.
      */
     @Nullable
-    public GrpcCallOptions grpcCallOption() {
-        return grpcCallOption;
+    public GrpcCallOptions grpcCallOptions() {
+        return grpcCallOptions;
     }
 
     private boolean isNotDefined(final String option) {

src/test/java/com/influxdb/v3/client/query/QueryOptionsTest.java

@@ -128,7 +128,7 @@ void setInboundMessageSizeSmall() throws Exception {
                     .build();
 
             QueryOptions queryOptions = new QueryOptions("test");
-            queryOptions.setGrpcCallOption(grpcCallOption);
+            queryOptions.setGrpcCallOptions(grpcCallOption);
 
             try (InfluxDBClient influxDBClient = InfluxDBClient.getInstance(builder.build())) {
                 try (Stream<PointValues> stream = influxDBClient.queryPoints(
@@ -166,7 +166,7 @@ void setInboundMessageSizeLarge() throws Exception {
                     .build();
 
             QueryOptions queryOptions = new QueryOptions("test");
-            queryOptions.setGrpcCallOption(grpcCallOption);
+            queryOptions.setGrpcCallOptions(grpcCallOption);
 
             try (InfluxDBClient influxDBClient = InfluxDBClient.getInstance(clientConfig)) {
                 Assertions.assertThatNoException().isThrownBy(() -> {
@@ -181,7 +181,15 @@ void setInboundMessageSizeLarge() throws Exception {
     }
 
     @Test
-    void setGrpcCallOption() {
+    void defaultGrpcCallOptions() {
+        GrpcCallOptions grpcCallOptions = new QueryOptions("test").grpcCallOptions();
+        Assertions.assertThat(grpcCallOptions).isNotNull();
+        Assertions.assertThat(grpcCallOptions.getMaxInboundMessageSize()).isEqualTo(Integer.MAX_VALUE);
+        Assertions.assertThat(grpcCallOptions.getCallOptions().length).isEqualTo(1);
+    }
+
+    @Test
+    void setGrpcCallOptions() {
         Executor executor = Executors.newSingleThreadExecutor();
         Deadline deadline = Deadline.after(2, TimeUnit.SECONDS);
         String compressorName = "name";
@@ -195,19 +203,19 @@ void setGrpcCallOption() {
                 .build();
 
         QueryOptions options = new QueryOptions("test");
-        options.setGrpcCallOption(grpcCallOption);
-        Assertions.assertThat(options.grpcCallOption()).isNotNull();
-        Assertions.assertThat(options.grpcCallOption().getMaxInboundMessageSize()).isEqualTo(1024);
-        Assertions.assertThat(options.grpcCallOption().getMaxOutboundMessageSize()).isEqualTo(1024);
-        Assertions.assertThat(options.grpcCallOption().getExecutor()).isEqualTo(executor);
-        Assertions.assertThat(options.grpcCallOption().getWaitForReady()).isTrue();
-        Assertions.assertThat(options.grpcCallOption().getCompressorName()).isEqualTo(compressorName);
-        Assertions.assertThat(options.grpcCallOption().getDeadline()).isEqualTo(deadline);
+        options.setGrpcCallOptions(grpcCallOption);
+        Assertions.assertThat(options.grpcCallOptions()).isNotNull();
+        Assertions.assertThat(options.grpcCallOptions().getMaxInboundMessageSize()).isEqualTo(1024);
+        Assertions.assertThat(options.grpcCallOptions().getMaxOutboundMessageSize()).isEqualTo(1024);
+        Assertions.assertThat(options.grpcCallOptions().getExecutor()).isEqualTo(executor);
+        Assertions.assertThat(options.grpcCallOptions().getWaitForReady()).isTrue();
+        Assertions.assertThat(options.grpcCallOptions().getCompressorName()).isEqualTo(compressorName);
+        Assertions.assertThat(options.grpcCallOptions().getDeadline()).isEqualTo(deadline);
 
     }
 
     @Test
-    void grpcCallOption() {
+    void grpcCallOptions() {
         Executor executor = Executors.newSingleThreadExecutor();
         Deadline deadline = Deadline.after(2, TimeUnit.SECONDS);
         GrpcCallOptions grpcCallOption = new GrpcCallOptions.Builder()