@@ -207,12 +207,11 @@ Stream<Object[]> query(@Nonnull final String query,
207207 * <p>
208208 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
209209 * <pre>
210- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
211- * Map.of("host", "server-a"), options)) {
210+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=intel")) {
212211 * rows.forEach(row -> {
213212 * // process row
214- * }
215- * }) ;
213+ * });
214+ * };
216215 * </pre>
217216 *
218217 * @param query the query string to execute, cannot be null
@@ -226,15 +225,14 @@ Stream<Object[]> query(@Nonnull final String query,
226225 * <p>
227226 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
228227 * <pre>
229- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
230- * Map.of("host", "server-a"), options)) {
228+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host", Map.of("host", "server-a"))) {
231229 * rows.forEach(row -> {
232230 * // process row
233- * }
234- * }) ;
231+ * })
232+ * };
235233 * </pre>
236234 *
237- * @param query the query string to execute, cannot be null
235+ * @param query the query string to execute, cannot be null
238236 * @param parameters query named parameters
239237 * @return Batches of rows returned by the query
240238 */
@@ -246,15 +244,14 @@ Stream<Object[]> query(@Nonnull final String query,
246244 * <p>
247245 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
248246 * <pre>
249- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
250- * Map.of("host", "server-a"), options)) {
247+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=intel", options)) {
251248 * rows.forEach(row -> {
252249 * // process row
253- * }
254- * }) ;
250+ * })
251+ * };
255252 * </pre>
256253 *
257- * @param query the query string to execute, cannot be null
254+ * @param query the query string to execute, cannot be null
258255 * @param options the options for querying data from InfluxDB
259256 * @return Batches of rows returned by the query
260257 */
@@ -266,12 +263,11 @@ Stream<Object[]> query(@Nonnull final String query,
266263 * <p>
267264 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
268265 * <pre>
269- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
270- * Map.of("host", "server-a"), options)) {
266+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host", Map.of("host", "server-a"), options)) {
271267 * rows.forEach(row -> {
272268 * // process row
273- * }
274- * }) ;
269+ * })
270+ * };
275271 * </pre>
276272 *
277273 * @param query the query string to execute, cannot be null
@@ -281,8 +277,8 @@ Stream<Object[]> query(@Nonnull final String query,
281277 */
282278 @ Nonnull
283279 Stream <Map <String , Object >> queryRows (@ Nonnull final String query ,
284- @ Nonnull final Map <String , Object > parameters ,
285- @ Nonnull final QueryOptions options );
280+ @ Nonnull final Map <String , Object > parameters ,
281+ @ Nonnull final QueryOptions options );
286282
287283 /**
288284 * Query data from InfluxDB IOx into Point structure using FlightSQL.
0 commit comments