public Stream<PointValues> query(final String measurement, final String query) {
        return influxDb.queryPoints(query, new QueryOptions(Objects.requireNonNull(clientConfig.getDatabase())));
    }
Query stream.

@param measurement the measurement
@param query       the query
@return the stream
support/cas-server-support-influxdb-core/src/main/java/org/apereo/cas/influxdb/InfluxDbConnectionFactory.java