@@ -187,12 +187,11 @@ Stream<Object[]> query(@Nonnull final String query,
187187 * <p>
188188 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
189189 * <pre>
190- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
191- * Map.of("host", "server-a"), options)) {
190+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=intel")) {
192191 * rows.forEach(row -> {
193192 * // process row
194- * }
195- * }) ;
193+ * });
194+ * };
196195 * </pre>
197196 *
198197 * @param query the query string to execute, cannot be null
@@ -206,15 +205,14 @@ Stream<Object[]> query(@Nonnull final String query,
206205 * <p>
207206 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
208207 * <pre>
209- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
210- * Map.of("host", "server-a"), options)) {
208+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host", Map.of("host", "server-a"))) {
211209 * rows.forEach(row -> {
212210 * // process row
213- * }
214- * }) ;
211+ * })
212+ * };
215213 * </pre>
216214 *
217- * @param query the query string to execute, cannot be null
215+ * @param query the query string to execute, cannot be null
218216 * @param parameters query named parameters
219217 * @return Batches of rows returned by the query
220218 */
@@ -226,15 +224,14 @@ Stream<Object[]> query(@Nonnull final String query,
226224 * <p>
227225 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
228226 * <pre>
229- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
230- * Map.of("host", "server-a"), options)) {
227+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=intel", options)) {
231228 * rows.forEach(row -> {
232229 * // process row
233- * }
234- * }) ;
230+ * })
231+ * };
235232 * </pre>
236233 *
237- * @param query the query string to execute, cannot be null
234+ * @param query the query string to execute, cannot be null
238235 * @param options the options for querying data from InfluxDB
239236 * @return Batches of rows returned by the query
240237 */
@@ -246,12 +243,11 @@ Stream<Object[]> query(@Nonnull final String query,
246243 * <p>
247244 * The result stream should be closed after use, you can use try-resource pattern to close it automatically:
248245 * <pre>
249- * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host",
250- * Map.of("host", "server-a"), options)) {
246+ * try (Stream<Map<String, Object>> rows = client.queryRows("select * from cpu where host=$host", Map.of("host", "server-a"), options)) {
251247 * rows.forEach(row -> {
252248 * // process row
253- * }
254- * }) ;
249+ * })
250+ * };
255251 * </pre>
256252 *
257253 * @param query the query string to execute, cannot be null
@@ -261,8 +257,8 @@ Stream<Object[]> query(@Nonnull final String query,
261257 */
262258 @ Nonnull
263259 Stream <Map <String , Object >> queryRows (@ Nonnull final String query ,
264- @ Nonnull final Map <String , Object > parameters ,
265- @ Nonnull final QueryOptions options );
260+ @ Nonnull final Map <String , Object > parameters ,
261+ @ Nonnull final QueryOptions options );
266262
267263 /**
268264 * Query data from InfluxDB IOx into Point structure using FlightSQL.
0 commit comments