diff --git a/src/main/java/com/influxdb/v3/client/InfluxDBClient.java b/src/main/java/com/influxdb/v3/client/InfluxDBClient.java index 0231edf..401e0fb 100644 --- a/src/main/java/com/influxdb/v3/client/InfluxDBClient.java +++ b/src/main/java/com/influxdb/v3/client/InfluxDBClient.java @@ -138,23 +138,23 @@ public interface InfluxDBClient extends AutoCloseable { @Nonnull Stream query(@Nonnull final String query, @Nonnull final QueryOptions options); - /** - * Query data from InfluxDB IOx into Point structure using FlightSQL. - *

- * The result stream should be closed after use, you can use try-resource pattern to close it automatically: - *

-	 * try (Stream<Object[]> rows = client.queryPoints("select * from cpu", options)) {
-	 *      rows.forEach(row -> {
-	 *          // process row
-	 *      }
-	 * });
-	 * 
- * - * @param query the SQL query string to execute, cannot be null - * @return Batches of PointValues returned by the query - */ - @Nonnull - Stream queryPoints(@Nonnull final String query); + /** + * Query data from InfluxDB IOx into Point structure using FlightSQL. + *

+ * The result stream should be closed after use, you can use try-resource pattern to close it automatically: + *

+     * try (Stream<Object[]> rows = client.queryPoints("select * from cpu", options)) {
+     *      rows.forEach(row -> {
+     *          // process row
+     *      }
+     * });
+     * 
+ * + * @param query the SQL query string to execute, cannot be null + * @return Batches of PointValues returned by the query + */ + @Nonnull + Stream queryPoints(@Nonnull final String query); /** * Query data from InfluxDB IOx into Point structure using FlightSQL. diff --git a/src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java b/src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java index 88851a4..fe2c986 100644 --- a/src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java +++ b/src/main/java/com/influxdb/v3/client/internal/InfluxDBClientImpl.java @@ -161,13 +161,13 @@ public Stream query(@Nonnull final String query, @Nonnull final QueryO }); } - @Nonnull - @Override - public Stream queryPoints(@Nonnull final String query) { - return queryPoints(query, QueryOptions.DEFAULTS); - } + @Nonnull + @Override + public Stream queryPoints(@Nonnull final String query) { + return queryPoints(query, QueryOptions.DEFAULTS); + } - @Nonnull + @Nonnull @Override public Stream queryPoints(@Nonnull final String query, @Nonnull final QueryOptions options) { return queryData(query, options)